mysql 执行触发器,实现跨服务器的表数据同步

时间:2024-03-31 17:46:30

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

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

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

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

步骤:

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

                  执行    show ENGINES; 语句

mysql 执行触发器,实现跨服务器的表数据同步

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

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

mysql 执行触发器,实现跨服务器的表数据同步

mysql 执行触发器,实现跨服务器的表数据同步

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

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

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

mysql 执行触发器,实现跨服务器的表数据同步

DROP TABLE IF EXISTS `表名`;
CREATE TABLE `表名`  (

  字段信息
  
) ENGINE=InnoDB CHARACTER SET = utf8 COLLATE = utf8_general_ci COMMENT = '表描述' ROW_FORMAT = Compact 
ENGINE=FEDERATED  CONNECTION = 'mysql://user:[email protected]:port/databaseName/tableName';

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

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

四:创建触发器

mysql 执行触发器,实现跨服务器的表数据同步

-- 插入

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表中插入或删除数据,远程库上的表数据同步增删。