diff options
Diffstat (limited to 'tests/queries.sql')
| -rw-r--r-- | tests/queries.sql | 79 |
1 files changed, 40 insertions, 39 deletions
diff --git a/tests/queries.sql b/tests/queries.sql index 2515778..c821e25 100644 --- a/tests/queries.sql +++ b/tests/queries.sql @@ -1,6 +1,6 @@ -- createTables.sql: --- write: +-- write: CREATE TABLE IF NOT EXISTS "q_payloads" ( id INTEGER NOT NULL PRIMARY KEY AUTOINCREMENT, timestamp TEXT NOT NULL DEFAULT (strftime('%Y-%m-%dT%H:%M:%f000000Z', 'now')), @@ -60,42 +60,43 @@ ) STRICT; --- read: +-- read: --- owner: +-- owner: -- take.sql: --- write: +-- write: INSERT INTO "q_owners" (topic, consumer, owner_id) VALUES (?, ?, ?) ON CONFLICT (topic, consumer) DO UPDATE SET owner_id=excluded.owner_id; --- read: +-- read: --- owner: +-- owner: -- publish.sql: --- write: +-- write: INSERT INTO "q_payloads" (topic, payload) VALUES (?, ?); + -- FIXME: must be inside a trnsaction INSERT INTO "q_messages" (uuid, flow_id, payload_id) VALUES (?, ?, last_insert_rowid()); --- read: +-- read: SELECT id, timestamp FROM "q_messages" WHERE uuid = ?; --- owner: +-- owner: -- find.sql: --- write: +-- write: --- read: +-- read: SELECT "q_messages".id, "q_messages".timestamp, @@ -111,12 +112,12 @@ LIMIT 1; --- owner: +-- owner: -- pending.sql: --- write: +-- write: --- read: +-- read: SELECT "q_messages".id, "q_messages".timestamp, @@ -136,7 +137,7 @@ ORDER BY "q_messages".id ASC; --- owner: +-- owner: SELECT owner_id FROM "q_owners" WHERE topic = ? AND @@ -144,19 +145,19 @@ -- commit.sql: --- write: +-- write: INSERT INTO "q_offsets" (consumer, message_id) VALUES (?, (SELECT id FROM "q_messages" WHERE uuid = ?)); --- read: +-- read: SELECT "q_payloads".topic from "q_payloads" JOIN "q_messages" ON "q_payloads".id = "q_messages".payload_id WHERE "q_messages".uuid = ?; --- owner: +-- owner: SELECT owner_id FROM "q_owners" WHERE topic = ? AND @@ -164,7 +165,7 @@ -- toDead.sql: --- write: +-- write: INSERT INTO "q_offsets" ( consumer, message_id) VALUES ( ?, (SELECT id FROM "q_messages" WHERE uuid = ?)); @@ -172,14 +173,14 @@ VALUES (?, ?, (SELECT id FROM "q_messages" WHERE uuid = ?)); --- read: +-- read: SELECT "q_payloads".topic FROM "q_payloads" JOIN "q_messages" ON "q_payloads".id = "q_messages".payload_id WHERE "q_messages".uuid = ?; --- owner: +-- owner: SELECT owner_id FROM "q_owners" WHERE topic = ? AND @@ -187,7 +188,7 @@ -- replay.sql: --- write: +-- write: INSERT INTO "q_messages" (uuid, flow_id, payload_id) SELECT ?, @@ -205,7 +206,7 @@ ); --- read: +-- read: SELECT "q_messages".id, "q_messages".timestamp, @@ -218,12 +219,12 @@ WHERE "q_messages".uuid = ?; --- owner: +-- owner: -- oneDead.sql: --- write: +-- write: --- read: +-- read: SELECT "q_deadletters".uuid, "q_offsets".timestamp, @@ -246,12 +247,12 @@ LIMIT 1; --- owner: +-- owner: -- allDead.sql: --- write: +-- write: --- read: +-- read: SELECT "q_deadletters".uuid, "q_deadletters".message_id, @@ -279,12 +280,12 @@ ORDER BY "q_deadletters".id ASC; --- owner: +-- owner: -- size.sql: --- write: +-- write: --- read: +-- read: SELECT COUNT(1) as size FROM "q_messages" @@ -293,12 +294,12 @@ WHERE "q_payloads".topic = ?; --- owner: +-- owner: -- count.sql: --- write: +-- write: --- read: +-- read: SELECT COUNT(1) as count FROM "q_messages" @@ -311,12 +312,12 @@ "q_offsets".consumer = ?; --- owner: +-- owner: -- hasData.sql: --- write: +-- write: --- read: +-- read: SELECT 1 as data FROM "q_messages" JOIN "q_payloads" ON @@ -330,4 +331,4 @@ LIMIT 1; --- owner: +-- owner: |