Node.js使用mssql循环调用仅返回最后一次结果的问题咨询

我来帮你拆解这个问题的核心原因，以及对应的解决办法：

核心原因 #

1. 连接池被频繁关闭导致前序查询中断 #

你在getRecord函数里每次都先调用sql.close()，再执行sql.connect(config)——这是导致问题的关键。

mssql的sql.connect会创建一个全局连接池，当你在循环里快速调用5次getRecord时，前几次的连接还没建立完成，后续的sql.close()就已经把全局连接池关掉了，直接中断了前4次的查询请求，只有最后一次的查询能顺利完成并输出结果。

2. 变量作用域问题（结合你的输出结果推测） #

从你给出的输出param : 4来看，你实际代码里应该是调用getRecord(i)而非getRecord()。但你用了var i声明循环变量，var是函数作用域，循环里的所有getRecord调用共享同一个i变量。因为数据库查询是异步操作，当所有异步请求完成时，循环已经执行完毕，i的值已经变成了4，所以最终输出的param都是4。

修复方案 #

方案1：复用连接池+并行查询 #

不要每次查询都关闭和重建连接池，应该初始化一次连接池后复用，最后在所有操作完成后统一关闭：

// 先初始化全局连接池
sql.connect(config).then(pool => {
  // 收集所有查询的Promise
  const queryPromises = [];
  // 用let声明i，确保每次循环的变量独立
  for(let i = 0; i < 5; ++i){
    queryPromises.push(getRecord(pool, i));
  }
  // 等待所有并行查询完成
  return Promise.all(queryPromises);
}).then(allResults => {
  console.log("所有查询结果汇总:", allResults);
  // 所有操作完成后关闭连接池
  return sql.close();
}).catch(err => {
  console.error("查询出错:", err);
  // 出错也要确保连接池关闭
  sql.close();
});

// 修改getRecord，复用传入的连接池，无需重复连接/关闭
const getRecord = function(pool, param) {
  return pool.request()
    .query('select TOP 1 * from table')
    .then(result => {
      console.log(result);
      console.log('param : ' + param);
      return result.recordset;
    });
}

方案2：用async/await实现顺序查询（更易读） #

如果希望查询按顺序执行，可以用async/await简化异步流程：

async function runSequentialQueries() {
  let pool;
  try {
    // 初始化连接池
    pool = await sql.connect(config);
    // 用let声明i，捕获当前循环的正确值
    for(let i = 0; i < 5; ++i){
      const result = await pool.request().query('select TOP 1 * from table');
      console.log(result);
      console.log('param : ' + i);
    }
  } catch(err) {
    console.error("查询出错:", err);
  } finally {
    // 无论成功失败，都确保连接池关闭
    if(pool) await sql.close();
  }
}

// 执行查询
runSequentialQueries();

关键注意事项 #

• 用let代替var声明循环变量，保证每次循环的变量是独立的，异步操作能捕获到当前循环的正确值。
• 永远不要在循环里频繁关闭/重建数据库连接池，这不仅会导致请求中断，还会严重降低程序性能。

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