在过程触发器内动态插入记录

2024-03-28

我们正在寻求将我们的数据库转换为 Postgres (9.3.5),我对此没有经验,并且我正在尝试让我们的审计表启动并运行。我知道每个表都需要自己的触发器,但所有触发器都可以调用单个函数。

表上的触发器正在传递需要审核的列的列表,因为我们的某些列未被跟踪。

以下是我关注的一些帖子:
- https://stackoverflow.com/a/7915100/229897 https://stackoverflow.com/a/7915100/229897
- http://www.postgresql.org/docs/9.3/static/plpgsql-statements.html http://www.postgresql.org/docs/9.3/static/plpgsql-statements.html
- http://www.postgresql.org/docs/9.4/static/plpgsql-trigger.html http://www.postgresql.org/docs/9.4/static/plpgsql-trigger.html

当我运行此命令时,出现错误:错误:“$1”处或附近的语法错误

DROP TABLE IF EXISTS people;
DROP TABLE IF EXISTS a_people;

CREATE TABLE IF NOT EXISTS people (
  record_id  SERIAL PRIMARY KEY NOT NULL,
  first_name VARCHAR NOT NULL,
  last_name VARCHAR NOT NULL,
  last_updated_on TIMESTAMP NOT NULL DEFAULT  CURRENT_TIMESTAMP 
);

CREATE TABLE IF NOT EXISTS a_people (
  record_id  SERIAL PRIMARY KEY NOT NULL,
  a_record_id INT,
  first_name VARCHAR NULL,
  last_name VARCHAR NULL,
  last_updated_on TIMESTAMP
);
/******************************************************/
--the function
CREATE OR REPLACE FUNCTION audit_func()
RETURNS TRIGGER AS 
$BODY$  
    DECLARE 
        audit   TEXT := TG_TABLE_SCHEMA || '.a_' || TG_TABLE_NAME;
        cols    TEXT := TG_ARGV[0];
    BEGIN
        EXECUTE format('INSERT INTO %1$s(a_%2$s) SELECT %2$s FROM ($1)',  audit, cols) USING OLD;   
        NEW.last_updated_on = CURRENT_TIMESTAMP;
        RETURN NEW;
    END;
$BODY$
LANGUAGE plpgsql;
/******************************************************/
--the trigger calling the function to update inbound records
CREATE TRIGGER build_user_full_name_trg 
BEFORE UPDATE
ON people 
FOR EACH ROW WHEN (OLD.* IS DISTINCT FROM NEW.*)
EXECUTE PROCEDURE audit_func('record_id,first_name,last_name');
/******************************************************/
INSERT INTO people (first_name, last_name) VALUES ('George','Lincoln');
UPDATE people SET last_name = 'Washington' WHERE first_name = 'George';
SELECT * FROM people;

我欢迎您的帮助(和耐心)!


这个子选择应该起作用:

EXECUTE format('INSERT INTO %1$s(a_%2$s) SELECT %2$s FROM (select ($1).*) XX',  audit, cols) USING OLD;   
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)

在过程触发器内动态插入记录 的相关文章

随机推荐