在.map()循环中执行SQL查询返回Shift Not Found报错如何排查

你现在的代码存在4个核心问题，直接导致功能异常：

• 错误逻辑完全混淆：connection.query回调的err参数仅代表SQL执行层面的故障（比如语法错误、连接中断、权限不足、字段不存在），和是否匹配到待更新的行没有任何关系。只要UPDATE语句语法合法，就算WHERE条件查不到任何记录，err也会是null。你现在把所有SQL执行错误都直接返回“Shift Not Found”，相当于把真实报错完全吞掉了，根本看不到实际故障原因。你目前一直进else分支，本质是SQL执行本身就报错了，常见诱因包括直接拼接SQL导致的语法问题、字段名/表名拼写错误、参数类型不匹配。
• 响应逻辑错误：你在数组遍历的回调里反复调用res.json()，只要shiftIDs长度大于1，第一次响应发出后后续调用会直接触发服务报错；就算数组长度为1，也因为判断逻辑错误返回错误结果。
• 异步捕获失效：try/catch无法捕获回调风格异步函数里抛出的错误，一旦数据库操作出现非预期错误，你的500错误捕获分支根本不会触发。
• 存在SQL注入风险：直接拼接用户传入参数到SQL语句中，不仅容易出现类型拼接错误，还存在严重的安全隐患。

按顺序操作即可快速定位问题：

1. 先在err分支打印完整错误信息和拼接后的SQL语句，不要返回写死的提示：

(err, rows) => {
  if (err) {
    console.log('SQL执行错误详情：', err)
    console.log('执行的SQL语句：', `UPDATE shift SET isBooked=${isBooked}, fk_guard=${guard_id} WHERE shiftID=${shift_id}`)
  }
  // 其余逻辑
}

打印出来的内容会直接告诉你是字段拼错、语法错还是连接问题。
2. 修正更新结果判断逻辑：SQL执行无错时，判断返回结果的affectedRows字段，值为0才代表没有匹配到对应shiftID的记录，值大于0才是更新成功。
3. 移除循环内的响应调用，等所有数据库操作执行完成后，统一返回一次结果。
4. 替换字符串拼接写法，改用参数化查询传入参数，从根源避免SQL拼接错误和注入问题。

推荐使用mysql2驱动的Promise写法，逻辑更清晰，也能正确捕获异步错误：

// 需提前安装mysql2：npm i mysql2，连接初始化时引入mysql2/promise
const approveShifts = async (req, res) => {
  const { guard_id } = req.params;
  const { shiftIDs, isBooked } = req.body;

  // 基础入参校验
  if (!Array.isArray(shiftIDs) || shiftIDs.length === 0) {
    return res.status(400).json({
      success: false,
      message: "shiftIDs必须为非空数组"
    })
  }

  try {
    const successShifts = []
    const failShifts = []

    for (const shift_id of shiftIDs) {
      try {
        // 参数化查询，用?占位符，驱动自动处理参数类型转义
        const [result] = await connection.query(
          'UPDATE shift SET isBooked = ?, fk_guard = ? WHERE shiftID = ?',
          [isBooked, guard_id, shift_id]
        )
        if (result.affectedRows > 0) {
          successShifts.push(shift_id)
        } else {
          failShifts.push({ shift_id, reason: "对应班次不存在" })
        }
      } catch (sqlError) {
        failShifts.push({ shift_id, reason: sqlError.message })
      }
    }

    // 所有操作完成后统一返回响应
    res.status(200).json({
      success: failShifts.length === 0,
      message: failShifts.length === 0 ? "所有班次审核完成" : "部分班次审核失败",
      data: { successShifts, failShifts }
    })
  } catch (error) {
    res.status(500).json({
      success: false,
      message: error.message
    })
  }
}

提示：如果待更新的shiftID数量很大，不建议循环单条执行UPDATE，可以通过CASE WHEN语法拼接单条批量更新语句，减少数据库IO消耗。如果业务要求所有更新要么全成功要么全失败，可以给更新操作加数据库事务保证一致性。

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