问题描述
我想创建一个触发器函数,它复制最近更新行的某些列并删除旧数据。之后,我想将复制的列插入到同一行的同一个表中(覆盖)。我需要插入数据,因为此函数将嵌入到现有程序中,并带有预定义的触发器。
这就是我目前所拥有的:
CREATE OR REPLACE FUNCTION update_table()
RETURNS TRIGGER AS
$func$
BEGIN
WITH tmp AS (DELETE FROM table
WHERE table.id = NEW.id
RETURNING id,geom )
INSERT INTO table (id,geom) SELECT * FROM tmp;
END;
$func$ language plpgsql;
CREATE TRIGGER T_update
AFTER UPDATE OF geom ON table
EXECUTE PROCEDURE update_table();
但我收到错误消息:
错误:无法对关系“表”执行 DELETE RETURNING
提示:您需要一个带有 RETURNING 子句的无条件 ON DELETE DO INSTEAD 规则。
为什么我应该在这里使用规则?
我使用的是 Postgresql 9.6
更新:
稍微澄清一下。当我的表 (id,geom
) 中有两列时,更新 geom
后,我想复制此(新)行并将其插入同一个表中,同时覆盖更新的行。 (我对更新前的任何值都不感兴趣)我知道这很奇怪,但我需要再次插入这一行,因为我嵌入此函数的程序会监听 INSERT
语句并且无法更改由我。
解决方法
更新行后,其旧值将不再可用。因此,如果您只是想在更新时保留旧行,您需要创建一个 BEFORE UPDATE
触发器,以便您仍然可以访问 OLD
值并创建一个新行,例如>
CREATE TABLE t (id int,geom geometry(point,4326));
CREATE OR REPLACE FUNCTION update_table() RETURNS TRIGGER AS $$
BEGIN
INSERT INTO t (id,geom) VALUES (OLD.id,OLD.geom);
RETURN NEW;
END; $$ LANGUAGE plpgsql;
CREATE TRIGGER t_update
BEFORE UPDATE OF geom ON t FOR EACH ROW EXECUTE PROCEDURE update_table();
INSERT INTO t VALUES (1,'SRID=4326;POINT(1 1)');
如果您更新记录 1
..
UPDATE t SET geom = 'SRID=4326;POINT(2 2)',id = 2 WHERE id = 1;
UPDATE t SET geom = 'SRID=4326;POINT(3 3)',id = 3 WHERE id = 2;
...您在同一张表中获得了一条新记录
SELECT id,ST_AsText(geom) FROM t;
id | st_astext
----+------------
1 | POINT(1 1)
2 | POINT(2 2)
3 | POINT(3 3)
演示:db<>fiddle
无关注意:考虑升级您的 PostgreSQL 版本! 9.6 将于 2021 年 11 月到达 EOL。
,首先感谢@JimJones 的回答。我想发布他为此目的修改的答案。此代码通过插入其自身的副本然后删除旧的副本来“覆盖”更新的行。这样我就可以在 INSERT
上触发。
CREATE TABLE t (Unique_id SERIAL,id int,geom) VALUES (NEW.id,NEW.geom);
RETURN NEW;
END;
$$ LANGUAGE plpgsql;
CREATE TRIGGER t_update
BEFORE UPDATE OF geom ON t FOR EACH ROW EXECUTE PROCEDURE update_table();
CREATE OR REPLACE FUNCTION delete_table() RETURNS TRIGGER AS $$
BEGIN
DELETE FROM t a
USING t b
WHERE a.Unique_id < b.Unique_id
AND a.geom = b.geom;
RETURN NEW;
END;
$$ LANGUAGE plpgsql;
CREATE TRIGGER t_delete
AFTER UPDATE OF geom ON t FOR EACH ROW EXECUTE PROCEDURE delete_table();
INSERT INTO t VALUES (1,1,'SRID=4326;POINT(1 1)');
UPDATE t SET geom = 'SRID=4326;POINT(2 2)' WHERE id = 1;