如何利用DB Link实现实时数据同步

利用 DB Link 实现实时数据同步的可行方案

一、方案总览与选型

• 基于触发器的“准实时”同步：在源库对业务表建立 AFTER INSERT/UPDATE/DELETE 触发器，通过 DB Link 将变更直接写入目标库。优点是变更即触发、时延低；注意触发器内避免长事务与远程依赖，必要时使用自治事务记录日志。适合大多数 OLTP 的点对点同步。
• 基于物化视图日志的快速刷新：在源库为目标表建 物化视图日志（Materialized View Log），在目标库建 快速刷新的物化视图（Fast Refresh on Commit），提交即增量刷新。优点是提交级近实时、对应用透明；要求主键或行 ID、版本列等以支持快速刷新，且对 DDL 较敏感。
• 定时/批量合并（补充）：当对“强实时”要求不高或网络抖动时，可用 DBMS_JOB/DBMS_SCHEDULER + MERGE 做分钟级或秒级批处理，以吞吐换稳定。

二、方案一 触发器 + DB Link 的落地步骤

• 前置准备
  • 网络与权限：两端网络可达（开放 1521 等端口），源库用户具备创建 DB Link、触发器及对目标对象的 INSERT/UPDATE/DELETE 权限；目标库用户具备对应 DML 权限。
  • 连接配置：在源库 tnsnames.ora 配置目标库连接串（示例：HOST、PORT、SERVICE_NAME），保证本地可解析。
• 创建 DB Link
  • 语法示例：CREATE [PUBLIC] DATABASE LINK link_name CONNECT TO target_user IDENTIFIED BY target_password USING ‘tns_name’;
  • 连通性测试：SELECT SYSTIMESTAMP FROM dual@link_name;
• 建立同义词（可选）
  • 为远程表创建同义词，简化触发器写法：CREATE OR REPLACE SYNONYM remote_tab FOR schema.remote_tab@link_name;
• 创建触发器
  • 要点：按业务主键判断存在性，决定是 INSERT 还是 UPDATE；删除时先写历史再删除；避免触发器中再次查询触发表导致 ORA-04091，必要时使用 PRAGMA AUTONOMOUS_TRANSACTION 写入日志表（仅日志，不回滚主事务）。
  • 示例（简化版，省略异常与日志）：

    CREATE OR REPLACE TRIGGER trg_a_test
    AFTER INSERT OR UPDATE OR DELETE ON a_test
    FOR EACH ROW
    BEGIN
      CASE
        WHEN INSERTING THEN
          INSERT INTO a_test@MYLINK (id, name, age)
          VALUES (:new.id, :new.name, :new.age);
        WHEN UPDATING THEN
          UPDATE a_test@MYLINK t
          SET t.name = :new.name, t.age = :new.age
          WHERE t.id = :old.id;
        WHEN DELETING THEN
          DELETE FROM a_test@MYLINK t WHERE t.id = :old.id;
      END CASE;
    END;
    /
    

• 验证与调优
  • 验证：在源库执行 INSERT/UPDATE/DELETE，在目标库查询确认变更是否到达。
  • 调优：控制单次远程调用粒度（批量提交、减少往返），避免触发器中远程聚合/排序，必要时将大事务拆分。

三、方案二 物化视图日志 + 快速刷新（提交级近实时）

• 适用场景：目标库需要“查询即最新”的汇总/明细视图，且源库支持 物化视图日志 与 快速刷新。
• 实施步骤
  • 源库：为目标表创建物化视图日志（建议基于主键/行 ID）

    CREATE MATERIALIZED VIEW LOG ON a_test
    WITH PRIMARY KEY, ROWID
    INCLUDING NEW VALUES;
    

  • 目标库：创建快速刷新的物化视图（ON COMMIT 提交即刷新）

    CREATE MATERIALIZED VIEW mv_a_test
    REFRESH FAST ON COMMIT
    AS
    SELECT id, name, age FROM a_test@MYLINK;
    

  • 验证：源库提交后，目标库查询 mv_a_test 立即可见最新数据。
• 注意事项
  • 快速刷新依赖日志与基表结构稳定；DDL 需重建日志/视图。
  • 对高并发写入的源表，日志与刷新会带来一定负载，需结合分区、批量提交与资源计划评估。

四、方案对比与适用场景

五、关键注意事项与避坑

• 事务与一致性
  • 触发器跨库写入默认与业务事务同提交；若需“先落库后通知”，将远程写入放到自治事务仅写日志，主事务不依赖其成功，避免阻塞与不一致。
• 性能与网络
  • DB Link 远程调用代价高，触发器内避免远程聚合/排序；批量操作拆分提交；跨机房/公网需压缩与限流。
• 双向同步与环路
  • 双向同步需设计冲突解决与方向标记，避免触发器环路；更推荐“变更捕获 + 队列/日志”的解耦架构。
• 安全与合规
  • 避免明文口令，使用 Wallet 或安全凭据存储；最小权限原则；限制来源 IP 与可访问对象。
• 高可用与容错
  • 目标库不可达时应降级（写入本地队列表/告警），网络恢复后重放；对关键链路加监控与告警。
• 其他数据库
  • SQL Server 可通过 Linked Server 调用远程过程实现同步，但同样存在延迟与一致性挑战；可通过提高频率、定时任务与触发器优化，但强实时需谨慎评估。