summaryrefslogtreecommitdiff
path: root/tests/queries.sql
diff options
context:
space:
mode:
Diffstat (limited to 'tests/queries.sql')
-rw-r--r--tests/queries.sql312
1 files changed, 156 insertions, 156 deletions
diff --git a/tests/queries.sql b/tests/queries.sql
index e790d41..241f419 100644
--- a/tests/queries.sql
+++ b/tests/queries.sql
@@ -1,59 +1,59 @@
-- createTables.sql:
-- write:
- CREATE TABLE IF NOT EXISTS "q_payloads" (
+ CREATE TABLE IF NOT EXISTS "fiinha_payloads" (
id INTEGER NOT NULL PRIMARY KEY AUTOINCREMENT,
timestamp TEXT NOT NULL DEFAULT (strftime('%Y-%m-%dT%H:%M:%f000000Z', 'now')),
topic TEXT NOT NULL,
payload BLOB NOT NULL
) STRICT;
- CREATE INDEX IF NOT EXISTS "q_payloads_topic"
- ON "q_payloads"(topic);
+ CREATE INDEX IF NOT EXISTS "fiinha_payloads_topic"
+ ON "fiinha_payloads"(topic);
- CREATE TABLE IF NOT EXISTS "q_messages" (
+ CREATE TABLE IF NOT EXISTS "fiinha_messages" (
id INTEGER NOT NULL PRIMARY KEY AUTOINCREMENT,
timestamp TEXT NOT NULL DEFAULT (strftime('%Y-%m-%dT%H:%M:%f000000Z', 'now')),
uuid BLOB NOT NULL UNIQUE,
flow_id BLOB NOT NULL,
payload_id INTEGER NOT NULL
- REFERENCES "q_payloads"(id)
+ REFERENCES "fiinha_payloads"(id)
) STRICT;
- CREATE INDEX IF NOT EXISTS "q_messages_flow_id"
- ON "q_messages"(flow_id);
+ CREATE INDEX IF NOT EXISTS "fiinha_messages_flow_id"
+ ON "fiinha_messages"(flow_id);
- CREATE TABLE IF NOT EXISTS "q_offsets" (
+ CREATE TABLE IF NOT EXISTS "fiinha_offsets" (
id INTEGER NOT NULL PRIMARY KEY AUTOINCREMENT,
timestamp TEXT NOT NULL DEFAULT (strftime('%Y-%m-%dT%H:%M:%f000000Z', 'now')),
consumer TEXT NOT NULL,
message_id INTEGER NOT NULL
- REFERENCES "q_messages"(id),
+ REFERENCES "fiinha_messages"(id),
instance_id INTEGER NOT NULL,
UNIQUE (consumer, message_id)
) STRICT;
- CREATE INDEX IF NOT EXISTS "q_offsets_consumer"
- ON "q_offsets"(consumer);
+ CREATE INDEX IF NOT EXISTS "fiinha_offsets_consumer"
+ ON "fiinha_offsets"(consumer);
- CREATE TABLE IF NOT EXISTS "q_deadletters" (
+ CREATE TABLE IF NOT EXISTS "fiinha_deadletters" (
id INTEGER NOT NULL PRIMARY KEY AUTOINCREMENT,
uuid BLOB NOT NULL UNIQUE,
consumer TEXT NOT NULL,
message_id INTEGER NOT NULL
- REFERENCES "q_messages"(id),
+ REFERENCES "fiinha_messages"(id),
instance_id INTEGER NOT NULL,
UNIQUE (consumer, message_id)
) STRICT;
- CREATE INDEX IF NOT EXISTS "q_deadletters_consumer"
- ON "q_deadletters"(consumer);
+ CREATE INDEX IF NOT EXISTS "fiinha_deadletters_consumer"
+ ON "fiinha_deadletters"(consumer);
- CREATE TABLE IF NOT EXISTS "q_replays" (
+ CREATE TABLE IF NOT EXISTS "fiinha_replays" (
id INTEGER NOT NULL PRIMARY KEY AUTOINCREMENT,
deadletter_id INTEGER NOT NULL UNIQUE
- REFERENCES "q_deadletters"(id) ,
+ REFERENCES "fiinha_deadletters"(id) ,
message_id INTEGER NOT NULL UNIQUE
- REFERENCES "q_messages"(id)
+ REFERENCES "fiinha_messages"(id)
) STRICT;
- CREATE TABLE IF NOT EXISTS "q_owners" (
+ CREATE TABLE IF NOT EXISTS "fiinha_owners" (
id INTEGER NOT NULL PRIMARY KEY AUTOINCREMENT,
topic TEXT NOT NULL,
consumer TEXT NOT NULL,
@@ -61,16 +61,16 @@
UNIQUE (topic, consumer)
) STRICT;
- CREATE TRIGGER IF NOT EXISTS "q_check_instance_owns_topic"
- BEFORE INSERT ON "q_offsets"
+ CREATE TRIGGER IF NOT EXISTS "fiinha_check_instance_owns_topic"
+ BEFORE INSERT ON "fiinha_offsets"
WHEN NEW.instance_id != (
- SELECT owner_id FROM "q_owners"
+ SELECT owner_id FROM "fiinha_owners"
WHERE topic = (
- SELECT "q_payloads".topic
- FROM "q_payloads"
- JOIN "q_messages" ON "q_payloads".id =
- "q_messages".payload_id
- WHERE "q_messages".id = NEW.message_id
+ SELECT "fiinha_payloads".topic
+ FROM "fiinha_payloads"
+ JOIN "fiinha_messages" ON "fiinha_payloads".id =
+ "fiinha_messages".payload_id
+ WHERE "fiinha_messages".id = NEW.message_id
) AND consumer = NEW.consumer
)
BEGIN
@@ -80,16 +80,16 @@
);
END;
- CREATE TRIGGER IF NOT EXISTS "q_check_can_publish_deadletter"
- BEFORE INSERT ON "q_deadletters"
+ CREATE TRIGGER IF NOT EXISTS "fiinha_check_can_publish_deadletter"
+ BEFORE INSERT ON "fiinha_deadletters"
WHEN NEW.instance_id != (
- SELECT owner_id FROM "q_owners"
+ SELECT owner_id FROM "fiinha_owners"
WHERE topic = (
- SELECT "q_payloads".topic
- FROM "q_payloads"
- JOIN "q_messages" ON "q_payloads".id =
- "q_messages".payload_id
- WHERE "q_messages".id = NEW.message_id
+ SELECT "fiinha_payloads".topic
+ FROM "fiinha_payloads"
+ JOIN "fiinha_messages" ON "fiinha_payloads".id =
+ "fiinha_messages".payload_id
+ WHERE "fiinha_messages".id = NEW.message_id
) AND consumer = NEW.consumer
)
BEGIN
@@ -106,7 +106,7 @@
-- take.sql:
-- write:
- INSERT INTO "q_owners" (topic, consumer, owner_id)
+ INSERT INTO "fiinha_owners" (topic, consumer, owner_id)
VALUES (?, ?, ?)
ON CONFLICT (topic, consumer) DO
UPDATE SET owner_id=excluded.owner_id;
@@ -118,15 +118,15 @@
-- publish.sql:
-- write:
- INSERT INTO "q_payloads" (topic, payload)
+ INSERT INTO "fiinha_payloads" (topic, payload)
VALUES (?, ?);
- INSERT INTO "q_messages" (uuid, flow_id, payload_id)
+ INSERT INTO "fiinha_messages" (uuid, flow_id, payload_id)
VALUES (?, ?, last_insert_rowid());
-- read:
- SELECT id, timestamp FROM "q_messages"
+ SELECT id, timestamp FROM "fiinha_messages"
WHERE uuid = ?;
@@ -137,17 +137,17 @@
-- read:
SELECT
- "q_messages".id,
- "q_messages".timestamp,
- "q_messages".uuid,
- "q_payloads".payload
- FROM "q_messages"
- JOIN "q_payloads" ON
- "q_payloads".id = "q_messages".payload_id
+ "fiinha_messages".id,
+ "fiinha_messages".timestamp,
+ "fiinha_messages".uuid,
+ "fiinha_payloads".payload
+ FROM "fiinha_messages"
+ JOIN "fiinha_payloads" ON
+ "fiinha_payloads".id = "fiinha_messages".payload_id
WHERE
- "q_payloads".topic = ? AND
- "q_messages".flow_id = ?
- ORDER BY "q_messages".id DESC
+ "fiinha_payloads".topic = ? AND
+ "fiinha_messages".flow_id = ?
+ ORDER BY "fiinha_messages".id DESC
LIMIT 1;
@@ -159,27 +159,27 @@
-- read:
SELECT
(
- SELECT owner_id FROM "q_owners"
+ SELECT owner_id FROM "fiinha_owners"
WHERE
topic = ? AND
consumer = ?
LIMIT 1
) AS owner_id,
- "q_messages".id,
- "q_messages".timestamp,
- "q_messages".uuid,
- "q_messages".flow_id,
- "q_payloads".payload
- FROM "q_messages"
- JOIN "q_payloads" ON
- "q_payloads".id = "q_messages".payload_id
+ "fiinha_messages".id,
+ "fiinha_messages".timestamp,
+ "fiinha_messages".uuid,
+ "fiinha_messages".flow_id,
+ "fiinha_payloads".payload
+ FROM "fiinha_messages"
+ JOIN "fiinha_payloads" ON
+ "fiinha_payloads".id = "fiinha_messages".payload_id
WHERE
- "q_payloads".topic = ? AND
- "q_messages".id NOT IN (
- SELECT message_id FROM "q_offsets"
+ "fiinha_payloads".topic = ? AND
+ "fiinha_messages".id NOT IN (
+ SELECT message_id FROM "fiinha_offsets"
WHERE consumer = ?
)
- ORDER BY "q_messages".id ASC
+ ORDER BY "fiinha_messages".id ASC
LIMIT 1;
@@ -190,26 +190,26 @@
-- read:
SELECT
- "q_messages".id,
- "q_messages".timestamp,
- "q_messages".uuid,
- "q_messages".flow_id,
- "q_payloads".topic,
- "q_payloads".payload
- FROM "q_messages"
- JOIN "q_payloads" ON
- "q_payloads".id = "q_messages".payload_id
+ "fiinha_messages".id,
+ "fiinha_messages".timestamp,
+ "fiinha_messages".uuid,
+ "fiinha_messages".flow_id,
+ "fiinha_payloads".topic,
+ "fiinha_payloads".payload
+ FROM "fiinha_messages"
+ JOIN "fiinha_payloads" ON
+ "fiinha_payloads".id = "fiinha_messages".payload_id
WHERE
- "q_payloads".topic = ? AND
- "q_messages".id NOT IN (
- SELECT message_id FROM "q_offsets"
+ "fiinha_payloads".topic = ? AND
+ "fiinha_messages".id NOT IN (
+ SELECT message_id FROM "fiinha_offsets"
WHERE consumer = ?
)
- ORDER BY "q_messages".id ASC;
+ ORDER BY "fiinha_messages".id ASC;
-- owner:
- SELECT owner_id FROM "q_owners"
+ SELECT owner_id FROM "fiinha_owners"
WHERE
topic = ? AND
consumer = ?;
@@ -217,8 +217,8 @@
-- commit.sql:
-- write:
- INSERT INTO "q_offsets" (consumer, message_id, instance_id)
- VALUES (?, (SELECT id FROM "q_messages" WHERE uuid = ?), ?);
+ INSERT INTO "fiinha_offsets" (consumer, message_id, instance_id)
+ VALUES (?, (SELECT id FROM "fiinha_messages" WHERE uuid = ?), ?);
-- read:
@@ -227,13 +227,13 @@
-- toDead.sql:
-- write:
- INSERT INTO "q_offsets"
+ INSERT INTO "fiinha_offsets"
( consumer, message_id, instance_id)
- VALUES ( ?, (SELECT id FROM "q_messages" WHERE uuid = ?), ?);
+ VALUES ( ?, (SELECT id FROM "fiinha_messages" WHERE uuid = ?), ?);
- INSERT INTO "q_deadletters"
+ INSERT INTO "fiinha_deadletters"
(uuid, consumer, message_id, instance_id)
- VALUES (?, ?, (SELECT id FROM "q_messages" WHERE uuid = ?), ?);
+ VALUES (?, ?, (SELECT id FROM "fiinha_messages" WHERE uuid = ?), ?);
-- read:
@@ -242,34 +242,34 @@
-- replay.sql:
-- write:
- INSERT INTO "q_messages" (uuid, flow_id, payload_id)
+ INSERT INTO "fiinha_messages" (uuid, flow_id, payload_id)
SELECT
?,
- "q_messages".flow_id,
- "q_messages".payload_id
- FROM "q_messages"
- JOIN "q_deadletters" ON
- "q_messages".id = "q_deadletters".message_id
- WHERE "q_deadletters".uuid = ?;
-
- INSERT INTO "q_replays" (deadletter_id, message_id)
+ "fiinha_messages".flow_id,
+ "fiinha_messages".payload_id
+ FROM "fiinha_messages"
+ JOIN "fiinha_deadletters" ON
+ "fiinha_messages".id = "fiinha_deadletters".message_id
+ WHERE "fiinha_deadletters".uuid = ?;
+
+ INSERT INTO "fiinha_replays" (deadletter_id, message_id)
VALUES (
- (SELECT id FROM "q_deadletters" WHERE uuid = ?),
+ (SELECT id FROM "fiinha_deadletters" WHERE uuid = ?),
last_insert_rowid()
);
-- read:
SELECT
- "q_messages".id,
- "q_messages".timestamp,
- "q_messages".flow_id,
- "q_payloads".topic,
- "q_payloads".payload
- FROM "q_messages"
- JOIN "q_payloads" ON
- "q_payloads".id = "q_messages".payload_id
- WHERE "q_messages".uuid = ?;
+ "fiinha_messages".id,
+ "fiinha_messages".timestamp,
+ "fiinha_messages".flow_id,
+ "fiinha_payloads".topic,
+ "fiinha_payloads".payload
+ FROM "fiinha_messages"
+ JOIN "fiinha_payloads" ON
+ "fiinha_payloads".id = "fiinha_messages".payload_id
+ WHERE "fiinha_messages".uuid = ?;
-- owner:
@@ -279,24 +279,24 @@
-- read:
SELECT
- "q_deadletters".uuid,
- "q_offsets".timestamp,
- "q_messages".uuid
- FROM "q_deadletters"
- JOIN "q_offsets" ON
- "q_deadletters".message_id = "q_offsets".message_id
- JOIN "q_messages" ON
- "q_deadletters".message_id = "q_messages".id
- JOIN "q_payloads" ON
- "q_messages".payload_id = "q_payloads".id
+ "fiinha_deadletters".uuid,
+ "fiinha_offsets".timestamp,
+ "fiinha_messages".uuid
+ FROM "fiinha_deadletters"
+ JOIN "fiinha_offsets" ON
+ "fiinha_deadletters".message_id = "fiinha_offsets".message_id
+ JOIN "fiinha_messages" ON
+ "fiinha_deadletters".message_id = "fiinha_messages".id
+ JOIN "fiinha_payloads" ON
+ "fiinha_messages".payload_id = "fiinha_payloads".id
WHERE
- "q_payloads".topic = ? AND
- "q_deadletters".consumer = ? AND
- "q_offsets".consumer = ? AND
- "q_deadletters".id NOT IN (
- SELECT deadletter_id FROM "q_replays"
+ "fiinha_payloads".topic = ? AND
+ "fiinha_deadletters".consumer = ? AND
+ "fiinha_offsets".consumer = ? AND
+ "fiinha_deadletters".id NOT IN (
+ SELECT deadletter_id FROM "fiinha_replays"
)
- ORDER BY "q_deadletters".id ASC
+ ORDER BY "fiinha_deadletters".id ASC
LIMIT 1;
@@ -307,30 +307,30 @@
-- read:
SELECT
- "q_deadletters".uuid,
- "q_deadletters".message_id,
- "q_offsets".timestamp,
- "q_offsets".consumer,
- "q_messages".timestamp,
- "q_messages".uuid,
- "q_messages".flow_id,
- "q_payloads".topic,
- "q_payloads".payload
- FROM "q_deadletters"
- JOIN "q_offsets" ON
- "q_deadletters".message_id = "q_offsets".message_id
- JOIN "q_messages" ON
- "q_deadletters".message_id = "q_messages".id
- JOIN "q_payloads" ON
- "q_messages".payload_id = "q_payloads".id
+ "fiinha_deadletters".uuid,
+ "fiinha_deadletters".message_id,
+ "fiinha_offsets".timestamp,
+ "fiinha_offsets".consumer,
+ "fiinha_messages".timestamp,
+ "fiinha_messages".uuid,
+ "fiinha_messages".flow_id,
+ "fiinha_payloads".topic,
+ "fiinha_payloads".payload
+ FROM "fiinha_deadletters"
+ JOIN "fiinha_offsets" ON
+ "fiinha_deadletters".message_id = "fiinha_offsets".message_id
+ JOIN "fiinha_messages" ON
+ "fiinha_deadletters".message_id = "fiinha_messages".id
+ JOIN "fiinha_payloads" ON
+ "fiinha_messages".payload_id = "fiinha_payloads".id
WHERE
- "q_payloads".topic = ? AND
- "q_deadletters".consumer = ? AND
- "q_offsets".consumer = ? AND
- "q_deadletters".id NOT IN (
- SELECT deadletter_id FROM "q_replays"
+ "fiinha_payloads".topic = ? AND
+ "fiinha_deadletters".consumer = ? AND
+ "fiinha_offsets".consumer = ? AND
+ "fiinha_deadletters".id NOT IN (
+ SELECT deadletter_id FROM "fiinha_replays"
)
- ORDER BY "q_deadletters".id ASC;
+ ORDER BY "fiinha_deadletters".id ASC;
-- owner:
@@ -341,10 +341,10 @@
-- read:
SELECT
COUNT(1) as size
- FROM "q_messages"
- JOIN "q_payloads" ON
- "q_messages".payload_id = "q_payloads".id
- WHERE "q_payloads".topic = ?;
+ FROM "fiinha_messages"
+ JOIN "fiinha_payloads" ON
+ "fiinha_messages".payload_id = "fiinha_payloads".id
+ WHERE "fiinha_payloads".topic = ?;
-- owner:
@@ -355,14 +355,14 @@
-- read:
SELECT
COUNT(1) as count
- FROM "q_messages"
- JOIN "q_offsets" ON
- "q_messages".id = "q_offsets".message_id
- JOIN "q_payloads" ON
- "q_messages".payload_id = "q_payloads".id
+ FROM "fiinha_messages"
+ JOIN "fiinha_offsets" ON
+ "fiinha_messages".id = "fiinha_offsets".message_id
+ JOIN "fiinha_payloads" ON
+ "fiinha_messages".payload_id = "fiinha_payloads".id
WHERE
- "q_payloads".topic = ? AND
- "q_offsets".consumer = ?;
+ "fiinha_payloads".topic = ? AND
+ "fiinha_offsets".consumer = ?;
-- owner:
@@ -372,13 +372,13 @@
-- read:
SELECT 1 as data
- FROM "q_messages"
- JOIN "q_payloads" ON
- "q_payloads".id = "q_messages".payload_id
+ FROM "fiinha_messages"
+ JOIN "fiinha_payloads" ON
+ "fiinha_payloads".id = "fiinha_messages".payload_id
WHERE
- "q_payloads".topic = ? AND
- "q_messages".id NOT IN (
- SELECT message_id FROM "q_offsets"
+ "fiinha_payloads".topic = ? AND
+ "fiinha_messages".id NOT IN (
+ SELECT message_id FROM "fiinha_offsets"
WHERE consumer = ?
)
LIMIT 1;
generated by cgit v1.2.3 (git 2.49.0) at 2025-07-12 16:34:12 +0000