1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
|
import assert from "node:assert/strict";
import sqlite from "../../src/sqlite.cjs";
import * as runner from "../runner.mjs";
import {
promisifyDb,
open,
handle,
init,
} from "../../src/db.mjs";
const test_promisifyDb = async t => {
t.start("promisifyDb()");
const createTable = "CREATE TABLE table_ (column INTEGER NOT NULL PRIMARY KEY);";
await t.test("we can access the underlying database and statement ref", async () => {
const db = await open(":memory:");
assert.ok(db.ref instanceof sqlite.Database);
const stmt = await db.prepare("SELECT 1;");
assert.ok(stmt.ref instanceof sqlite.Statement);
});
await t.test("we can run the wrapped fns", async () => {
const db = await open(":memory:");
await db.exec(createTable);
const stmt = await db.prepare("INSERT INTO table_ (column) VALUES ($column)");
await stmt.run({ $column: 3 });
await stmt.run({ $column: 1 });
await stmt.finalize();
assert.rejects(
async () => await stmt.run({ $column: 2 }),
{
message: "SQLITE_MISUSE: Statement is already finalized",
code: "SQLITE_MISUSE",
},
);
const selectAll = "SELECT column FROM table_ ORDER BY column;";
const all = await db.all(selectAll);
assert.deepEqual(all, [{ column: 1 }, { column: 3 }]);
const contents = [];
const cb = row => contents.push(row);
await db.each(selectAll, cb);
assert.deepEqual(contents, [{ column: 1 }, { column: 3 }]);
});
};
const test_open = async t => {
t.start("open()");
await t.test("we must provide a name", () => {
assert.rejects(
async () => await open(),
assert.AssertionError,
);
assert.rejects(
async () => await open(undefined),
assert.AssertionError,
);
assert.rejects(
async () => await open(null),
assert.AssertionError,
);
assert.rejects(
async () => await open(""),
assert.AssertionError,
);
});
await t.test("failure to open causes a promise rejection", () => {
assert.rejects(
async () => await open("tests/non/existing/directory/and/file"),
{
message: "SQLITE_CANTOPEN: unable to open database file",
code: "SQLITE_CANTOPEN",
},
);
});
};
const test_init = async t => {
t.start("init()");
await t.test("we only know how to deal with 1 database", async () => {
const logFn = () => {};
await init(logFn);
const ref1 = handle;
await init(logFn);
const ref2 = handle;
assert.notDeepEqual(ref1, ref2);
});
};
await runner.runTests([
test_promisifyDb,
test_open,
test_init,
]);
|
