Node.js中使用mssql在单个事务内执行多条查询的正确实现方式

结论先行 #

你可以使用mssql模块提供的Transaction能力，通过request.query依次执行多条语句实现需求，但你当前写的实现逻辑是完全错误的。

现有代码的核心问题 #

• 异步执行逻辑混乱：你写的多个request.query是并行触发的，完全无法保证Shipping新增→Listing更新→User_Notes新增等业务要求的执行顺序，事务一致性无法保障
• 提交时机错误：每个query的回调里都调用了transaction.commit，只要第一条SQL执行完成就会直接提交事务，后续所有操作都不会被纳入事务范围
• 缺少异常回滚逻辑：任意一步SQL执行出错时，没有调用transaction.rollback回滚已执行的操作，会产生脏数据
• 实例使用错误：同一个sql.Request实例不能同时执行多个异步query，会直接抛出请求冲突错误

正确实现逻辑 #

核心逻辑是按业务顺序串行执行所有SQL，全部执行成功再统一提交，任意一步出错直接回滚，推荐使用async/await写法避免回调地狱，示例代码如下：

const sql = require('mssql')

async function runMultiTableTransaction() {
    const transaction = new sql.Transaction(/* 传入你的数据库连接池实例 */)
    try {
        // 开启事务
        await transaction.begin()
        const request = new sql.Request(transaction)

        // 1. 新增Shipping表，建议使用参数化查询避免SQL注入
        await request.query(`INSERT INTO Shipping (col1, col2) VALUES ('val1', 'val2')`)
        // 2. 更新Listing表
        await request.query(`UPDATE Listing SET col1 = 'newVal' WHERE id = xxx`)
        // 3. 新增User_Notes表
        await request.query(`INSERT INTO User_Notes (col1, col2) VALUES ('val1', 'val2')`)
        // 4. 更新Customer_Login表
        await request.query(`UPDATE Customer_Login SET col1 = 'newVal' WHERE id = xxx`)
        // 5. 新增Push_Notification表
        await request.query(`INSERT INTO Push_Notification (col1, col2) VALUES ('val1', 'val2')`)

        // 所有操作执行成功，统一提交事务
        await transaction.commit()
        console.log('事务执行完成，已提交')
    } catch (err) {
        // 任意步骤出错，回滚所有操作
        await transaction.rollback()
        console.error('事务执行失败，已回滚，错误信息：', err)
        throw err
    }
}

如果必须使用回调写法，需要嵌套回调保证执行顺序，仅在最后一步执行提交：

const transaction = new sql.Transaction(/* 连接池实例 */)
transaction.begin(err => {
    if (err) return console.error('开启事务失败：', err)
    const request = new sql.Request(transaction)

    // 第一步：新增Shipping
    request.query('INSERT INTO Shipping ...', (err) => {
        if (err) return transaction.rollback(() => console.error('Shipping新增失败，已回滚：', err))
        // 第二步：更新Listing
        request.query('UPDATE Listing ...', (err) => {
            if (err) return transaction.rollback(() => console.error('Listing更新失败，已回滚：', err))
            // 第三步：新增User_Notes
            request.query('INSERT INTO User_Notes ...', (err) => {
                if (err) return transaction.rollback(() => console.error('User_Notes新增失败，已回滚：', err))
                // 第四步：更新Customer_Login
                request.query('UPDATE Customer_Login ...', (err) => {
                    if (err) return transaction.rollback(() => console.error('Customer_Login更新失败，已回滚：', err))
                    // 第五步：新增Push_Notification
                    request.query('INSERT INTO Push_Notification ...', (err) => {
                        if (err) return transaction.rollback(() => console.error('Push_Notification新增失败，已回滚：', err))
                        // 所有操作完成，统一提交
                        transaction.commit(err => {
                            if (err) return console.error('事务提交失败：', err)
                            console.log('事务提交成功')
                        })
                    })
                })
            })
        })
    })
})

注意事项 #

• 所有动态参数不要直接拼接SQL字符串，使用mssql的参数化查询功能：通过request.input('参数名', 数据类型, 参数值)声明参数，SQL语句中用@参数名占位，避免SQL注入风险
• 控制事务的执行时长，不要在事务执行过程中插入其他非数据库IO操作，避免长时间锁表影响其他业务请求

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