forked from mirrors/relay
38 lines
839 B
MySQL
38 lines
839 B
MySQL
|
-- Your SQL goes here
|
||
|
|
CREATE OR REPLACE FUNCTION invoke_nodes_trigger ()
|
||
|
|
RETURNS TRIGGER
|
||
|
|
LANGUAGE plpgsql
|
||
|
|
AS $$
|
||
|
|
DECLARE
|
||
|
|
rec RECORD;
|
||
|
|
channel TEXT;
|
||
|
|
payload TEXT;
|
||
|
|
BEGIN
|
||
|
|
case TG_OP
|
||
|
|
WHEN 'INSERT' THEN
|
||
|
|
rec := NEW;
|
||
|
|
channel := 'new_nodes';
|
||
|
|
payload := NEW.listener_id;
|
||
|
|
WHEN 'UPDATE' THEN
|
||
|
|
rec := NEW;
|
||
|
|
channel := 'new_nodes';
|
||
|
|
payload := NEW.listener_id;
|
||
|
|
WHEN 'DELETE' THEN
|
||
|
|
rec := OLD;
|
||
|
|
channel := 'rm_nodes';
|
||
|
|
payload := OLD.listener_id;
|
||
|
|
ELSE
|
||
|
|
RAISE EXCEPTION 'Unknown TG_OP: "%". Should not occur!', TG_OP;
|
||
|
|
END CASE;
|
||
|
|
|
||
|
|
PERFORM pg_notify(channel, payload::TEXT);
|
||
|
|
RETURN rec;
|
||
|
|
END;
|
||
|
|
$$;
|
||
|
|
|
||
|
|
CREATE TRIGGER nodes_notify
|
||
|
|
AFTER INSERT OR UPDATE OR DELETE
|
||
|
|
ON nodes
|
||
|
|
FOR EACH ROW
|
||
|
|
EXECUTE PROCEDURE invoke_nodes_trigger();
|