New tags-Table added

README.md

@@ -183,8 +183,8 @@ Writes a value into the database and returns the key.
 
 ### key
 
-The key can be a string or `undefined`.
-If the `key` is `undefined`, a UUID is generated as the key.
+The `key` can be a string or `undefined`.
+If the `key` is `undefined`, a UUID is used instead.
 
 ### value
 

examples/binaryExampleSync.ts

@@ -17,7 +17,3 @@ const targetBuffer = store.get("my-image")
 writeFileSync("<Target File Path>", targetBuffer)
 
 
-
-
-
-

examples/createTestDatabase.ts

@@ -0,0 +1,6 @@
+import { BunSqliteKeyValue } from "../src"
+
+
+const store = new BunSqliteKeyValue("test_database.sqlite")
+store.close()
+

src/index.ts

@@ -85,12 +85,28 @@ export class BunSqliteKeyValue {
         // Open database
         this.db = new Database(filename, dbOptions)
         this.db.run("PRAGMA journal_mode = WAL")
-
-        // Create table and indexes
-        this.db.run("CREATE TABLE IF NOT EXISTS items (key TEXT PRIMARY KEY, value BLOB, expires INT)")
-        this.db.run("CREATE UNIQUE INDEX IF NOT EXISTS ix_items_key ON items (key)")
+        this.db.run("PRAGMA foreign_keys = ON")
+
+        // Create items table and indexes
+        this.db.run(`
+        CREATE TABLE IF NOT EXISTS items (
+            key TEXT NOT NULL PRIMARY KEY, 
+            value BLOB, 
+            expires INT
+        ) STRICT`)
+        // Not required: this.db.run("CREATE UNIQUE INDEX IF NOT EXISTS ix_items_key ON items (key)")
         this.db.run("CREATE INDEX IF NOT EXISTS ix_items_expires ON items (expires)")
 
+        // Create tags table and indexes
+        this.db.run(`
+        CREATE TABLE IF NOT EXISTS tags (
+            tag TEXT NOT NULL,
+            item_key TEXT NOT NULL REFERENCES items ON DELETE CASCADE ON UPDATE CASCADE,
+            PRIMARY KEY (tag, item_key)
+        ) STRICT`)
+        // Not required: this.db.run("CREATE UNIQUE INDEX IF NOT EXISTS ix_tags_unique ON tags (tag, item_key)")
+        this.db.run("CREATE INDEX IF NOT EXISTS ix_tags_item_key ON tags (item_key)")
+
         // Prepare and cache statements
         this.clearStatement = this.db.query("DELETE FROM items")
         this.deleteStatement = this.db.query("DELETE FROM items WHERE key = $key")