Node/Express环境下多表查询数据无法获取问题求助

Hey there! 作为Node/Express新手碰到异步查询的问题太正常了——我当初刚上手的时候也在这栽过好几次跟头😅。你说的单个函数里多查询拿不到数据，大概率是异步操作的执行顺序没处理好，毕竟MySQL的查询默认是异步回调模式，如果你直接按同步逻辑写，代码会在查询完成前就往下跑，自然拿不到结果。

先模拟你可能写过的错误代码（结合users和run表的场景）：

function getRunUserInfo(userId) {
  let userEvent;
  let userRuns;

  // 查用户表的赛事字段
  db.query('SELECT event_name FROM users WHERE id = ?', [userId], (err, results) => {
    if (err) throw err;
    userEvent = results[0].event_name;
  });

  // 查该用户的跑步记录
  db.query('SELECT * FROM run WHERE user_id = ?', [userId], (err, results) => {
    if (err) throw err;
    userRuns = results;
  });

  // 这里直接返回的话，两个变量全是undefined！
  return { userEvent, userRuns };
}

为啥会这样？因为db.query是异步的——函数会先执行完最后一行的return，才会慢悠悠执行两个回调里的赋值操作，自然拿不到你要的数据。

把原生的回调式查询改成Promise版本，就能用async/await让异步代码「看起来像同步」，彻底避开时序问题：

// 先封装一个通用的Promise版查询函数
function dbQuery(sql, params) {
  return new Promise((resolve, reject) => {
    db.query(sql, params, (err, results) => {
      if (err) reject(err);
      else resolve(results);
    });
  });
}

// 再用async/await写你的业务逻辑
async function getRunUserInfo(userId) {
  try {
    // await会强制等待当前查询完成，再执行下一行
    const userResult = await dbQuery('SELECT event_name FROM users WHERE id = ?', [userId]);
    const runResult = await dbQuery('SELECT * FROM run WHERE user_id = ?', [userId]);

    // 现在两个数据都稳稳拿到了
    return {
      userEvent: userResult[0].event_name,
      userRuns: runResult
    };
  } catch (err) {
    // 统一捕获错误，避免程序崩溃
    console.error('查询出错:', err);
    throw err; // 把错误抛给上层处理
  }
}

// 调用的时候也要用await（或者用.then()）
app.get('/user/:id/run-data', async (req, res) => {
  try {
    const data = await getRunUserInfo(req.params.id);
    res.json(data);
  } catch (err) {
    res.status(500).json({ error: '数据查询失败' });
  }
});

如果暂时不想折腾Promise，也可以把第二个查询嵌套到第一个的回调里，强制保证执行顺序——但要注意，嵌套多了会变成「回调地狱」，代码可读性极差：

function getRunUserInfo(userId, callback) {
  // 先查用户表
  db.query('SELECT event_name FROM users WHERE id = ?', [userId], (err, userResults) => {
    if (err) return callback(err);
    
    // 拿到用户数据后，再查跑步记录
    db.query('SELECT * FROM run WHERE user_id = ?', [userId], (err, runResults) => {
      if (err) return callback(err);
      
      // 两个查询都完成了，把结果传给回调函数
      callback(null, {
        userEvent: userResults[0].event_name,
        userRuns: runResults
      });
    });
  });
}

// 调用示例
getRunUserInfo(101, (err, data) => {
  if (err) {
    console.error('出错了:', err);
  } else {
    console.log('拿到数据:', data);
  }
});

如果你的两个查询不需要先后顺序（比如已经知道userId，不需要从用户表取额外参数），可以用Promise.all()让两个查询同时发起，节省时间：

async function getRunUserInfo(userId) {
  try {
    // 同时发起两个查询，等待所有查询完成
    const [userResult, runResult] = await Promise.all([
      dbQuery('SELECT event_name FROM users WHERE id = ?', [userId]),
      dbQuery('SELECT * FROM run WHERE user_id = ?', [userId])
    ]);

    return {
      userEvent: userResult[0].event_name,
      userRuns: runResult
    };
  } catch (err) {
    console.error('查询出错:', err);
    throw err;
  }
}

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