mysql2-import

import Importer from 'mysql2-import'; import path from 'path'; // Ensure .env or similar is set up for production const host = process.env.MYSQL_HOST ?? 'localhost'; const user = process.env.MYSQL_USER ?? 'root'; const password = process.env.MYSQL_PASSWORD ?? 'password'; const database = process.env.MYSQL_DATABASE ?? 'mydb'; const importer = new Importer({ host, user, password, database }); // Create a dummy SQL file for demonstration if it doesn't exist import fs from 'fs'; const dummySqlFilePath = path.join(process.cwd(), 'dummy_data.sql'); if (!fs.existsSync(dummySqlFilePath)) { fs.writeFileSync(dummySqlFilePath, ` DROP TABLE IF EXISTS \`users\`; CREATE TABLE \`users\` ( \`id\` INT AUTO_INCREMENT PRIMARY KEY, \`name\` VARCHAR(255) NOT NULL ); INSERT INTO \`users\` (name) VALUES ('Alice'), ('Bob'); `); console.log('Created dummy_data.sql for quickstart.'); } importer.onProgress(progress => { const percent = Math.floor(progress.bytes_processed / progress.total_bytes * 10000) / 100; console.log(`File ${progress.file_no} of ${progress.total_files}: ${percent}% Completed (${progress.file_path})`); }); importer.onDumpCompleted(data => { if (data.error) { console.error(`Error completing dump for ${data.file_path}:`, data.error); } else { console.log(`Dump completed for ${data.file_path}`); } }); importer.import(dummySqlFilePath).then(() => { const files_imported = importer.getImported(); console.log(`${files_imported.length} SQL file(s) imported successfully.`); }).catch(err => { console.error('An error occurred during import:', err); }).finally(() => { importer.disconnect(); console.log('Importer disconnected.'); // Clean up dummy file if it was created if (fs.existsSync(dummySqlFilePath)) { fs.unlinkSync(dummySqlFilePath); console.log('Removed dummy_data.sql.'); } });