详细解答可以参考官方帮助文档本小节简单介绍如何使用 DTS 提供订阅 SDK 进行 分布式关系型数据库服务 DRDS(以下简称 DRDS) 的订阅。
下载 Demo
首先,需要先下载 DTS 订阅 DRDS 数据变化 Demo 。使用解压工具,解压下载到本地的 Demo。
运行 Demo本 Demo 的运行方式与 “使用 Maven 依赖形式的 SDK” 章节中 Demo 的运行方式基本相同,区别仅在于,订阅 DRDS 的数据变化时,由于 DRDS 有逻辑数据库和逻辑表的概念,区别与一般的数据库名和表名,因此需要通过对应的方式获取 DRDS 的逻辑数据库名和逻辑表名,可以参考 Demo 中如下代码片段。
System.out.println("PrimaryKey Column Name:" + key); //DRDS 中物理数据库名和物理数据表名 System.out.println("Record DB Name:"+record.getDbname()+",Table Name:"+record.getTablename()); //DRDS 中逻辑数据库名和逻辑表名 System.out.println("Record Logical DB Name:"+record.getLogicalDbname()+",Table Name:"+record.getLogicalTablename());