Node.js导入mysqldump失败排查及替代方案咨询

首先，你的代码里有几个关键问题导致了导入后数据库为空的情况：

1. 数据库配置不匹配 #

你手动创建了footballers数据库，但导入时依赖config.db.database配置项。如果这个配置项的值不是footballers，数据会被导入到其他数据库中，导致你检查的目标库为空。

解决方法：
在sqldumpImporter函数中直接指定目标数据库，避免依赖可能出错的配置：

function sqldumpImporter () {
  importer.config({
    host: config.db.host,
    user: config.db.user,
    password: config.db.password,
    database: 'footballers' // 明确指定要导入的数据库
  })
  // ... 其他代码
}

2. 相对路径可能失效 #

你的SQL文件路径是./lib/api/sqldumps/footballers2655c10.sql，如果服务启动目录不是server文件夹（比如从项目根目录启动），这个相对路径会找不到文件，导致工具导入空内容却提示成功。

解决方法：
使用绝对路径确保文件能被正确找到：

const path = require('path');

function sqldumpImporter () {
  // ... 配置代码
  const sqlFilePath = path.resolve(__dirname, './lib/api/sqldumps/footballers2655c10.sql');
  importer.importSQL(sqlFilePath).then(/* ... */);
}

3. 新增验证步骤排查问题 #

可以在导入成功后手动查询数据库，确认数据是否真的导入：

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

async function verifyImport() {
  const conn = await mysql.createConnection({
    host: config.db.host,
    user: config.db.user,
    password: config.db.password,
    database: 'footballers'
  });
  const [rows] = await conn.query('SELECT COUNT(*) FROM footballers');
  console.log('表中数据行数:', rows[0]['COUNT(*)']);
  await conn.end();
}

// 在导入成功后调用验证
importer.importSQL(sqlFilePath).then( async () => {
  console.log('SQL dump successfully loaded');
  await verifyImport();
  syncSequelize();
})

如果node-mysql-importer不好用，推荐以下几种更可靠的方案：

1. 使用mysql2手动执行SQL文件 #

mysql2是mysql模块的升级版，支持Promise，能灵活处理各类SQL语句：

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

async function importSQLWithMysql2() {
  // 连接目标数据库
  const connection = await mysql.createConnection({
    host: config.db.host,
    user: config.db.user,
    password: config.db.password,
    database: 'footballers'
  });

  // 读取SQL文件内容
  const sqlContent = await fs.readFile(
    path.resolve(__dirname, './lib/api/sqldumps/footballers2655c10.sql'),
    'utf8'
  );

  // 分割SQL语句（若包含存储过程/DELIMITER，需额外处理）
  const statements = sqlContent.split(';')
    .map(stmt => stmt.trim())
    .filter(stmt => stmt.length > 0);

  // 逐个执行语句
  for (const stmt of statements) {
    await connection.execute(`${stmt};`);
  }

  await connection.end();
  console.log('SQL导入完成');
  syncSequelize();
}

2. 调用系统mysql命令行（最可靠） #

如果服务器安装了mysql客户端，直接调用命令行工具是处理复杂SQL Dump的最佳方式（支持存储过程、触发器等所有语法）：

const { exec } = require('child_process');
const path = require('path');

function importWithShellCommand() {
  const sqlFilePath = path.resolve(__dirname, './lib/api/sqldumps/footballers2655c10.sql');
  // 构建导入命令（生产环境建议用环境变量或配置文件传递密码，避免明文风险）
  const cmd = `mysql -h ${config.db.host} -u ${config.db.user} -p${config.db.password} footballers < ${sqlFilePath}`;

  exec(cmd, (err, stdout, stderr) => {
    if (err) {
      console.error(`导入失败: ${stderr}`);
      return;
    }
    console.log('SQL导入成功');
    syncSequelize();
  });
}

3. 使用Sequelize直接执行SQL内容 #

如果你已经在用Sequelize，可直接读取SQL文件并执行（适合简单SQL Dump）：

const fs = require('fs').promises;
const path = require('path');

async function importWithSequelize() {
  const sqlContent = await fs.readFile(
    path.resolve(__dirname, './lib/api/sqldumps/footballers2655c10.sql'),
    'utf8'
  );
  
  // 执行原生SQL
  await db.sequelize.query(sqlContent, { raw: true });
  console.log('导入完成');
  syncSequelize();
}

内容的提问来源于stack exchange，提问作者Dani Vijay