Function getDb

packages/cli/src/db/client.ts:20–34

(opts: { dbPath?: string } = {})

let cached: CachedHandle | null = null;

export function getDb(opts: { dbPath?: string } = {}): StageDb {
	const dbPath = opts.dbPath ?? getDbPath();
	if (cached && cached.path === dbPath) return cached.drizzle;
	if (cached) closeDb();

	const sqlite = new Database(dbPath);
	sqlite.pragma("journal_mode = WAL");
	sqlite.pragma("foreign_keys = ON");

	const db = drizzle(sqlite, { schema });
	migrate(db, { migrationsFolder: findMigrationsFolder() });

	cached = { sqlite, drizzle: db, path: dbPath };
	return db;
}

export function closeDb(): void {
	if (!cached) return;