Oracle 分散式資料同步方案選型指南：從 ETL 到高級復寫

方案分類總覽

Oracle 內建即時同步深度解析

方案 A：DB Link + 儲存程序 + Job

-- 1. 建立 DB Link
CREATE DATABASE LINK remote_db
CONNECT TO sync_user IDENTIFIED BY pwd
USING '(DESCRIPTION=(ADDRESS=(PROTOCOL=TCP)(HOST=10.1.1.2)(PORT=1521))(CONNECT_DATA=(SERVICE_NAME=ORCL)))';

-- 2. 同步儲存程序
CREATE OR REPLACE PROCEDURE sync_orders IS
BEGIN
    MERGE INTO local_orders t
    USING (SELECT * FROM orders@remote_db WHERE sync_flag = 'N') s
    ON (t.order_id = s.order_id)
    WHEN MATCHED THEN UPDATE SET t.qty = s.qty, t.amt = s.amt
    WHEN NOT MATCHED THEN INSERT VALUES (s.order_id, s.qty, s.amt);
    
    UPDATE orders@remote_db SET sync_flag = 'Y' WHERE sync_flag = 'N';
    COMMIT;
EXCEPTION WHEN OTHERS THEN ROLLBACK; RAISE;
END;

-- 3. 排程執行
BEGIN
    DBMS_SCHEDULER.CREATE_JOB(
        job_name => 'JOB_SYNC_ORDERS',
        job_type => 'STORED_PROCEDURE',
        job_action => 'SYNC_ORDERS',
        start_date => SYSTIMESTAMP,
        repeat_interval => 'FREQ=MINUTELY; INTERVAL=5',
        enabled => TRUE);
END;

方案 B：高級復寫 - 企業級雙向同步

核心概念

• Replication Object：表、索引、檢視、程序等
• Replication Group：物件邏輯分組，一物件屬一群組
• Master Sites：多主節點，皆可讀寫
• Propagation Mode：
  • 非同步：延遲 RPC 隊列，Store-and-Forward
  • 同步：兩階段提交，強一致性，高網路依賴
  • 程序式：Wrapper 封裝，減少網路傳輸

建立步驟 (主定義站點執行)

-- 1. 環境準備：repadmin 用戶、權限、GLOBAL_NAMES=TRUE
-- 2. 建立雙向 DB Link (名稱必須 = GLOBAL_NAME)
-- 3. 建立復寫群組
BEGIN
    DBMS_REPCAT.CREATE_MASTER_REPGROUP(
        gname => 'ORDER_RG',
        qualifier => '',
        group_comment => '訂單雙向同步');
END;

-- 4. 加入復寫物件 (以 TABLE 為例)
BEGIN
    DBMS_REPCAT.CREATE_MASTER_REPOBJECT(
        gname => 'ORDER_RG',
        type => 'TABLE',
        oname => 'ORDERS',
        sname => 'SCOTT',
        copy_rows => FALSE,
        use_existing_object => TRUE);
END;

-- 5. 產生復寫支援 (觸發器、封裝)
BEGIN
    DBMS_REPCAT.GENERATE_REPLICATION_SUPPORT(
        sname => 'SCOTT', oname => 'ORDERS', type => 'TABLE');
END;

-- 6. 加入其他 Master 站點
BEGIN
    DBMS_REPCAT.ADD_MASTER_DATABASE(
        gname => 'ORDER_RG',
        master => 'REMOTE_DB',
        use_existing_objects => TRUE,
        copy_rows => FALSE,
        propagation_mode => 'ASYNCHRONOUS');
END;

-- 7. 啟動復寫活動
BEGIN
    DBMS_REPCAT.RESUME_MASTER_ACTIVITY(gname => 'ORDER_RG');
END;

常見錯誤與對策

選型建議

1. 單向、批次、大量 → SQL*Loader / Data Pump / ETL
2. 單向、即時、少量 → DB Link + Procedure + Job
3. 雙向、即時、多節點、結構複雜 → 高級復寫
4. 異構/跨平台 → GoldenGate / XStreams / Kafka CDC
5. 雲原生/微服務 → 事件驅動架構 (Outbox Pattern + CDC)

高級復寫雖強大，但維護複雜度高，12c 後建議改用 GoldenGate 或 Active Data Guard 實現即時雙向同步。