Node.js+MySQL后端：基于两次查询构建合并数组问题求助

核心问题 #

1. 异步逻辑失效：forEach不支持异步等待，且回调式db.query无法追踪所有异步操作的完成状态，导致allData在数据未填充时就被调用。
2. 字段拼写错误：代码中firsName是笔误，应为firstName。
3. 低效多次查询：循环调用数据库查询会产生冗余请求，性能不如一次关联查询。

方案一：SQL JOIN一次性查询（推荐） #

直接通过JOIN关联两张表，一次查询就能获取目标数据，无需后续循环处理：

export const view = async (req, res) => {
  const { classIdentifier, syllabusCode } = req.body;
  const { teacherID } = req.params;

  const query = `
    SELECT DISTINCT ci.studentID AS userID, ui.firstName, ui.lastName
    FROM classIndex ci
    JOIN userIndex ui ON ci.studentID = ui.userID
    WHERE ci.teacherID = ? 
      AND ci.classIdentifier = ? 
      AND ci.syllabusCode = ?;
  `;

  db.query(query, [teacherID, classIdentifier, syllabusCode], (err, rows) => {
    if (err) {
      console.error(err);
      return res.status(500).json({ error: '数据库查询失败' });
    }
    res.json(rows);
  });
};

方案二：修复异步逻辑（分步查询场景） #

若必须分步查询，需将回调式db.query封装为Promise，用Promise.all管理所有异步请求：

// 封装数据库查询为Promise
const queryPromise = (sql, params) => {
  return new Promise((resolve, reject) => {
    db.query(sql, params, (err, results) => {
      if (err) reject(err);
      else resolve(results);
    });
  });
};

export const view = async (req, res) => {
  try {
    const { classIdentifier, syllabusCode } = req.body;
    const { teacherID } = req.params;

    // 获取userID列表
    const userIdsResult = await queryPromise(
      "SELECT DISTINCT studentID AS userID FROM classIndex WHERE teacherID = ? AND classIdentifier = ? AND syllabusCode = ?;",
      [teacherID, classIdentifier, syllabusCode]
    );

    // 批量查询用户信息
    const userPromises = userIdsResult.map(row => 
      queryPromise(
        "SELECT userID, firstName, lastName FROM userIndex WHERE userID = ?",
        [row.userID]
      )
    );

    const userResults = await Promise.all(userPromises);
    
    // 合并并格式化结果
    const allData = userResults.flat().map(user => ({
      userID: user.userID,
      firstName: user.firstName, // 修复拼写错误
      lastName: user.lastName
    }));

    res.json(allData);
  } catch (err) {
    console.error(err);
    res.status(500).json({ error: '服务器错误' });
  }
};

关键修复说明 #

• Promise封装：将回调式查询转为Promise，适配async/await异步流程管理。
• Promise.all：确保所有用户信息查询完成后再处理结果，避免数据未就绪问题。
• 字段修正：将firsName改为firstName，保证返回字段与预期一致。
• 异常捕获：统一处理错误，向前端返回合理的错误响应。

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