Coś takiego?
CREATE FUNCTION notif()
RETURNS TRIGGER AS $$
DECLARE
data JSONB;
result JSONB;
BEGIN
SELECT json_agg(tmp) -- requires Postgres9.3+
INTO data
FROM (
-- your subquery goes here, for example:
SELECT followers.following_user_id
FROM followers
WHERE followers.followed_user_id = NEW.user_id
) tmp;
result := json_build_object('data', data, 'row', row_to_json(NEW));
PERFORM pg_notify('event', result::TEXT);
RETURN NEW;
END;
$$ language plpgsql;
Również z komentarzy:
Źle rozumiesz rzeczy. Zwrot i powiadomienie to dwie różne rzeczy.
Przede wszystkim zajmijmy się zwrotem. W przypadku wyzwalaczy AFTER INSERT zwracana wartość jest całkowicie ignorowana :
Zwracana wartość ma znaczenie tylko dla wyzwalaczy PRZED. W takim przypadku możesz zmodyfikować (lub nawet uniemożliwić) wiersz przed zapisaniem do tabeli. Zobacz to:https://www.postgresql.org/docs/9.2/ plpgsql-trigger.html To nie ma nic wspólnego z powiadomieniami.
A co z powiadomieniami? Cokolwiek otrzymujesz z powiadomienia, przekazujesz jako drugi argument do pg_notify
. Wszystko to jest dość dobrze udokumentowane:https://www.postgresql.org /docs/9.0/sql-notify.html