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
111
112
113
114
115
116
117
118
119
120
121
122
123
124
import init, { Database } from '../pkg/absurder_sql.js';
let db = null;
// Message handler
self.onmessage = async function(e) {
const { type, id, count } = e.data;
try {
switch (type) {
case 'init':
await init();
db = await Database.newDatabase('worker_demo.db');
// Workers don't have localStorage for leader election
// so we enable non-leader writes
db.allowNonLeaderWrites(true);
self.postMessage({
type,
id,
success: true,
message: 'Database initialized in worker'
});
break;
case 'createTable':
await db.execute('DROP TABLE IF EXISTS benchmark');
await db.execute(`
CREATE TABLE benchmark (
id INTEGER PRIMARY KEY AUTOINCREMENT,
name TEXT,
value REAL,
created_at INTEGER
)
`);
self.postMessage({
type,
id,
success: true,
message: 'Table created successfully'
});
break;
case 'insertData':
const startInsert = performance.now();
const insertCount = count || 1000;
await db.execute('BEGIN TRANSACTION');
for (let i = 0; i < insertCount; i++) {
await db.execute(
'INSERT INTO benchmark (name, value, created_at) VALUES (?, ?, ?)',
[
{ type: 'Text', value: `Item ${i}` },
{ type: 'Real', value: Math.random() * 100 },
{ type: 'Integer', value: Date.now() }
]
);
}
await db.execute('COMMIT');
const insertDuration = Math.round(performance.now() - startInsert);
self.postMessage({
type,
id,
success: true,
message: `Inserted ${insertCount} rows in ${insertDuration}ms`,
data: { count: insertCount, duration: insertDuration }
});
break;
case 'queryData':
const startQuery = performance.now();
const result = await db.execute('SELECT COUNT(*) as count FROM benchmark');
const queryDuration = Math.round(performance.now() - startQuery);
const rowCount = result.rows.length > 0 ? result.rows[0].values[0].value : 0;
self.postMessage({
type,
id,
success: true,
data: { count: rowCount, duration: queryDuration }
});
break;
case 'sync':
await db.sync();
self.postMessage({
type,
id,
success: true,
message: 'Database synced to IndexedDB'
});
break;
case 'clear':
await db.execute('DROP TABLE IF EXISTS benchmark');
await db.sync();
self.postMessage({
type,
id,
success: true,
message: 'Database cleared'
});
break;
default:
throw new Error(`Unknown message type: ${type}`);
}
} catch (error) {
console.error(`[Worker] Error in ${type}:`, error);
self.postMessage({
type,
id,
success: false,
error: error.toString()
});
}
};
// Log when worker is loaded
console.log('[Worker] AbsurderSQL worker loaded');