nodejs mysql和处理交易 - 代码设计

Question

因此，我对Nodejs并不陌生，这是问题所在。 我们都知道nodejs是单线螺纹，因此我们对任何I/O操作（如文件读取和数据库查询）使用异步操作

考虑以下代码，该代码基本上打开了交易，可以使某些数据库插入和提交：

    const mysql = require ("mysql2/promise")
    const pool   = mysql.createPool({
        host: "localhost",
        user: "<myuser>",
        password: "<mypass>",
        database: "<mydb>",
        connectionLimit: 10,
    });

    const test = async function () {
        let conn = await pool.getConnection()
        await conn.beginTransaction()
        await conn.execute("insert into test.temp1 (a) values(?)", [1])
        await conn.execute("insert into test.temp1 (a) values(?)", [2])
        await  conn.commit()
        await conn.release()
    }
    test()

这一切都很好，但这一切都很好，但是真实的实时代码结构更为复杂。一个查询可能会更新用户余额，另一个查询可能会插入日志记录和另一个查询，以在代码（可重用性）中的不同位置插入事务记录），所有这些都在一个事务中。

因此，考虑以下代码，该代码是上述代码的修改版本：

const pool   = mysql.createPool({
        host: "localhost",
        user: "<myuser>",
        password: "<mypass>",
        database: "<mydb>",
        connectionLimit: 10,
});

const function1 = async function (params){
    let conn = await pool.getConnection()
    await conn.execute("insert into test.temp1 (a) values(?)", [params])
    throw new Error("error in my code")
}
const test = async function () {
    let  conn = await pool.getConnection()
    await conn.beginTransaction()
    await function1(1)
    await function1(2)
    await  conn.commit()
    await conn.release()
}
test().catch(async function (err){
    let  conn = await pool.getConnection()
    conn.rollback()
    console.log(err)
})

问题是内部呼叫使用的连接与打开交易的连接不同，因此交易块不起作用，

我无法将连接存储在某些中静态资源并在我的内部函数中使用它，因为它是所有运行代码的单线螺纹和共享的

是我的解决方案，可以通过连接到所有类/函数？这并不是

我应该用来更好地支持交易的其他设计模式吗？