knex-umzug

import KnexUmzug from 'knex-umzug'; import { Umzug, migrator } from 'umzug'; import knex from 'knex'; const db = knex({ client: 'sqlite3', connection: { filename: './migrations.sqlite' }, useNullAsDefault: true // Recommended for sqlite3 with knex }); // Define your migrations directory const migrationsPath = `${process.cwd()}/migrations`; const umzug = new Umzug({ migrations: { glob: `${migrationsPath}/*.js`, // Optional: context can be passed to migration files // context: db }, storage: new KnexUmzug({ context: 'default', connection: db, tableName: 'umzug_migrations_table' }), logger: console // Or your preferred logger }); async function runMigrations() { console.log('Starting migrations...'); try { const migrations = await umzug.up(); console.log('Migrations finished successfully!', migrations); } catch (error) { console.error('Migration failed:', error); process.exit(1); } finally { await db.destroy(); // Close the database connection } } // Example migration file content (e.g., migrations/001-create-users-table.js) /* export const up = async ({ context: sequelize }) => { // Or knex object if passed via context // await knex.schema.createTable('users', (table) => { // table.increments('id').primary(); // table.string('name').notNullable(); // table.timestamps(true, true); // }); }; export const down = async ({ context: sequelize }) => { // await knex.schema.dropTable('users'); }; */ // Create a dummy migration file for demonstration import fs from 'fs/promises'; import path from 'path'; const dummyMigrationContent = ` export const up = async ({ context: knexInstance }) => { console.log('Running 001-create-test-table migration UP'); await knexInstance.schema.createTableIfNotExists('test_table', (table) => { table.increments('id').primary(); table.string('name').notNullable(); table.timestamps(true, true); }); }; export const down = async ({ context: knexInstance }) => { console.log('Running 001-create-test-table migration DOWN'); await knexInstance.schema.dropTableIfExists('test_table'); }; `; async function setupAndRun() { await fs.mkdir(migrationsPath, { recursive: true }); await fs.writeFile(path.join(migrationsPath, '001-create-test-table.js'), dummyMigrationContent); await runMigrations(); // Clean up dummy migration file and directory await fs.unlink(path.join(migrationsPath, '001-create-test-table.js')); await fs.rmdir(migrationsPath); } setupAndRun();