PostgreSQL中如何通过存储过程的插入触发器获取所有插入行？

在PostgreSQL中，你确实可以一次性获取插入的所有行，关键是使用语句级触发器而非行级触发器，并且要注意触发器只能调用触发器函数（不能直接调用存储过程）。以下是具体实现步骤：

1. 创建触发器函数 #

触发器函数负责获取本次插入的所有行，分组后写入tableB：

CREATE OR REPLACE FUNCTION Public.my_trigger_func()
RETURNS trigger
LANGUAGE plpgsql
AS $$
DECLARE
  inserted_ctids tid[];
BEGIN
  -- 提取本次插入行的ctid数组（ctid是PostgreSQL中行的物理位置标识）
  inserted_ctids := (pg_gettriggerdata()::json->>'new_ctids')::tid[];
  
  -- 获取本次插入的行，分组后插入tableB
  INSERT INTO Public."tableB" ("TrackCode", "count")
  SELECT "TrackCode", COUNT(*) AS "count"
  FROM Public."tableA"
  WHERE ctid = ANY(inserted_ctids)
  GROUP BY "TrackCode";
  
  RETURN NULL; -- 语句级触发器无需返回NEW/OLD，返回NULL即可
END;
$$;

2. 创建语句级触发器 #

创建一个语句级触发器，在每次INSERT操作完成后触发一次：

CREATE TRIGGER my_trigger
AFTER INSERT ON Public."tableA"
FOR EACH STATEMENT -- 标记为语句级触发器，一次性处理所有插入行
EXECUTE FUNCTION Public.my_trigger_func();

关键说明 #

• 语句级触发器：FOR EACH STATEMENT表示触发器会在整个INSERT语句执行完成后触发一次，不管你插入1行还是1000行，都只会执行一次触发器逻辑，正好满足你按trackCode分组的需求。
• 精准获取插入行：通过pg_gettriggerdata()获取本次插入行的ctid，再筛选tableA中的对应行，确保只处理本次INSERT操作产生的数据，不会包含其他事务或历史数据。
• 避免手动COMMIT：触发器会在INSERT的事务上下文内执行，不需要手动提交，去掉你原代码中的COMMIT;语句，否则会导致事务错误。

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