Создайте триггер оператора postgres после UPDATE, используя данные из обновления для вызова NOTIFY

Я хотел бы создать триггер, который запускается всякий раз, когда оператор INSERT в таблице завершается успешно, используя данные из вставки для вызова pg_notify:

CREATE OR REPLACE FUNCTION notify_updates() RETURNS TRIGGER AS $$
   BEGIN
    PERFORM pg_notify(NEW.aggregate_type, NEW.aggregate_id::text);
    RETURN NEW;
   END;
$$ LANGUAGE plpgsql;

CREATE OR REPLACE TRIGGER model_notification
 AFTER INSERT ON events
 FOR EACH STATEMENT
 EXECUTE PROCEDURE notify_updates()

aggregate_type и aggregate_id — столбцы таблицы events. значения для aggregate_type известны заранее, и можно заранее вызвать LISTEN на соответствующих каналах.

Я получаю сообщение об ошибке: «Имя канала не может быть пустым». Я думаю, это потому, что триггер запускается для каждого оператора, а не для каждой строки. Есть ли способ заставить это работать для триггеров операторов? Я думаю, интересная часть заключается в том, что может быть пара строк, которые были вставлены, а postgres не знает, какое значение ему следует выбрать?

Этот вопрос похож на Использование данных строки в триггере pg_notify в качестве имени канала?, но я хочу, чтобы триггер запускался для каждого оператора, а не для каждой строки, потому что в моем конкретном случае значения для aggregate_type и aggregate_id будут одинаковыми для всех строк каждой вставки.

3 метода стилизации элементов HTML
3 метода стилизации элементов HTML
Когда дело доходит до применения какого-либо стиля к нашему HTML, существует три подхода: встроенный, внутренний и внешний. Предпочтительным обычно...
Формы c голосовым вводом в React с помощью Speechly
Формы c голосовым вводом в React с помощью Speechly
Пытались ли вы когда-нибудь заполнить веб-форму в области электронной коммерции, которая требует много кликов и выбора? Вас попросят заполнить дату,...
Стилизация и валидация html-формы без использования JavaScript (только HTML/CSS)
Стилизация и валидация html-формы без использования JavaScript (только HTML/CSS)
Будучи разработчиком веб-приложений, легко впасть в заблуждение, считая, что приложение без JavaScript не имеет права на жизнь. Нам становится удобно...
Flatpickr: простой модуль календаря для вашего приложения на React
Flatpickr: простой модуль календаря для вашего приложения на React
Если вы ищете пакет для быстрой интеграции календаря с выбором даты в ваше приложения, то библиотека Flatpickr отлично справится с этой задачей....
В чем разница между Promise и Observable?
В чем разница между Promise и Observable?
Разберитесь в этом вопросе, и вы значительно повысите уровень своей компетенции.
Что такое cURL в PHP? Встроенные функции и пример GET запроса
Что такое cURL в PHP? Встроенные функции и пример GET запроса
Клиент для URL-адресов, cURL, позволяет взаимодействовать с множеством различных серверов по множеству различных протоколов с синтаксисом URL.
1
0
36
1
Перейти к ответу Данный вопрос помечен как решенный

Ответы 1

Ответ принят как подходящий

Вам нужна таблица переходов:

CREATE OR REPLACE FUNCTION notify_updates() RETURNS TRIGGER AS $$
   BEGIN
    PERFORM pg_notify(aggregate_type, aggregate_id::text)
      FROM new_table -- transition table
      LIMIT 1;       -- !!
    RETURN NEW;
   END;
$$ LANGUAGE plpgsql;

CREATE TRIGGER model_notification
 AFTER INSERT ON events
 REFERENCING NEW TABLE AS new_table -- define transition table name
 FOR EACH STATEMENT
 EXECUTE PROCEDURE notify_updates();

Подробнее об этой функции читайте в документации:

Таблицы переходов появились в Postgres 10. Читайте также Триггер, который будет строить одну строку из нескольких строк.

Я полностью пропустил первую ссылку на документы, это было полезно. Мне также пришлось сделать еще одно приведение для Aggregate_type к тексту (это столбец varchar), что, в свою очередь, требует, чтобы я добавил кавычки в команду LISTEN. На данный момент это нормально в качестве обходного пути и выходит за рамки этого вопроса здесь

l7r7 23.04.2022 11:13

Другие вопросы по теме