mysql - 如何使用nodeJs在Lambda函数中使用mysq事务提交回滚

Question

您好，我想在我的 Lambda(Node) 函数中使用 Mysql 的 beginTransactio 或 transactio 提交回滚功能。我尝试了 mysql 包的基本结构，但似乎它在 lambda 中不起作用

const mysql = require('mysql');
exports.handler = async (event) => {
    const con = mysql.createConnection(
        {
            host: "host",
            user: "user",
            password: "*****",
            database: "db"
        }
    );
    con.beginTransaction(
        function (err) {
            con.query(
                "query goes here",
                function (err, status) {
                    if (err) {
                        con.rollback();
                        con.end();
                        return err;
                    } else {
                        con.commit();
                        con.end();
                        return true;
                    }
                })
        });
}

Answer 1

抱歉延迟回复。只需要指定没有回调的 beginTransaction

const mysql = require('mysql');
exports.handler = async (event) => {
    const con = mysql.createConnection(
        {
            host: "host",
            user: "user",
            password: "*****",
            database: "db"
        }
    );
    con.beginTransaction(); //here i was declaring standard callback function with err parameter
            con.query(
                "query goes here",
                function (err, status) {
                    if (err) {
                        con.rollback();
                        con.end();
                        return err;
                    } else {
                        con.commit();
                        con.end();
                        return true;
                    }
                });
}