基于ExcelJS逐行处理Excel并实现数据库插入及结果反馈需求咨询

我之前刚好落地过类似需求，给你整理一套可直接复用的实现思路，代码都是实际跑通的：

1. 基础准备工作 #

先确保安装好依赖包：ExcelJS用于读写Excel，再加上你对应的数据库驱动（比如mysql2、pg等）：

npm install exceljs mysql2

2. 核心逻辑：逐行处理+状态标记 #

这里的关键是严格按顺序串行处理每行，绝对不能用并行操作，否则会打乱处理顺序。我们用async/await配合普通for循环实现，同时在每行末尾新增“处理状态”列，记录成功/失败详情：

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

// 初始化数据库连接池（复用连接更高效）
const pool = mysql.createPool({
  host: '你的数据库地址',
  user: '数据库用户名',
  password: '数据库密码',
  database: '目标数据库名'
});

async function processExcel(filePath) {
  // 读取待处理的Excel文件
  const workbook = new ExcelJS.Workbook();
  await workbook.xlsx.readFile(filePath);
  const worksheet = workbook.getWorksheet(1); // 默认取第一个工作表

  // 在表头最后添加“处理状态”列
  const statusColumnIndex = worksheet.columns.length + 1;
  const statusHeader = worksheet.getCell(1, statusColumnIndex);
  statusHeader.value = '处理状态';
  statusHeader.font = { bold: true };

  // 逐行处理（从第2行开始，跳过表头）
  for (let rowNum = 2; rowNum <= worksheet.rowCount; rowNum++) {
    const currentRow = worksheet.getRow(rowNum);
    // 把行数据转成对象，根据你的实际表头调整字段映射
    const rowData = {
      username: currentRow.getCell(1).value,
      email: currentRow.getCell(2).value,
      age: currentRow.getCell(3).value
    };

    try {
      // 数据库插入用参数化查询，防止SQL注入
      await pool.execute(
        'INSERT INTO user_info (username, email, age) VALUES (?, ?, ?)',
        [rowData.username, rowData.email, rowData.age]
      );
      // 标记处理成功
      currentRow.getCell(statusColumnIndex).value = '处理成功';
    } catch (error) {
      // 标记失败并记录错误信息
      currentRow.getCell(statusColumnIndex).value = `处理失败：${error.message}`;
      console.error(`第${rowNum}行处理出错：`, error);
    }
  }

  // 收集所有失败记录，用于生成结果文件
  const failedRecords = [];
  // 先把表头加入结果集
  failedRecords.push(worksheet.getRow(1).values);
  // 遍历筛选失败行
  for (let rowNum = 2; rowNum <= worksheet.rowCount; rowNum++) {
    const currentRow = worksheet.getRow(rowNum);
    const status = currentRow.getCell(statusColumnIndex).value;
    if (status?.startsWith('处理失败')) {
      failedRecords.push(currentRow.values);
    }
  }

  // 生成失败记录Excel
  const resultWorkbook = new ExcelJS.Workbook();
  const resultSheet = resultWorkbook.addWorksheet('失败记录');
  resultSheet.addRows(failedRecords);
  await resultWorkbook.xlsx.writeFile('处理失败记录.xlsx');

  console.log('处理完成！失败记录已保存到「处理失败记录.xlsx」');
  // 关闭数据库连接池
  await pool.end();
}

// 调用函数，传入你的待处理Excel路径
processExcel('待导入数据.xlsx').catch(err => console.error('全局异常：', err));

3. 必看注意事项 #

• 串行处理的必要性：一定要用普通for循环+async/await，别用forEach或map——这些方法不支持异步串行，会导致行处理顺序混乱，甚至数据库插入顺序出错。
• 内存优化：如果处理几十万行的超大Excel，建议用ExcelJS的流式读取API（workbook.xlsx.read配合流），避免内存溢出。
• 事务可选：如果需要保证数据一致性（比如某行失败就回滚所有已插入数据），可以把整个处理逻辑包在数据库事务里，根据业务需求决定。
• 日志补充：除了Excel里的标记，建议把错误信息写入日志文件，方便后续排查问题。

内容的提问来源于stack exchange，提问作者Prashanth Raghu