Node.js中如何在回调函数中传递参数及解决异步操作下data变量未更新的问题

嘿，你遇到的是JavaScript异步操作的经典坑！connection.query是异步函数，它不会阻塞代码执行——当你调用它之后，代码会立刻跳到后面的if (i == ori_image_path.length - 1)判断，然后执行res.send(data)，但这时候回调函数还没跑（数据库查询还没完成呢），所以data还是初始的{}，自然拿不到错误信息。

给你两种靠谱的解决方案：

方案1：用Promise + async/await（推荐，代码更易读） #

先把connection.query包装成Promise（现在很多数据库库本身就支持Promise，比如mysql2，如果你用的是旧版mysql，自己包装一下就行）：

// 包装query为Promise函数
function queryPromise(sql, params) {
  return new Promise((resolve, reject) => {
    connection.query(sql, params, (err, results) => {
      if (err) reject(err);
      else resolve(results);
    });
  });
}

然后在你的请求处理函数里用async/await，配合Promise.all等待所有查询完成：

// 注意外层函数要加async
async function handleImageUpload(req, res) {
  const data = {};
  try {
    // 遍历所有路径，生成查询Promise数组
    const queryPromises = ori_image_path.map((oriPath, index) => {
      const srcPath = src_image_path[index];
      const title = yourTitleArray[index]; // 替换成你实际的title数组
      return queryPromise(sql, [oriPath, srcPath, title]);
    });

    // 等待所有查询完成，只要有一个失败就会进入catch
    await Promise.all(queryPromises);
    
    // 所有查询都成功
    data.success_message = "이미지 업로드 완료";
  } catch (err) {
    // 捕获任意一个查询的错误
    console.dir(err);
    data.error_message = "failed";
  }
  // 最后统一发送响应
  res.send(data);
}

方案2：用计数器跟踪异步完成（传统回调方式） #

如果不想用Promise，也可以用计数器来记录有多少个查询已经完成，等全部完成后再发送响应：

const data = {};
const totalQueries = ori_image_path.length;
let completedQueries = 0;

ori_image_path.forEach((oriPath, index) => {
  const srcPath = src_image_path[index];
  const title = yourTitleArray[index]; // 替换成实际的title数组
  
  connection.query(sql, [oriPath, srcPath, title], (err, results) => {
    completedQueries++;
    
    // 如果有错误，标记错误信息
    if (err) {
      console.dir(err);
      data.error_message = "failed";
    }
    
    // 当所有查询都完成时，才发送响应
    if (completedQueries === totalQueries) {
      if (!data.error_message) {
        data.success_message = "이미지 업로드 완료";
      }
      res.send(data);
    }
  });
});

核心问题就是：异步操作的回调不会立刻执行，你不能在同步代码里直接访问异步回调里修改的变量，必须等所有异步操作完成后再处理结果~

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