如何从 PostgreSQL 中的触发器访问其他 INSERTed/UPDATEd 行？

Question

MS SQL 中的解决方案

MS SQL触发功能具有deleted与inserted在其中受操作的所有行存储系统表。您可以计算更新的行数：

set @updatedCount = (select count(*) from deleted)

或找出最小值：

set @updatedMinimumCol1 = (select min(col1) from deleted)

---

PostgreSQL 的问题

对于FOR EACH ROW触发器，我可以使用 OLD 和 NEW 系统记录，但它们每次调用触发器只存储 1 行。触发器的调用是分开的，所以如果用户更新 10 行，触发器将被调用 10 次，但每次我只能知道 1 个当前行，而不是所有 10 行。

因为FOR EACH STATEMENT我根本不知道任何访问更新行的机制。我使用 PostgreSQL v9.6，OLD TABLE并NEW TABLE在 v10 中引入。

PostgreSQL 不允许在语句级触发器中引用旧表和新表，即包含所有旧行和/或新行的表，这些表由 SQL 标准中的 OLD TABLE 和 NEW TABLE 子句引用。

---

尝试使用 transaction_timestamp() 附加列

我可以DEFAULT transaction_timestamp()向主表添加特殊列，然后使用它来区分刚刚更新的行与其他行，但这不是解决方案，因为多个INSERTs/UPDATEs可以在一个事务中并且它们将具有相同的事务时间戳。可能我可以在每个语句之后清除触发器中的这个时间戳列以避免这个问题，但是如果这种清除会再次发出更新触发器，如何做到这一点 - 将是无限更新触发器调用。

所以，这次尝试失败了。

---

PostgreSQL 中的错误解决方案

我知道的唯一方法是：

首先，使用FOR EACH ROW触发器像聚合函数一样收集当前的统计信息（min 和 count）。我使用临时表在调用之间存储它（此触发器每行调用 1 次）。但是我们不知道哪一行是最后的（什么时候使用这个统计数据）。

CREATE TEMP TABLE IF NOT EXISTS _stats (
  _current_min   int,
  _current_count int
) ON COMMIT DROP;

IF EXISTS(SELECT 1 FROM _stats LIMIT 1) THEN
  --Current row is not first, there is statistics for previous rows.
  UPDATE _stats
  SET _current_min   = (CASE WHEN NEW.col1 < _current_min THEN NEW.col1
                        ELSE _current_min END)
    , _current_count = _current_count + 1;
ELSE
  --There is no stats because current row is first for this INSERT/UPDATE
  INSERT INTO _stats (_current_min, _current_count)
  VALUES (NEW.col1, 1);
END IF;

其次，使用FOR EACH STATEMENT触发器来使用收集的统计信息。不要忘记清除临时表（如果用户将在一个事务中运行多个 INSERT/UPDATE，旧的统计信息将保留在临时表中并破坏所有接下来的计算！）。

对于更复杂的任务，我们可以创建临时表inserted，并deleted在相同的方式_stats。

---

解决方法

在 PostgreSQL 中，我们可以使用 INSERT/UPDATE/DELETE 的 RETURNING 子句来获取所有受操作影响的行的新值。然后我们可以使用它们进行操作，但是每个带有 INSERTs/UPDATEs 的函数都必须实现这项技术 ===> 1. 带有此类 INSERTs/UPDATEs 的函数中的附加代码 - RETURNING 的重复；2.我们可以忘记将这种技术实现到新功能中；3. 数据将被破坏，因为不会自动调用所需的操作（就像触发器一样）。

---

问题

也许，您知道访问受 INSERT/UPDATE 影响的所有行的更好方法吗？

Answer 1

查看文档，您应该能够从语句触发器访问旧记录和新记录：

CREATE TRIGGER some_table_update_trigger
  AFTER UPDATE ON some_table
  REFERENCING NEW TABLE AS newtab OLD TABLE AS oldtab
  FOR EACH STATEMENT
  EXECUTE PROCEDURE do_something_with_newtab_and_oldtab();