taotetek · October 3, 2010 15:36
diff --git a/listen_notify_poller_trigger.sql b/listen_notify_poller_trigger.sql
 CREATE FUNCTION notify_trigger() RETURNS trigger AS $$
 DECLARE
 BEGIN
  PERFORM pg_notify('watchers', TG_TABLE_NAME || ',id,' || NEW.id );
  RETURN new;
 END;
 $$ LANGUAGE plpgsql;

 CREATE TRIGGER watched_table_trigger AFTER INSERT ON watched_table
 FOR EACH ROW EXECUTE PROCEDURE notify_trigger();
	CREATE FUNCTION notify_trigger() RETURNS trigger AS $$
	DECLARE
	BEGIN
	PERFORM pg_notify('watchers', TG_TABLE_NAME \|\| ',id,' \|\| NEW.id );
	RETURN new;
	END;
	$$ LANGUAGE plpgsql;

	CREATE TRIGGER watched_table_trigger AFTER INSERT ON watched_table
	FOR EACH ROW EXECUTE PROCEDURE notify_trigger();