Node.js中使用mssql包批量插入SQL Server数据报错求助

一、错误原因：语法不兼容 #

你遇到的Incorrect syntax near '?'错误，核心原因是MySQL的VALUES ?批量插入语法是专属写法，MSSQL并不支持这种占位符格式。MSSQL有自己的批量插入规范，下面给你两种实用的解决方案：

二、方案1：使用mssql的Table参数（推荐） #

这是官方推荐的高效批量插入方式，既安全又能保证性能，适合数据量较大的场景：

const db = require('mssql');
let config = {
 user: 'salim',
 password: 'admin',
 server: 'LAPTOP-JK45R', // 连接命名实例请用'localhost\\instance'格式
 database: 'master',
}
var pool;
var connectPool = initializeConnectionPool();

function initializeConnectionPool() {
 pool = new db.ConnectionPool(config);
 pool.on('error', (err) => { console.error(err); });
 return pool.connect();
}

connectPool.then(async () => {
 console.log('Got pool connection...');

 // 1. 定义与数据库表匹配的Table结构
 const personTable = new db.Table('Person');
 personTable.columns.add('name', db.NVarChar(50), { nullable: false });
 personTable.columns.add('address', db.NVarChar(200), { nullable: false });

 // 2. 批量添加待插入的数据行
 const values = [
  ['John', 'Highway 71'],
  ['Peter', 'Lowstreet 4'],
  ['Amy', 'Apple st 652'],
  ['Hannah', 'Mountain 21']
 ];
 values.forEach(row => personTable.rows.add(...row));

 // 3. 执行批量插入操作
 const request = pool.request();
 request.input('PersonTable', personTable);
 const result = await request.query(`
  INSERT INTO Person (name, address)
  SELECT name, address FROM @PersonTable
 `);

 console.log(`Result: ${JSON.stringify(result)}`);
});

三、方案2：构造多组VALUES语句 #

如果不想使用Table参数，也可以手动构造符合MSSQL语法的多值插入语句，同时通过参数化查询避免SQL注入：

connectPool.then(async () => {
 console.log('Got pool connection...');

 const values = [
  ['John', 'Highway 71'],
  ['Peter', 'Lowstreet 4'],
  ['Amy', 'Apple st 652'],
  ['Hannah', 'Mountain 21']
 ];

 // 1. 生成参数占位符与参数列表
 const params = [];
 const placeholders = values.map((row, idx) => {
  const rowParams = row.map((_, colIdx) => `@p${idx * row.length + colIdx}`);
  params.push(...row);
  return `(${rowParams.join(', ')})`;
 }).join(', ');

 // 2. 构造完整的插入SQL
 const q = `INSERT INTO Person (name, address) VALUES ${placeholders}`;

 // 3. 绑定参数并执行查询
 const request = pool.request();
 params.forEach((val, idx) => request.input(`p${idx}`, db.NVarChar, val));
 const result = await request.query(q);

 console.log(`Result: ${JSON.stringify(result)}`);
});

四、如何查看mssql生成的查询语句 #

想要排查最终生成的SQL，有两种简单方法：

方式1：开启连接池调试日志 #

初始化配置时添加debug选项，控制台会输出所有执行的SQL语句：

let config = {
 user: 'salim',
 password: 'admin',
 server: 'LAPTOP-JK45R',
 database: 'master',
 options: {
  debug: true // 开启调试模式，输出SQL日志
 }
}

方式2：监听request的prepared事件 #

在执行查询前给request添加事件监听，直接获取生成的SQL文本：

const request = pool.request();
request.on('prepared', (statement) => {
 console.log('Generated SQL:', statement.text);
});
// 后续执行query操作即可看到输出

这样你就能直观看到发送给MSSQL的最终SQL，快速定位语法问题。

内容的提问来源于stack exchange，提问作者Salim Shamim