Node.js/Express+MySQL：如何通过另一表数组查询关联数据

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

直接通过关联查询整合三张表，一次请求就能拿到所有任务及对应更新，避免多次数据库查询，效率更高。

修改后的代码：

// 获取所有任务及对应更新
Task.getAll = (userId, result) => {
  const query = `
    SELECT t.*, u.taskUpdate 
    FROM users us
    JOIN tasks t ON us.familyid = t.familyId
    LEFT JOIN updates u ON t.taskId = u.taskId
    WHERE us.id = ?
  `;

  sql.query(query, [userId], (err, res) => {
    if (err) {
      console.log("获取任务及更新出错: ", err);
      return result(null, err);
    }
    console.log("带更新的任务列表: ", res);
    return result(null, res);
  });
};

• 使用LEFT JOIN可保证无更新的任务也能被返回，此时taskUpdate字段为null；若仅需返回有更新的任务，替换为INNER JOIN即可。
• 原代码中直接拼接userId存在SQL注入风险，这里改为参数化查询[userId]，安全性更高。

方法二：基于现有逻辑批量查询更新 #

如果需要保留原有查询任务的流程，可通过IN语句批量查询所有任务对应的更新，再合并结果：

修改后的代码：

// 获取所有任务及对应更新
Task.getAll = (userId, result) => {
  sql.query(`SELECT familyid FROM users WHERE id = ?`, [userId], (err, userRes) => {
    if (err) {
      console.log("查询用户表出错: ", err);
      return result(null, err);
    }

    sql.query("SELECT * FROM tasks WHERE familyId = ?", userRes[0].familyid, (err, tasksRes) => {
      if (err) {
        console.log("查询任务表出错: ", err);
        return result(null, err);
      }

      if (tasksRes.length === 0) {
        return result(null, tasksRes);
      }

      // 提取所有任务ID
      const taskIds = tasksRes.map(task => task.taskId);
      // 批量查询对应更新
      sql.query(`SELECT taskId, taskUpdate FROM updates WHERE taskId IN (?)`, [taskIds], (err, updatesRes) => {
        if (err) {
          console.log("查询更新表出错: ", err);
          return result(null, err);
        }

        // 合并任务与更新数据
        const tasksWithUpdates = tasksRes.map(task => {
          const matchedUpdate = updatesRes.find(upd => upd.taskId === task.taskId);
          return {
            ...task,
            taskUpdate: matchedUpdate ? matchedUpdate.taskUpdate : null
          };
        });

        console.log("带更新的任务列表: ", tasksWithUpdates);
        return result(null, tasksWithUpdates);
      });
    });
  });
};

关于forEach失败的原因 #

如果之前尝试forEach循环查询更新失败，大概率是异步操作时序问题：sql.query是异步执行的，forEach不会等待每个查询完成就继续执行，导致结果还未返回就提前结束了。批量查询（IN语句）是更高效的解决方式，若一定要用循环，可改用Promise.all管理所有异步查询。

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