Skip to content

Commit

Permalink
updating tests after rebase
Browse files Browse the repository at this point in the history
  • Loading branch information
nandorsoma authored and henneberger committed Aug 29, 2024
1 parent cb7f471 commit d719afc
Show file tree
Hide file tree
Showing 2 changed files with 22 additions and 16 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -82,17 +82,20 @@ Inputs: importedevent_2
"sql" : "CREATE TABLE IF NOT EXISTS \"Event\" (\"_uuid\" TEXT NOT NULL,\"ID\" BIGINT ,\"EPOCH_TIMESTAMP\" BIGINT ,\"SOME_VALUE\" TEXT ,\"TIMESTAMP\" TIMESTAMP WITHOUT TIME ZONE ,\"event_time\" TIMESTAMP WITH TIME ZONE NOT NULL , PRIMARY KEY (\"_uuid\"));"
},
{
"sql" : "CREATE OR REPLACE FUNCTION notify_on_Event_insert()\nRETURNS TRIGGER AS $$\nBEGIN\n PERFORM pg_notify('Event_notify', NEW._uuid::text);\n RETURN NEW;\nEND;\n$$ LANGUAGE plpgsql;\n\nCREATE TRIGGER insert_notify_trigger\nAFTER INSERT ON \"Event\"\nFOR EACH ROW EXECUTE PROCEDURE notify_on_Event_insert();"
"sql" : "CREATE OR REPLACE FUNCTION notify_on_Event_insert()\nRETURNS TRIGGER AS $$\nBEGIN\n PERFORM pg_notify('Event_notify', jsonb_build_object('_uuid', NEW._uuid)::text);\n RETURN NEW;\nEND;\n$$ LANGUAGE plpgsql;\n\nCREATE TRIGGER insert_notify_trigger\nAFTER INSERT ON \"Event\"\nFOR EACH ROW EXECUTE PROCEDURE notify_on_Event_insert();"
}
],
"listenQueries" : [
"queries" : [
{
"sql" : "LISTEN Event_notify"
}
],
"onNotifyQueries" : [
{
"sql" : "SELECT * FROM \"Event\" WHERE \"_uuid\"= ?;"
"listen" : {
"sql" : "LISTEN Event_notify;"
},
"onNotify" : {
"sql" : "SELECT *\nFROM \"Event\"\nWHERE \"_uuid\" = $1"
},
"parameters" : [
"_uuid"
]
}
]
}
Original file line number Diff line number Diff line change
Expand Up @@ -81,17 +81,20 @@ Inputs: event_2
"sql" : "CREATE TABLE IF NOT EXISTS \"Event\" (\"_uuid\" TEXT NOT NULL,\"ID\" BIGINT NOT NULL,\"EPOCH_TIMESTAMP\" BIGINT NOT NULL,\"SOME_VALUE\" TEXT NOT NULL,\"TIMESTAMP\" TIMESTAMP WITH TIME ZONE NOT NULL,\"event_time\" TIMESTAMP WITH TIME ZONE NOT NULL , PRIMARY KEY (\"_uuid\"));"
},
{
"sql" : "CREATE OR REPLACE FUNCTION notify_on_Event_insert()\nRETURNS TRIGGER AS $$\nBEGIN\n PERFORM pg_notify('Event_notify', NEW._uuid::text);\n RETURN NEW;\nEND;\n$$ LANGUAGE plpgsql;\n\nCREATE TRIGGER insert_notify_trigger\nAFTER INSERT ON \"Event\"\nFOR EACH ROW EXECUTE PROCEDURE notify_on_Event_insert();"
"sql" : "CREATE OR REPLACE FUNCTION notify_on_Event_insert()\nRETURNS TRIGGER AS $$\nBEGIN\n PERFORM pg_notify('Event_notify', jsonb_build_object('_uuid', NEW._uuid)::text);\n RETURN NEW;\nEND;\n$$ LANGUAGE plpgsql;\n\nCREATE TRIGGER insert_notify_trigger\nAFTER INSERT ON \"Event\"\nFOR EACH ROW EXECUTE PROCEDURE notify_on_Event_insert();"
}
],
"listenQueries" : [
"queries" : [
{
"sql" : "LISTEN Event_notify"
}
],
"onNotifyQueries" : [
{
"sql" : "SELECT * FROM \"Event\" WHERE \"_uuid\"= ?;"
"listen" : {
"sql" : "LISTEN Event_notify;"
},
"onNotify" : {
"sql" : "SELECT *\nFROM \"Event\"\nWHERE \"_uuid\" = $1"
},
"parameters" : [
"_uuid"
]
}
]
}

0 comments on commit d719afc

Please sign in to comment.