Oracle 如何使用基于时间戳字段激活的触发器使两个表保持同步？

Question

我想进行一次性导入/导出以将数据从 TableA 复制到 TableB。但是，在一次性导入数据后，我需要使用触发器使表保持同步，直到我们准备好使用新表。

是否可以编写一个触发器，根据 tableA 中时间戳字段的值将数据从一个表复制到另一个表，或者在 systimestamp 上使用条件。属性上的触发器是首选，但如果不可能，那我可以去 systimestamp 吗？

我是 Oracle 的新手，如果有人能帮我想出这样的触发器，我将不胜感激。

TableA
CREATE TABLE user.tableA (
    attr1 ... NOT NULL,
    attr2 ...,
    ...,
    attrN TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
    CONSTRAINT tableA_PK PRIMARY KEY (attr1) ENABLE
 )

user.tableB is the same as user.tableA

需要想出一个触发器来将插入从 TableA 复制到 TableB。 下面的代码需要工作

CREATE TRIGGER user.sync_from_A_to_B
  AFTER INSERT ON user.tableA
  FOR EACH ROW
BEGIN
  if (systimestamp OR attrN >= to_timestamp('2021-07-31 00:00:00', 'YYYY-MM-DD HH24:MI:SS')
  then
    INSERT INTO user.tableB
         (
             attr1,
             attr2,
             ...,
             attrN
         )
         VALUES
         (
             :new.attr1,
             :new.attr1,
             :new....,
             :new.attrN
         )
  end if;
END;
/

Answer 1

使用本机功能同步两个表的便捷方法是创建materialized view，并在提交时快速刷新。本质上，它是一个表和查询定义来填充该表。然后，Oracle 在刷新时更新目标表（在您的情况下为on commit）。然后您可以删除物化视图并保留表（因此删除查询定义和对基表的任何依赖）以将您的应用程序重新定位到它。

SQL> set echo on
SQL> 
SQL> create table t_a (
  2    id primary key,
  3    val,
  4    str
  5  ) as
  6  select level, level, chr(32 + level)
  7  from dual
  8  connect by level < 4;

Table T_A created.
 
SQL> select * from t_a;

        ID        VAL STR 
---------- ---------- ----
         1          1 !   
         2          2 "   
         3          3 #   
 
SQL> create materialized view log on t_a
  2  with primary key /*To enable incremental updates*/;

Materialized view log T_A created.

SQL> create materialized view t_b
  2  refresh on commit fast
  3  as
  4  select * from t_a;

Materialized view T_B created.

SQL> select * from t_b;

        ID        VAL STR 
---------- ---------- ----
         1          1 !   
         2          2 "   
         3          3 #   

SQL> insert into t_a values(10, 11, 'W');

1 row inserted.

SQL> update t_a set val = 100 where id = 1;

1 row updated.

SQL> select * from t_b;

        ID        VAL STR 
---------- ---------- ----
         1          1 !   
         2          2 "   
         3          3 #   

SQL> /*Still no changes*/ 
SQL> commit;

Commit complete.
 
SQL> select * from t_b;

        ID        VAL STR 
---------- ---------- ----
         2          2 "   
         3          3 #   
         1        100 !   
        10         11 W   
 
SQL> /*Looks ok, we're moving to target table*/
SQL> drop materialized view t_b preserve table;

Materialized view T_B dropped.
 
SQL> drop table t_a;

Table T_A dropped.
 
SQL> select * from t_b;

        ID        VAL STR 
---------- ---------- ----
         2          2 "   
         3          3 #   
         1        100 !   
        10         11 W   

Answer 2

我猜测物化视图无法满足您的需求。确实，它比触发强制同步要好得多，但问题的关键似乎是直到我们准备好使用新表。 这意味着在未来某个时间源表 (tableA) 将被停止（删除？）。如果是这样，那么在那个时候物化视图刷新变得无效。
但是，您不需要后行触发器，而是后语句触发器。该触发器将直接从 TableA 插入到 TableB。

create trigger user.sync_from_a_to_b
  after insert on user.tablea 
begin
    insert into user.tableb
         (
             attr1,
             attr2,
             ...,
             attrn
         )
      select 
             attr1,
             attr2,
             ...,
             attrn
       from tablea 
      where attrn >= (select max attrn from tableb);  
end;

您面临的主要问题是同步还需要处理删除和更新。也许你最好的选择是两阶段方法。创建一个 物化视图，直到您准备好切换到新表。然后一次性直接从 MV 切换到新表。