node-db-migration

import { CommandsRunner, PsqlDriver } from 'node-db-migration'; import { Client } from 'pg'; import path from 'path'; import { fileURLToPath } from 'url'; const __filename = fileURLToPath(import.meta.url); const __dirname = path.dirname(__filename); async function runMigrations() { const client = new Client({ connectionString: process.env.DATABASE_URL ?? 'postgresql://postgres:@localhost:5432/test_db', }); try { await client.connect(); console.log('Connected to PostgreSQL database.'); const migrations = new CommandsRunner({ driver: new PsqlDriver(client), directoryWithScripts: path.join(__dirname, 'migrations'), // Ensure 'migrations' directory exists with .sql files migrationTable: 'my_app_migrations' // Optional: custom table name for migration tracking }); // Example: Create a dummy migration directory and file for demonstration // In a real app, these would be pre-existing. const fs = await import('fs/promises'); const migrationsDir = path.join(__dirname, 'migrations'); await fs.mkdir(migrationsDir, { recursive: true }); const migrationFileName = `${new Date().toISOString().replace(/[-:.]/g, '').substring(0, 14)}-create-users-table.sql`; await fs.writeFile(path.join(migrationsDir, migrationFileName), 'CREATE TABLE IF NOT EXISTS users (id SERIAL PRIMARY KEY, name VARCHAR(255) NOT NULL, email VARCHAR(255) UNIQUE);'); console.log('Running `migrate` command...'); await migrations.run('migrate'); console.log('Migrations completed successfully.'); // You can run other commands like 'list', 'getFailed', 'resolve' // console.log('\nListing unapplied migrations:'); // await migrations.run('list'); } catch (error) { console.error('Migration failed:', error); process.exit(1); } finally { await client.end(); console.log('Database connection closed.'); } } runMigrations();