怎样编写SQL触发器实现跨数据库的数据自动同步-SQL-PHP中文网

postgresql用dblink+触发器跨库同步可行但需严控连接与事务：必须显式管理dblink_connect/disconnect，避免连接堆积；生产环境禁用明文密码，改用foreign server+user mapping；sql字段顺序须严格匹配目标表，update/delete需防主键冲突，且务必捕获异常并return new。

怎样编写sql触发器实现跨数据库的数据自动同步

PostgreSQL 用 dblink + 触发器同步跨库表数据

直接能用，但必须注意连接管理与事务边界。源库触发器执行时，dblink_connect() 建立的是会话级连接，同一事务中多次调用不会自动复用，也不自动关闭；若不显式 dblink_disconnect()，连接可能堆积或超时失败。

常见错误现象：ERROR: connection to server was lost 或 could not establish connection，多因目标库地址/密码写错，或防火墙拦截 5432 端口；更隐蔽的是未处理 UPDATE 和 DELETE 时目标表主键冲突或缺失导致的 SQL 报错，触发器会静默失败（除非加 EXCEPTION 捕获）。

源库必须先执行 CREATE EXTENSION IF NOT EXISTS dblink;
连接字符串里避免硬编码密码，生产环境建议用 USER MAPPING + FOREIGN SERVER 方式替代明文 password=xxx
PERFORM dblink_exec(...) 中的 SQL 必须完整、字段顺序严格匹配目标表，NEW.* 不能直接用于含默认值或生成列的目标表
触发器函数末尾务必 RETURN NEW;（AFTER 类型）或 RETURN NULL;（INSTEAD OF），否则可能中断主事务

SQL Server 用链接服务器 + AFTER 触发器同步跨实例表

链接服务器是 SQL Server 原生支持跨实例访问的机制，但触发器内调用远程表性能敏感，且容易因网络抖动或目标库锁表导致源库事务长时间阻塞。

典型踩坑点：触发器里直接写 INSERT INTO LinkName.DB.dbo.Table ... SELECT * FROM inserted，一旦目标库不可达，整个源库 INSERT 操作会卡住并最终超时回滚；更麻烦的是，inserted 和 deleted 表只在当前触发器作用域有效，无法跨批处理，批量操作（如 UPDATE TOP(1000)）可能漏同步。

创建链接服务器后，务必用 SELECT TOP 1 * FROM LinkName.DB.dbo.Table 手动验证连通性
触发器开头加上 SET XACT_ABORT ON;，确保远程失败时本地事务能干净回滚
避免在触发器中做复杂计算或循环，尤其不要对 inserted 表逐行调用远程 INSERT —— 改用单条 INSERT ... SELECT 批量同步
DELETE 同步时，必须用 deleted 表的主键条件，不能依赖业务字段（如 WHERE name = OLD.name 可能误删）

MySQL 不支持跨库触发器直接写远程表

MySQL 的触发器作用域严格限定在当前实例内，CREATE TRIGGER 语句不允许出现其他实例的数据库名或 IP 地址。所谓“跨库同步”，实际只能靠外部工具补位，比如用 mysqldump --where 定时导出+导入，或监听 binlog（通过 mysqlbinlog 或 Debezium）解析变更再投递。