42 lines
1.2 KiB
TypeScript
42 lines
1.2 KiB
TypeScript
import postgres from 'postgres'
|
|
import { readdir, readFile } from 'node:fs/promises'
|
|
import { join, dirname } from 'node:path'
|
|
import { fileURLToPath } from 'node:url'
|
|
|
|
const __dirname = dirname(fileURLToPath(import.meta.url))
|
|
const sqlDir = join(__dirname, '../../../sql')
|
|
|
|
const databaseUrl = process.env.DATABASE_URL
|
|
if (!databaseUrl) {
|
|
console.error('[db-migrate] DATABASE_URL is not set')
|
|
process.exit(1)
|
|
}
|
|
|
|
const sql = postgres(databaseUrl)
|
|
|
|
await sql`
|
|
CREATE TABLE IF NOT EXISTS schema_migrations (
|
|
filename TEXT PRIMARY KEY,
|
|
applied_at TIMESTAMPTZ NOT NULL DEFAULT NOW()
|
|
)
|
|
`
|
|
|
|
const applied = new Set((await sql`SELECT filename FROM schema_migrations`).map((r) => r.filename))
|
|
|
|
const files = (await readdir(sqlDir)).filter((f) => f.endsWith('.sql')).sort()
|
|
|
|
for (const file of files) {
|
|
if (applied.has(file)) {
|
|
console.log(`[db-migrate] skip ${file} (already applied)`)
|
|
continue
|
|
}
|
|
const content = await readFile(join(sqlDir, file), 'utf8')
|
|
console.log(`[db-migrate] applying ${file}...`)
|
|
await sql.unsafe(content)
|
|
await sql`INSERT INTO schema_migrations (filename) VALUES (${file})`
|
|
console.log(`[db-migrate] applied ${file}`)
|
|
}
|
|
|
|
await sql.end()
|
|
console.log('[db-migrate] done')
|