为 postgresql 中的每个新插入创建触发器

Question

我在两个不同的数据库中有两个表 table1 和 table2。现在我创建了一个触发器，每当在 table1 中插入新行时，它将插入到 table2 中。下面是我的触发器

CREATE TRIGGER sync_user_table AFTER INSERT ON table1
for each row execute procedure sync_and_maintain_users_table()

CREATE OR REPLACE function sync_and_maintain_users_table()
returns trigger as
$BODY$
begin
    insert into global_db.public.table2
    values (user_uuid, user_registration_date, user_service_provider);
end;
$BODY$
language plpgsql;

但上述触发器不起作用。我也没有收到任何错误，我不确定出了什么问题。

Answer 1

创建触发器时可能没有错误，但运行时可能会出现错误：

CREATE OR REPLACE function sync_and_maintain_users_table()
returns trigger as
$BODY$
begin
    insert into global_db.public.table2
    values (user_uuid, user_registration_date, user_service_provider);
end;
$BODY$
language plpgsql;
CREATE FUNCTION

CREATE TRIGGER sync_user_table AFTER INSERT ON table1
for each row execute procedure sync_and_maintain_users_table();
CREATE TRIGGER

insert into table1 values(1);
ERROR:  cross-database references are not implemented: "global_db.public.table2"
LINE 1: insert into global_db.public.table2
                    ^
QUERY:  insert into global_db.public.table2
    values (user_uuid, user_registration_date, user_service_provider)
CONTEXT:  PL/pgSQL function sync_and_maintain_users_table() line 3 at SQL statement

在 PostgreSQL 中，您不能使用 database.schema.object 语法直接引用另一个数据库。

如果你解决了这个问题，你会遇到另一个错误：

CREATE OR REPLACE function sync_and_maintain_users_table()
returns trigger as
$BODY$
begin
    insert into public.table2
    values (user_uuid, user_registration_date, user_service_provider);
end;
$BODY$
language plpgsql;
CREATE FUNCTION

insert into table1 values(1);
ERROR:  column "user_uuid" does not exist
LINE 2:     values (user_uuid, user_registration_date, user_service_...
                    ^
HINT:  There is a column named "user_uuid" in table "table2", but it cannot be referenced from this part of the query.
QUERY:  insert into public.table2
    values (user_uuid, user_registration_date, user_service_provider)
CONTEXT:  PL/pgSQL function sync_and_maintain_users_table() line 3 at SQL statement

您需要添加代码来初始化 VALUES 子句中使用的变量。 请参阅https://www.postgresql.org/docs/12/plpgsql-trigger.html 中的示例。