Есть определенное число таблиц. Скажем 50. На каждой висит триггер на обновление. Колонки во всех таблица разные.
Как в триггере определять какое именно поле(колонка) обновилось при операции UPDATE?
Stack Overflow на русском — это сайт вопросов и ответов для программистов. Присоединяйтесь! Регистрация займёт не больше минуты.
Присоединиться к сообществуЕсть определенное число таблиц. Скажем 50. На каждой висит триггер на обновление. Колонки во всех таблица разные.
Как в триггере определять какое именно поле(колонка) обновилось при операции UPDATE?
Воспользуйтесь данным тригером
https://wiki.postgresql.org/wiki/Audit_trigger
Он регистрирует старые и новые значения, дату, схему, таблицу, пользователя, тип действия и сам запрос.
Можете отредактировать под свои требования.
Триггер
-- create a schema named "audit"
CREATE schema audit;
REVOKE CREATE ON schema audit FROM public;
CREATE TABLE audit.logged_actions (
schema_name text NOT NULL,
TABLE_NAME text NOT NULL,
user_name text,
action_tstamp TIMESTAMP WITH TIME zone NOT NULL DEFAULT CURRENT_TIMESTAMP,
action TEXT NOT NULL CHECK (action IN ('I','D','U')),
original_data text,
new_data text,
query text
) WITH (fillfactor=100);
REVOKE ALL ON audit.logged_actions FROM public;
-- You may wish to use different permissions; this lets anybody
-- see the full audit data. In Pg 9.0 and above you can use column
-- permissions for fine-grained control.
GRANT SELECT ON audit.logged_actions TO public;
CREATE INDEX logged_actions_schema_table_idx
ON audit.logged_actions(((schema_name||'.'||TABLE_NAME)::TEXT));
CREATE INDEX logged_actions_action_tstamp_idx
ON audit.logged_actions(action_tstamp);
CREATE INDEX logged_actions_action_idx
ON audit.logged_actions(action);
--
-- Now, define the actual trigger function:
--
CREATE OR REPLACE FUNCTION audit.if_modified_func() RETURNS TRIGGER AS $body$
DECLARE
v_old_data TEXT;
v_new_data TEXT;
BEGIN
/* If this actually for real auditing (where you need to log EVERY action),
then you would need to use something like dblink or plperl that could log outside the transaction,
regardless of whether the transaction committed or rolled back.
*/
/* This dance with casting the NEW and OLD values to a ROW is not necessary in pg 9.0+ */
IF (TG_OP = 'UPDATE') THEN
v_old_data := ROW(OLD.*);
v_new_data := ROW(NEW.*);
INSERT INTO audit.logged_actions (schema_name,table_name,user_name,action,original_data,new_data,query)
VALUES (TG_TABLE_SCHEMA::TEXT,TG_TABLE_NAME::TEXT,session_user::TEXT,substring(TG_OP,1,1),v_old_data,v_new_data, current_query());
RETURN NEW;
ELSIF (TG_OP = 'DELETE') THEN
v_old_data := ROW(OLD.*);
INSERT INTO audit.logged_actions (schema_name,table_name,user_name,action,original_data,query)
VALUES (TG_TABLE_SCHEMA::TEXT,TG_TABLE_NAME::TEXT,session_user::TEXT,substring(TG_OP,1,1),v_old_data, current_query());
RETURN OLD;
ELSIF (TG_OP = 'INSERT') THEN
v_new_data := ROW(NEW.*);
INSERT INTO audit.logged_actions (schema_name,table_name,user_name,action,new_data,query)
VALUES (TG_TABLE_SCHEMA::TEXT,TG_TABLE_NAME::TEXT,session_user::TEXT,substring(TG_OP,1,1),v_new_data, current_query());
RETURN NEW;
ELSE
RAISE WARNING '[AUDIT.IF_MODIFIED_FUNC] - Other action occurred: %, at %',TG_OP,now();
RETURN NULL;
END IF;
EXCEPTION
WHEN data_exception THEN
RAISE WARNING '[AUDIT.IF_MODIFIED_FUNC] - UDF ERROR [DATA EXCEPTION] - SQLSTATE: %, SQLERRM: %',SQLSTATE,SQLERRM;
RETURN NULL;
WHEN unique_violation THEN
RAISE WARNING '[AUDIT.IF_MODIFIED_FUNC] - UDF ERROR [UNIQUE] - SQLSTATE: %, SQLERRM: %',SQLSTATE,SQLERRM;
RETURN NULL;
WHEN OTHERS THEN
RAISE WARNING '[AUDIT.IF_MODIFIED_FUNC] - UDF ERROR [OTHER] - SQLSTATE: %, SQLERRM: %',SQLSTATE,SQLERRM;
RETURN NULL;
END;
$body$
LANGUAGE plpgsql
SECURITY DEFINER
SET search_path = pg_catalog, audit;
--
-- To add this trigger to a table, use:
-- CREATE TRIGGER tablename_audit
-- AFTER INSERT OR UPDATE OR DELETE ON tablename
-- FOR EACH ROW EXECUTE PROCEDURE audit.if_modified_func();
--
Тест
-- Tested with a table named "t"
DROP TABLE IF EXISTS t;
CREATE TABLE t (x INT NOT NULL PRIMARY KEY, y text);
-- needs to be applied to all tables that we want to monitor
-- this is a test trigger to show how we can audit all changes to the relevant tables, including inserts
CREATE TRIGGER t_if_modified_trg
AFTER INSERT OR UPDATE OR DELETE ON t
FOR EACH ROW EXECUTE PROCEDURE audit.if_modified_func();
-- Some sample updates, deletes, and inserts to illustrate the points
SELECT * FROM t; SELECT * FROM audit.logged_actions;
INSERT INTO t (x,y) VALUES (1,'asdf'),(2,'werwer'),(3,NULL);
SELECT * FROM t; SELECT * FROM audit.logged_actions;
-- You may have noticed that the times output in the prior query are in your local time.
-- They're stored as UTC, but Pg is converting them for display according to the 'timezone' GUC.
SHOW timezone;
-- See?
SET timezone = 'UTC';
SELECT * FROM audit.logged_actions;
RESET timezone;
-- Another way to achieve the same effect:
SELECT *, action_tstamp AT TIME ZONE 'UTC' AS action_tstamp_utc FROM audit.logged_actions;
UPDATE t SET y='eeeeee' WHERE x=2;
SELECT * FROM t; SELECT * FROM audit.logged_actions;
UPDATE t SET y='yuyuyuy' WHERE x=3;
SELECT * FROM t; SELECT * FROM audit.logged_actions;
DELETE FROM t WHERE x=1;
SELECT * FROM t; SELECT * FROM audit.logged_actions;
-- should be a pk violation
UPDATE t SET x=4 WHERE x=2;
SELECT * FROM t; SELECT * FROM audit.logged_actions;