blob: a7c2e22f67e8891aa5830d4cb81eb186c1f5ce93 (
plain)
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
|
import {Prisbeam} from "./Prisbeam";
export class PrisbeamPropertyStore {
backend: Prisbeam;
length: number;
constructor(backend: Prisbeam) {
this.backend = backend;
}
async initialize() {
this.length = (await this.backend._sql("SELECT COUNT(*) FROM metadata"))[0]["COUNT(*)"];
}
private sqlstr(str?: string) {
if (str === null) {
return "NULL";
} else {
return "'" + str.replaceAll("'", "''") + "'";
}
}
async setItem(key: string, value: string) {
if ((await this.backend._sql("SELECT COUNT(*) FROM metadata WHERE key = " + this.sqlstr(key)))[0]["COUNT(*)"] === 0) {
await this.backend._sql('INSERT INTO metadata(key, value) VALUES (' + this.sqlstr(key) + ', ' + this.sqlstr(value) + ')');
this.length = (await this.backend._sql("SELECT COUNT(*) FROM metadata"))[0]["COUNT(*)"];
} else {
await this.backend._sql('UPDATE metadata SET value = ' + this.sqlstr(value) + ' WHERE key = ' + this.sqlstr(key));
}
}
async removeItem(key: string) {
if ((await this.backend._sql("SELECT COUNT(*) FROM metadata WHERE key = " + this.sqlstr(key)))[0]["COUNT(*)"] === 0) {
return;
} else {
await this.backend._sql('DELETE FROM metadata WHERE key = ' + this.sqlstr(key));
this.length = (await this.backend._sql("SELECT COUNT(*) FROM metadata"))[0]["COUNT(*)"];
}
}
async getItem(key: string) {
if ((await this.backend._sql("SELECT COUNT(*) FROM metadata WHERE key = " + this.sqlstr(key)))[0]["COUNT(*)"] === 0) {
return null;
} else {
return (await this.backend._sql('SELECT value FROM metadata WHERE key = ' + this.sqlstr(key)))[0]["value"];
}
}
async clear() {
await this.backend._sql("DROP TABLE IF EXISTS metadata");
await this.backend._sql("CREATE TABLE metadata (key TEXT NOT NULL UNIQUE, value LONGTEXT NOT NULL, PRIMARY KEY (key))");
this.length = (await this.backend._sql("SELECT COUNT(*) FROM metadata"))[0]["COUNT(*)"];
}
}
|
