tcn

Модуль tcn предоставляет триггерную функцию, уведомляющую блоки прослушивания об изменениях в любой таблице, к которой она привязана. Она должна использоваться в качестве триггера AFTER вида FOR EACH ROW.

Этот модуль считается «доверенным», то есть его могут устанавливать обычные пользователи с правом CREATE в текущей базе данных.

Этой функции в операторе CREATE TRIGGER может передаваться только один параметр, и он является необязательным. Если этот параметр присутствует, он будет использован для указания имени канала для уведомлений. Если он отсутствует, именем канала будет tcn.

Информационное наполнение уведомлений состоит из имени таблицы, буквы, обозначающей тип выполняемой операции, и пар имя столбца/значение для столбцов первичного ключа. Каждая часть отделяется от следующей запятой. Для упрощения синтаксического анализа сообщения регулярными выражениями имена таблицы и столбцов всегда заключаются в кавычки, а значения данных — в апострофы. Внутренние кавычки и апострофы дублируются.

Далее следует краткий пример использования расширения.

test=# create table tcndata
test-#   (
test(#     a int not null,
test(#     b date not null,
test(#     c text,
test(#     primary key (a, b)
test(#   );
CREATE TABLE
test=# create trigger tcndata_tcn_trigger
test-#   after insert or update or delete on tcndata
test-#   for each row execute function triggered_change_notification();
CREATE TRIGGER
test=# listen tcn;
LISTEN
test=# insert into tcndata values (1, date '2012-12-22', 'one'),
test-#                            (1, date '2012-12-23', 'another'),
test-#                            (2, date '2012-12-23', 'two');
INSERT 0 3
Asynchronous notification "tcn" with payload ""tcndata",I,"a"='1',"b"='2012-12-22'" received from server process with PID 22770.
Asynchronous notification "tcn" with payload ""tcndata",I,"a"='1',"b"='2012-12-23'" received from server process with PID 22770.
Asynchronous notification "tcn" with payload ""tcndata",I,"a"='2',"b"='2012-12-23'" received from server process with PID 22770.
test=# update tcndata set c = 'uno' where a = 1;
UPDATE 2
Asynchronous notification "tcn" with payload ""tcndata",U,"a"='1',"b"='2012-12-22'" received from server process with PID 22770.
Asynchronous notification "tcn" with payload ""tcndata",U,"a"='1',"b"='2012-12-23'" received from server process with PID 22770.
test=# delete from tcndata where a = 1 and b = date '2012-12-22';
DELETE 1
Asynchronous notification "tcn" with payload ""tcndata",D,"a"='1',"b"='2012-12-22'" received from server process with PID 22770.