如何解决更新列特定触发器的最佳做法
欢迎 Oracle 专家
在 Oracle 12 数据库中(已计划升级;-))我们设置了不同的表,通过“更新后”触发器更新公共基表,如下所示:
Search_Flat | |||
---|---|---|---|
身份证 | Field_A | Field_B | Field_C |
现在 table1 包含 n 列,假设 n 中有 2 个与 Search_Flat 表相关。由于 table1 的更新可能只影响与 Seach_Flat 无关的列,我们希望向触发器添加检查。所以我们的第一种方法如下:
CREATE OR REPLACE TRIGGER tr_tbl_1_au_search
AFTER UPDATE OF
field_a,field_b
ON schemauser.search_flat
FOR EACH ROW
BEGIN
IF :new.field_a <> :old.field_a THEN
UPDATE schemauser.search_flat SET field_a = :new.field_a WHERE id = :new.ID;
END IF;
IF :new.field_b <> :old.field_b THEN
UPDATE schemauser.search_flat SET field_b = :new.field_b WHERE id = :new.ID;
END IF;
END;
或者,我们也可以设置触发器,如下所示:
CREATE OR REPLACE TRIGGER tr_tbl_1_au_search
AFTER UPDATE OF
field_a,field_b
ON schemauser.search_flat
FOR EACH ROW
BEGIN
IF :new.field_a <> :old.field_a OR :new.field_b <> :old.field_b THEN
UPDATE schemauser.search_flat
SET field_a = :new.field_a,field_b = :new.field_b
WHERE id = :new.ID;
END IF;
END;
现在的问题是关于触发器本身的设置。哪种方法更好:
- search_flat 行的锁定时间
- 受影响组件(即 table_1、trigger 和 search_flat)的整体性能
在生产中,我们讨论了 4 个表,每个表有 10 个字段,每个字段都在触发器中考虑。我们有独立的应用服务器访问共享数据库,同时更新 4 个表。我们不时检测到以下错误,这就是我们不想优化触发器的原因:
ORA-02049:超时:分布式事务等待锁定
旁注: 由于性能原因,我们选择了这种设置而不是视图或物化视图,因为 gui 中使用的基表要求立即更新,并且需要4 个馈送表太高,无法在更新时更新物化视图。
我期待着讨论和你的想法。
解决方法
据我了解您的帖子,您有 4 个要搜索的活动表(称为“table1”、“table2”等),但是从它们查询太慢,因此您想维护一个,扁平化表来代替搜索,并有触发器来保持扁平化表始终是最新的。 您想知道两种触发方法中哪一种更好。
我认为答案是“都不是”,因为两者都容易出现死锁。想象一下这个场景
用户 1 -
UPDATE table1
SET field_a = 500
WHERE <condition effecting 200 distinct IDs>
用户 2 几乎同时-
UPDATE table1
SET field_b = 700
WHERE <condition effecting 200 distinct IDs>
触发器开始处理。您无法控制更新行的顺序。也许它是这样的:
用户 1 的触发器,时间索引 100 ->
UPDATE search_flat SET field_a = 500 WHERE id = 90;
用户 2 的触发器,时间索引 101 ->
UPDATE search_flat SET field_b = 700 WHERE id = 91;
用户 1 的触发器,时间索引 102 ->
UPDATE search_flat SET field_a = 500 WHERE id = 91; (waits on user 2's session)
用户 2 的触发器,时间索引 103 ->
UPDATE search_flat SET field_b = 700 WHERE id = 90; (deadlock error)
用户 2 的原始更新失败并回滚。
您有多个并发进程,所有进程都更新 search_flat
中的同一组行,而无法控制处理顺序。这是导致死锁的秘诀。
如果您想安全地执行此操作,则不应考虑您概述的 FOR EACH ROW
触发器方法。相反,请创建一个复合触发器来执行此操作。
这里有一些示例代码来说明这个想法。请务必阅读评论。
-- Aside: consider setting this at the system level if on 12.2 or later
-- alter system set temp_undo_enabled=false;
CREATE GLOBAL TEMPORARY TABLE table1_updates_gtt (
id NUMBER,field_a VARCHAR2(80),field_b VARCHAR2(80)
) ON COMMIT DELETE ROWS;
CREATE GLOBAL TEMPORARY TABLE table2_updates_gtt (
id NUMBER,field_a VARCHAR2(80)
) ON COMMIT DELETE ROWS;
-- .. so on for table3 and 4.
CREATE OR REPLACE TRIGGER table1_search_maint_trg
FOR INSERT OR UPDATE OR DELETE ON table1 -- with similar compound triggers for table2,3,4.
COMPOUND TRIGGER
AFTER EACH ROW IS
BEGIN
-- Update the table-1 specific GTT with the changes.
CASE WHEN INSERTING OR UPDATING THEN
-- Assumes ID is immutable primary key
INSERT INTO table1_updates_gtt (id,field_a) VALUES (:new.id,:new.field_a);
WHEN DELETING THEN
INSERT INTO table1_updates_gtt (id,field_a) VALUES (:old.id,null); -- or figure out what you want to do about deletes.
END CASE;
END AFTER EACH ROW;
AFTER STATEMENT IS
BEGIN
-- Write the data from the GTT to the search_flat table.
-- NOTE: The ORDER BY in the next line is what saves us from deadlocks.
FOR r IN ( SELECT id,field_a,field_b FROM table1_updates_gtt ORDER BY id ) LOOP
-- TODO: replace with BULK processing for better performance,if DMLs can affect a lot of rows
UPDATE search_flat sf
SET sf.field_a = r.field_a,sf.field_b = r.field_b
WHERE sf.id = r.id
AND ( sf.field_a <> r.field_a
OR (sf.field_a IS NULL AND r.field_a IS NOT NULL)
OR (sf.field_a IS NOT NULL AND r.field_a IS NULL)
OR sf.field_b <> r.field_b
OR (sf.field_b IS NULL AND r.field_b IS NOT NULL)
OR (sf.field_b IS NOT NULL AND r.field_b IS NULL)
);
END LOOP;
END AFTER STATEMENT;
END table1_search_maint_trg;
此外,正如许多评论者指出的那样,为此使用物化视图可能更好。如果您使用的是 12.2 或更高版本,实时物化视图(又名“启用查询计算”)为此类事情提供了很多希望。您的应用程序和实时搜索结果不会产生 COMMIT
开销。只是如果基础表最近有很多更新,搜索时间会稍微缩短。
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。