migrate_db.js

const mysql = require('mysql2/promise');
const fs = require('fs');
const path = require('path');

async function runMigration() {
    const config = {
        host: '172.29.0.11',
        port: 3306,
        user: process.argv[2],
        password: process.argv[3],
        database: 'ods_db',
        multipleStatements: true
    };

    try {
        console.log('Connecting to MySQL Server...');
        const connection = await mysql.createConnection(config);

        console.log('Connected! Reading migration script...');
        const sql = fs.readFileSync(path.join(__dirname, 'migration_v2.sql'), 'utf8');

        console.log('Executing migration...');
        await connection.query(sql);

        console.log('Migration completed successfully!');
        await connection.end();
    } catch (err) {
        console.error('Error:', err.message);
        process.exit(1);
    }
}

if (process.argv.length < 4) {
    console.log('Usage: node migrate_db.js <user> <password>');
    process.exit(1);
}

runMigration();