umzug

import { Sequelize } from 'sequelize'; import { Umzug, SequelizeStorage } from 'umzug'; import { join, dirname } from 'path'; import { fileURLToPath } from 'url'; import { readFileSync, writeFileSync, existsSync, mkdirSync } from 'fs'; const __dirname = dirname(fileURLToPath(import.meta.url)); const dbPath = join(__dirname, 'db.sqlite'); const migrationsDir = join(__dirname, 'migrations'); // Ensure migrations directory exists if (!existsSync(migrationsDir)) { mkdirSync(migrationsDir, { recursive: true }); } // Create a dummy migration file for demonstration const migrationContent = ` const { DataTypes } = require('sequelize'); async function up({ context: queryInterface }) { await queryInterface.createTable('users', { id: { type: DataTypes.INTEGER, allowNull: false, primaryKey: true, autoIncrement: true }, name: { type: DataTypes.STRING, allowNull: false, }, createdAt: { type: DataTypes.DATE, allowNull: false, }, updatedAt: { type: DataTypes.DATE, allowNull: false, }, }); } async function down({ context: queryInterface }) { await queryInterface.dropTable('users'); } module.exports = { up, down }; `; const migrationFilePath = join(migrationsDir, '00_initial.js'); if (!existsSync(migrationFilePath)) { writeFileSync(migrationFilePath, migrationContent); } const sequelize = new Sequelize({ dialect: 'sqlite', storage: dbPath, logging: false // Suppress sequelize logs for cleaner output }); const umzug = new Umzug({ migrations: { glob: join(migrationsDir, '*.js') }, context: sequelize.getQueryInterface(), storage: new SequelizeStorage({ sequelize }), logger: console, }); (async () => { console.log('Running Umzug migrations...'); await umzug.up(); console.log('Migrations complete.'); // Optional: Verify table creation try { const [results] = await sequelize.query("SELECT name FROM sqlite_master WHERE type='table' AND name='users';"); if (results.length > 0) { console.log('Table "users" exists in the database.'); } else { console.log('Table "users" does NOT exist.'); } } catch (error) { console.error('Error verifying table:', error.message); } // Optional: Rollback example // console.log('Rolling back migrations...'); // await umzug.down(); // console.log('Rollback complete.'); await sequelize.close(); })();