Node.js连接MySQL按user_id更新s_rate字段不生效问题求解

• 参数读取逻辑错误：你传入的req.body是记录数组结构，直接访问params.s_rate、params.user_id得到的值都是undefined，SQL执行时没有有效更新值、也匹配不到目标行，自然无法完成更新。
• 日志打印对象错误：查询回调中你打印的是res（HTTP响应对象），不是数据库返回的执行结果rows，所以控制台会输出ServerResponse相关结构，根本看不到数据库真实执行状态。
• 缺少接口响应逻辑：数据库操作完成后没有给前端返回任何响应，请求会一直挂起直到超时。
• SQL逻辑和传参不匹配：当前单条UPDATE语句的作用是把指定user_id下所有记录的s_rate设为同一个值，如果你要更新的是同个user_id下不同id对应记录的不同s_rate值，这条SQL完全不适用。

根据你的实际需求二选一即可：

场景1：将指定user_id下所有记录的s_rate统一更新为同一个值 #

这种情况需要调整前端传参格式，不要传数组，直接传包含user_id和目标s_rate的单对象即可，接口代码修复如下：

app.post('/saveTable', (req, res) => {
    pool.getConnection((err, connection) => {
        if (err) {
            return res.status(500).json({ code: 500, msg: '数据库连接失败', err })
        }

        const { user_id, s_rate } = req.body
        // 参数合法性校验
        if (user_id === undefined || s_rate === undefined) {
            connection.release()
            return res.status(400).json({ code: 400, msg: '缺少必要参数user_id或s_rate' })
        }

        connection.query(
            'UPDATE words SET s_rate = ? WHERE user_id = ?',
            [s_rate, user_id],
            (err, result) => {
                connection.release()
                if (err) {
                    console.log('数据库执行错误：', err)
                    return res.status(500).json({ code: 500, msg: '更新失败', err })
                }
                console.log('更新结果：', result)
                // 返回响应给前端
                return res.json({ 
                    code: 200, 
                    msg: '更新成功', 
                    affectedRows: result.affectedRows 
                })
            }
        )
    })
})

场景2：按记录id批量更新同user_id下每条记录对应的s_rate #

也就是你当前传入数组的格式：每条记录带唯一主键id，需要把对应行的s_rate更新为该条记录传入的值，接口代码修复如下：

app.post('/saveTable', (req, res) => {
    pool.getConnection((err, connection) => {
        if (err) {
            return res.status(500).json({ code: 500, msg: '数据库连接失败', err })
        }

        const params = req.body
        // 参数格式校验
        if (!Array.isArray(params) || params.length === 0) {
            connection.release()
            return res.status(400).json({ code: 400, msg: '参数格式错误，需传入非空记录数组' })
        }
        const valid = params.every(item => item.id !== undefined && item.s_rate !== undefined && item.user_id !== undefined)
        if (!valid) {
            connection.release()
            return res.status(400).json({ code: 400, msg: '记录缺少必要字段id/s_rate/user_id' })
        }

        // 构造批量更新SQL
        const updateSql = `
            UPDATE words 
            SET s_rate = CASE id 
                ${params.map(() => 'WHEN ? THEN ?').join(' ')}
            END
            WHERE user_id = ? AND id IN (?)
        `
        // 组装SQL参数
        const sqlParams = []
        params.forEach(item => {
            sqlParams.push(item.id, item.s_rate)
        })
        sqlParams.push(params[0].user_id, params.map(item => item.id))

        connection.query(updateSql, sqlParams, (err, result) => {
            connection.release()
            if (err) {
                console.log('数据库执行错误：', err)
                return res.status(500).json({ code: 500, msg: '批量更新失败', err })
            }
            console.log('批量更新结果：', result)
            return res.json({
                code: 200,
                msg: '更新成功',
                affectedRows: result.affectedRows
            })
        })
    })
})

通用修复点说明 #

• 新增全链路参数校验，避免非法参数导致SQL执行异常
• 修正日志打印对象，改为输出数据库真实执行结果，方便排查问题
• 所有分支（参数错误、执行错误、执行成功）都返回标准HTTP响应，避免请求挂起
• 所有分支都正确释放数据库连接，避免连接池泄漏
• 批量更新场景增加user_id条件校验，避免越权更新其他用户的数据

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