需求:同步不同服务器上的数据库表的数据。

说明:现有服务器A,服务器B。需要在插入(修改|删除)A上的用户数据表sourceTable的同时,操作B上用户表remoteTable与A中一致;如:在项目A中注册用户后,需要在B中也可以登录。

接下来就使用mysql的Federated引擎以及触发器实现该需求。

Federated引擎:Federated就像他的名字所说“联盟”,其作用就是把两个不同区域的数据库联系起来,以至可以访问在远程数据库的表中的数据,而不是本地的表。

步骤:

一:检查本地mysql是否支持Federated数据引擎

执行    show ENGINES; 语句

49bcdee2a67827bcf877311c59c13b12.png

Support值为NO,说明未支持该引擎。需修改mysql的配置文件进行设置。

找到mysql的配置文件,在[mysqld]后添加federated即可;添加完成,重启mysql服务再次查询该引擎状态为YES即为支持。

0f9bb7bed7dcba9ec95dfdcb71cf72d1.png

4309824526946a66a36253657e8cd180.png

二:在本地数据库中创建一个可以映射远程表数据的桥接表 [结构与remoteTable一致]

注意:该表与远程服务器中需要同步数据的表结构一致(创建表结构即可,表数据会映射过来)

导出远程服务器表结构,并设置Federated引擎以及需要连接的远程服务地址及表名。具体如下:

45f235c2c8377662ccaebafb95c4e9e9.png

DROp TABLE IF EXISTS `表名`;

CREATE TABLE `表名`  (

字段信息

) ENGINE=InnoDB CHARACTER SET = utf8 COLLATE = utf8_general_ci COMMENT = '表描述' ROW_FORMAT = Compact

ENGINE=FEDERATED  CONNECTION = 'mysql://user:password@ip:port/databaseName/tableName';

创建完成后,如果远程服务器的数据表中存在数据,会被映射到本地。

三:在本地创建触发表(sourceTable)

四:创建触发器

7a0edfd02a43f6596026f925deaf2f42.png

-- 插入

drop trigger if exists insert_user;

create trigger insert_user

after insert on 触发表

for each row

begin

insert into 桥接表(字段名)

values(new.触发表的字段名);

end;

-- 删除

-- 删除

drop trigger if exists delete_user;

create trigger 触发表

after delete on fd_enterprise

for each row

begin

delete from 桥接表 where ID=old.ID;

end;

至此,所有步骤完成;

可进行验证;向sourceTable表中插入或删除数据,远程库上的表数据同步增删。

Logo

腾讯云面向开发者汇聚海量精品云计算使用和开发经验,营造开放的云计算技术生态圈。

更多推荐