Node.js向MySQL插入大数据集：连接池与引号转义问题

问题根源 #

你遇到的ER_PARSE_ERROR大概率是因为手动拼接SQL字符串或者错误的参数传递方式，导致mysql模块对单引号进行了重复转义，或者转义后的SQL格式不符合语法要求。

正确的批量插入实现方式 #

mysql模块原生支持批量插入，并且会自动正确处理所有值的转义（包括单引号），核心是使用参数化查询，不要手动拼接VALUES部分：

1. 基础示例 #

假设你要插入的表结构是users(name, email)，批量插入代码如下：

// 引入全局连接池（你已经修正后的db模块）
const pool = require('./db');

// 待插入的记录数组，每个元素是对应字段的值数组
const batchRecords = [
  ["John O'Connor", "john@example.com"],
  ["Mary Ann", "mary@example.com"],
  ["Bob's Burger", "bob@example.com"]
];

// 构造SQL语句，VALUES后用单个?作为占位符
const insertSql = 'INSERT INTO users (name, email) VALUES ?';

// 执行批量插入，注意第二个参数是包含records数组的数组
pool.query(insertSql, [batchRecords], (err, result) => {
  if (err) {
    console.error('插入失败:', err);
    return;
  }
  console.log(`成功插入 ${result.affectedRows} 条记录`);
});

2. 为什么这样能解决转义问题 #

• mysql模块会自动遍历batchRecords中的每个值组，对每个字符串里的单引号进行正确转义（比如把John O'Connor转成符合MySQL要求的格式）
• 完全避免手动拼接SQL带来的语法错误和SQL注入风险

常见错误写法（需要避免） #

以下写法会导致转义问题或语法错误，务必不要用：

// 错误：手动拼接VALUES，导致转义重复或格式错误
let wrongSql = 'INSERT INTO users (name) VALUES ';
batchRecords.forEach((record, idx) => {
  wrongSql += idx > 0 ? ', ' : '';
  wrongSql += `('${record.name}')`; // 手动拼接字符串，模块会再次转义单引号
});

pool.query(wrongSql, (err) => {
  // 这里会出现ER_PARSE_ERROR，因为单引号被重复转义
});

调试技巧 #

如果还是遇到错误，可以用pool.format()方法查看最终生成的SQL，确认转义是否正确：

const formattedSql = pool.format(insertSql, [batchRecords]);
console.log('生成的SQL:', formattedSql);
// 输出示例：INSERT INTO users (name, email) VALUES ('John O\'Connor', 'john@example.com'), ('Mary Ann', 'mary@example.com')

通过查看生成的SQL，可以快速定位是转义问题还是字段/值不匹配的问题。

内容的提问来源于stack exchange，提问作者Ken Ingram