Public Triggers

Non-automatic SQL trigger.  It puts row data in partial SQL form into queue.  It does not auto-detect table structure, it needs to be passed as trigger arg.

Purpose

Used by Londiste to generate replication events.  The “partial SQL” format is more compact than the urlencoded format but cannot be parsed, only applied.  Which is fine for Londiste.

Parameters

Column types

Queue event fields

Automatic SQL trigger.  It puts row data in partial SQL form into queue.  It autodetects table structure.

Purpose

Written as more flexible version of logtriga to handle exceptional cases where there is no primary key index on table etc.

Parameters

Optinal arguments

Queue event fields

pgq.logutriga() RETURNS TRIGGER AS

Trigger function that puts row data in urlencoded form into queue.

Purpose

Used as producer for several PgQ standard consumers (cube_dispatcher, queue_mover, table_dispatcher).  Basically for cases where the consumer wants to parse the event and look at the actual column values.

Trigger parameters

Optinal arguments

Queue event fields

Regular listen trigger example

CREATE TRIGGER triga_nimi AFTER INSERT OR UPDATE ON customer
FOR EACH ROW EXECUTE PROCEDURE pgq.logutriga('qname');

Redirect trigger example

CREATE TRIGGER triga_nimi BEFORE INSERT OR UPDATE ON customer
FOR EACH ROW EXECUTE PROCEDURE pgq.logutriga('qname', 'SKIP');