30 lines
534 B
PL/PgSQL
30 lines
534 B
PL/PgSQL
BEGIN;
|
|
|
|
|
|
CREATE OR REPLACE FUNCTION process_raw_etsy_event() RETURNS TRIGGER AS $process_raw_etsy_event$
|
|
BEGIN
|
|
INSERT INTO etsy_store_events (
|
|
platform,
|
|
store_id,
|
|
event_timestamp,
|
|
event_id
|
|
)
|
|
SELECT
|
|
NEW.platform,
|
|
NEW.store_id,
|
|
NEW.event_timestamp,
|
|
NEW.event_id;
|
|
RETURN NULL;
|
|
END;
|
|
$process_raw_etsy_event$ LANGUAGE plpgsql;
|
|
|
|
CREATE OR REPLACE TRIGGER etsy_store_events
|
|
AFTER INSERT ON raw_store_events
|
|
FOR EACH ROW
|
|
WHEN (NEW.platform = 'etsy')
|
|
EXECUTE FUNCTION process_raw_etsy_event();
|
|
|
|
|
|
COMMIT;
|
|
|