mysql同一数据库不同表实时同步

1、在分析型数据库上创建目标表，数据更新类型为实时写入，字段名称和MySQL中的建议均相同；

2、在阿里云数据传输的控制台上创建数据订阅通道，并记录这个通道的ID；

3、 配置dts-ads-writer/app.conf文件，配置方式如下：所有配置均保存在app.conf中，运行前请保证配置正确；修改配置后，请重启writer，基本配置：

注意事项：

1、RDS

for

MySQL表和分析型数据库中表的主键定义必须完全一致；如果不一致会出现数据不一致问题。如果需要调整RDS/分析型数据库表的主键，建议先停止writer进程；

2、一个插件进程中分析型数据库db只能是一个，由adsJdbcUrl指定；

3、一个插件进程只能对应一个数据订阅通道；如果更新通道中的订阅对象时，需要重启进程。

GO

IF OBJECT_ID('history_data') IS NOT NULL

DROP TABLE history_data

GO

CREATE TABLE history_data

(DTIME DATE NULL,

 A NVARCHAR(50) NULL,

 B NVARCHAR(50) NULL,

 C NVARCHAR(50) NULL,

 cStyle NVARCHAR(10) NULL

 )

 GO

 IF OBJECT_ID('realtime_data') IS NOT NULL

DROP TABLE realtime_data

GO

CREATE TABLE realtime_data

(DTIME DATE NULL,

 A NVARCHAR(50) NULL,

 B NVARCHAR(50) NULL,

 C NVARCHAR(50) NULL

 )

 GO

 --创建触发器

 CREATE TRIGGER t_realtime_data

   ON  DBO.realtime_data

   AFTER INSERT,DELETE,UPDATE

AS 

BEGIN

-- SET NOCOUNT ON added to prevent extra result sets from

-- interfering with SELECT statements.

SET NOCOUNT ON

    --将插入的行　或者是修改后的行保存

    INSERT INTO history_data(DTIME,A,B,C,CSTYLE)

    SELECT DTIME,A,B,C,'INSERTED' FROM INSERTED

    --将删除的行　或者是修改前的行保存

    INSERT INTO history_data(DTIME,A,B,C,CSTYLE)

    SELECT DTIME,A,B,C,'DELETED' FROM DELETED

    -- Insert statements for trigger here

END

GO