66 lines
2.8 KiB
JavaScript
66 lines
2.8 KiB
JavaScript
|
import { createHash, randomUUID } from "node:crypto";
|
||
|
|
import { existsSync } from "node:fs";
|
||
|
|
import { readdir, readFile } from "node:fs/promises";
|
||
|
|
import path from "node:path";
|
||
|
|
import { fileURLToPath } from "node:url";
|
||
|
|
import pg from "pg";
|
||
|
|
if (existsSync(".env"))
|
||
|
|
process.loadEnvFile(".env");
|
||
|
|
const MIGRATIONS_DIR = path.resolve(path.dirname(fileURLToPath(import.meta.url)), "../prisma/migrations");
|
||
|
|
const LOCK_ID = 72707369;
|
||
|
|
const client = new pg.Client({ connectionString: process.env.DATABASE_URL });
|
||
|
|
async function main() {
|
||
|
|
await client.query(`SELECT pg_advisory_lock(${LOCK_ID})`);
|
||
|
|
await client.query(`CREATE TABLE IF NOT EXISTS "_prisma_migrations" (
|
||
|
|
"id" VARCHAR(36) PRIMARY KEY NOT NULL,
|
||
|
|
"checksum" VARCHAR(64) NOT NULL,
|
||
|
|
"finished_at" TIMESTAMPTZ,
|
||
|
|
"migration_name" VARCHAR(255) NOT NULL,
|
||
|
|
"logs" TEXT,
|
||
|
|
"rolled_back_at" TIMESTAMPTZ,
|
||
|
|
"started_at" TIMESTAMPTZ NOT NULL DEFAULT now(),
|
||
|
|
"applied_steps_count" INTEGER NOT NULL DEFAULT 0
|
||
|
|
)`);
|
||
|
|
const { rows } = await client.query(`SELECT migration_name, finished_at FROM "_prisma_migrations" WHERE rolled_back_at IS NULL`);
|
||
|
|
const failed = rows.find((r) => !r.finished_at);
|
||
|
|
if (failed) {
|
||
|
|
throw new Error(`migration ${failed.migration_name} failed earlier; fix the database, then mark it with ` +
|
||
|
|
`\`prisma migrate resolve\` (see its "logs" column in _prisma_migrations)`);
|
||
|
|
}
|
||
|
|
const applied = new Set(rows.map((r) => r.migration_name));
|
||
|
|
const entries = await readdir(MIGRATIONS_DIR, { withFileTypes: true });
|
||
|
|
const pending = entries
|
||
|
|
.filter((e) => e.isDirectory() && !applied.has(e.name))
|
||
|
|
.map((e) => e.name)
|
||
|
|
.sort();
|
||
|
|
for (const name of pending) {
|
||
|
|
const script = await readFile(path.join(MIGRATIONS_DIR, name, "migration.sql"), "utf8");
|
||
|
|
const id = randomUUID();
|
||
|
|
await client.query(`INSERT INTO "_prisma_migrations" (id, checksum, migration_name) VALUES ($1, $2, $3)`, [id, createHash("sha256").update(script).digest("hex"), name]);
|
||
|
|
try {
|
||
|
|
await client.query(script);
|
||
|
|
}
|
||
|
|
catch (e) {
|
||
|
|
await client.query(`UPDATE "_prisma_migrations" SET logs = $2 WHERE id = $1`, [
|
||
|
|
id,
|
||
|
|
String(e),
|
||
|
|
]);
|
||
|
|
throw new Error(`migration ${name} failed`, { cause: e });
|
||
|
|
}
|
||
|
|
await client.query(`UPDATE "_prisma_migrations" SET finished_at = now(), applied_steps_count = 1 WHERE id = $1`, [id]);
|
||
|
|
console.log(`applied ${name}`);
|
||
|
|
}
|
||
|
|
console.log(pending.length ? `${pending.length} migration(s) applied` : "no pending migrations");
|
||
|
|
}
|
||
|
|
try {
|
||
|
|
await client.connect();
|
||
|
|
await main();
|
||
|
|
}
|
||
|
|
catch (e) {
|
||
|
|
console.error(e);
|
||
|
|
process.exitCode = 1;
|
||
|
|
}
|
||
|
|
finally {
|
||
|
|
await client.end();
|
||
|
|
}
|
||
|
|
//# sourceMappingURL=migrate.js.map
|