Oracle跨Schema复制差异字段表所有DML数据的实现方法

该需求完全可以实现。跨Schema不属于同步阻碍，目标表B多出的额外字段只要提前明确赋值规则，就可以完整覆盖INSERT、UPDATE、DELETE三类DML操作产生的所有数据变更同步。
本次示例中表B比表A多出customer_id字段，只要提前确定该字段的生成规则（如序列自增、全局唯一ID、业务规则拼接等）即可正常同步。

根据业务对同步实时性、数据量、源库性能损耗的要求不同，可以选择以下4种落地方式：

方案1：行级触发器实时同步 #

该方案适合DML并发量不高、要求毫秒级实时同步的轻量化场景，实现成本最低。

1. 前置准备：给同步操作用户授予两个Schema下对应表的操作权限，提前确定customer_id的生成规则，比如创建自增序列：

-- 在SchemaB下创建customer_id对应的自增序列
CREATE SEQUENCE SchemaB.seq_customer_id START WITH 1 INCREMENT BY 1 NOCACHE NOCYCLE;

2. 在源表（SchemaA下的表A）上创建行级触发器，覆盖三类DML操作，跨Schema操作直接通过Schema名.表名的格式引用目标表即可：

CREATE OR REPLACE TRIGGER SchemaA.trg_sync_a_to_b
AFTER INSERT OR UPDATE OR DELETE ON SchemaA.table_a
FOR EACH ROW
BEGIN
  IF INSERTING THEN
    -- 插入操作：给额外字段按预设规则赋值，其余字段直接映射源表新值
    INSERT INTO SchemaB.table_b(
      customer_id,
      custome_name, 
      customer_desc,
      create_date,
      create_user,
      update_date,
      update_user
    ) VALUES (
      SchemaB.seq_customer_id.NEXTVAL,
      :NEW.custome_name,
      :NEW.customer_desc,
      :NEW.create_date,
      :NEW.create_user,
      :NEW.update_date,
      :NEW.update_user
    );
  ELSIF UPDATING THEN
    -- 更新操作：通过两表共有的唯一业务键匹配目标表记录，更新映射字段
    UPDATE SchemaB.table_b
    SET 
      custome_name = :NEW.custome_name,
      customer_desc = :NEW.customer_desc,
      create_date = :NEW.create_date,
      create_user = :NEW.create_user,
      update_date = :NEW.update_date,
      update_user = :NEW.update_user
    WHERE custome_name = :OLD.custome_name;
  ELSIF DELETING THEN
    -- 删除操作：通过相同的唯一业务键匹配删除目标表对应记录
    DELETE FROM SchemaB.table_b
    WHERE custome_name = :OLD.custome_name;
  END IF;
END;
/

注意：如果表A存在主键，优先用主键作为两表匹配的关联键，避免业务字段重复导致错改、错删数据。

方案2：物化视图准实时同步 #

该方案适合不想在源表创建触发器、对同步延迟容忍度在秒到分钟级的场景。直接在SchemaB下针对SchemaA的表A创建物化视图，创建物化视图日志后支持增量刷新，customer_id字段可以在视图查询逻辑中直接通过序列、函数生成赋值，设置定时刷新任务即可自动同步增量DML变更。

方案3：日志解析类工具高性能同步 #

该方案适合核心生产系统、DML并发高、数据量大、对源库性能影响要求极低的场景，常用工具为Oracle官方的GoldenGate（OGG）。实现逻辑是直接解析Oracle的Redo日志、归档日志捕获表A的所有DML变更，投递到目标端SchemaB的表B时，自动按预设规则给customer_id字段赋值，同步延迟在毫秒级，不会占用源库事务资源，不会对源表业务造成侵入。

方案4：定时任务增量同步 #

该方案适合对同步实时性要求不高（如小时级、天级同步）的场景。可以给表A新增更新时间戳字段，通过定时调度的存储过程，每次扫描上次同步时间点之后的增量变更数据，合并写入SchemaB的表B，新增记录时按规则给customer_id赋值即可，实现和维护成本最低。

• 首次开启增量同步前，必须先将表A的历史存量数据全量导入表B，避免出现数据遗漏
• 跨Schema操作前必须提前给操作用户分配对应表的读写权限，否则会触发权限不足报错
• 如果表B的额外字段设置了默认值，同步插入时可以不用显式赋值，直接走字段默认值逻辑即可
• 不要用可能重复的非唯一字段作为更新、删除操作的匹配键，避免出现批量误操作

内容的提问来源于stack exchange，提问作者Harish Manik