durable-objects-sql-tag

import { DurableObject } from 'cloudflare:workers'; import { sql, wrapDatabase, type MigrationVersionDefinition } from 'durable-objects-sql-tag'; const migrations: MigrationVersionDefinition[] = [ { name: 'Create users table', migrate(db) { db.run(sql`CREATE TABLE users (id TEXT PRIMARY KEY, name TEXT NOT NULL, email TEXT NOT NULL UNIQUE) STRICT`); }, }, ]; export class MyDurableObject extends DurableObject { private db; constructor(ctx: DurableObjectState, env: Env) { super(ctx, env); this.db = wrapDatabase(ctx.storage); ctx.blockConcurrencyWhile(() => this.db.migrate(migrations)); } async fetch(request: Request): Promise<Response> { const user = this.db.queryOne<{ id: string; name: string }>(sql`SELECT * FROM users WHERE id = ${'abc'}`); const users = this.db.queryMany<{ id: string; name: string }>(sql`SELECT * FROM users WHERE status = ${'active'}`); this.db.run(sql`INSERT INTO users (id, name, email) VALUES (${'id'}, ${'name'}, ${'email'})`); return new Response('OK'); } }