Node.js中async/await异步调用导致数据库操作时序错乱的问题求助

你的问题核心在于虽然给getNumOfSessionForTrainerClientList标了async，但函数内部还是用回调处理数据库查询，而且调用时没有用await等待异步操作完成，导致赋值语句在查询结果返回前就执行了，自然拿到的是初始值0。下面一步步帮你修复：

第一步：重构getNumOfSessionForTrainerClientList为真正的异步函数 #

把回调式的mysql查询改成Promise风格，这样才能用await等待结果。另外注意不要在函数里重复调用mysqlconn.connect()——如果已经有全局连接，重复连接会出问题，应该复用现有连接：

async function getNumOfSessionForTrainerClientList(req, rows) {
  // 用Promise包装mysql查询，方便await
  return new Promise((resolve, reject) => {
    const query = "select * from SCHEDULE WHERE CLIENT_USERNAME = ? AND ASSIGNED_TRAINER = ?";
    mysqlconn.query(query, [rows["USERNAME"], req.session.username], (err, sessionData) => {
      if (err) {
        console.log(err);
        reject(err);
        return;
      }
      // 这里根据你的业务逻辑返回计算值，比如sessionData的长度（你原来的代码里直接设为1，可按需调整）
      const numberOfSessions = sessionData.length;
      resolve(numberOfSessions);
    });
  });
}

第二步：在主查询的循环中正确使用await #

主函数里的循环需要等待每个异步调用完成后再执行赋值，所以要在for循环里用await，同时确保外层的query回调也是async函数（你已经标了，很好）：

var select = "select * from USERS WHERE ASSIGNED_TRAINER = ?";
mysqlconn.connect(function(err) {
  if (err) {
    console.error('Database connection failed: ' + err.stack);
    return;
  }
  mysqlconn.query(select, [req.session.username], async function(err, rows) {
    if (err) {
      console.log(err);
    } else {
      for (let i = 0; i < rows.length; i++) {
        // 等待异步函数返回结果
        const numOfSessionsUsed = await getNumOfSessionForTrainerClientList(req, rows[i]);
        // 现在可以安全地进行赋值计算
        rows[i]["NUM_OF_SESSIONS_PER_MONTH"] = parseInt(rows[i]["NUM_OF_SESSIONS_PER_MONTH"]) - numOfSessionsUsed;
        console.log(`Updated sessions for ${rows[i].USERNAME}: ${rows[i]["NUM_OF_SESSIONS_PER_MONTH"]}`);
      }
    }
    mysqlconn.end();
  });
});

额外优化建议 #

• 避免重复连接数据库：如果mysqlconn是全局连接对象，不要在每个函数里都调用connect()，初始化时连接一次即可，频繁连接会消耗资源。
• 使用连接池：对于生产环境，建议用mysql的连接池代替单连接，避免连接耗尽的问题：

  const pool = mysql.createPool({
    host: 'your-host',
    user: 'your-user',
    password: 'your-password',
    database: 'your-db'
  });
  // 使用时直接从池里拿连接
  pool.query(query, params, (err, results) => { ... });
  

• 完善错误处理：现在的代码里错误只是打印，建议在生产环境中加入更健壮的错误捕获（比如try/catch包裹await）：

  try {
    const numOfSessionsUsed = await getNumOfSessionForTrainerClientList(req, rows[i]);
    rows[i]["NUM_OF_SESSIONS_PER_MONTH"] = parseInt(rows[i]["NUM_OF_SESSIONS_PER_MONTH"]) - numOfSessionsUsed;
  } catch (err) {
    console.error(`Failed to get sessions for ${rows[i].USERNAME}:`, err);
    // 可以设置默认值或者跳过该用户
    rows[i]["NUM_OF_SESSIONS_PER_MONTH"] = parseInt(rows[i]["NUM_OF_SESSIONS_PER_MONTH"]);
  }
  

这样修改后，就能保证每次赋值操作都在异步查询完成后执行，不会再出现时序错乱的问题了。

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