javascript - 第二次查询执行出错如何回滚| Node JS

Question

我以前在 PHP 中使用回滚，我想在 NodeJS 中实现相同的概念。我正在调用一个将数据插入到 database 的函数，成功后我从另一个 Model 调用另一个函数将数据插入到另一个 table.

我的代码

StoreReport

'use strict';

var sql = require('./db.js');

// IMPORT ANOTHER MODEL
var CashDetailModel = require('./cashDetailModel.js');

var StoreReport =function(storeReport){
    this.store_id=storeReport.store_id;
    this.cash_expense=storeReport.cash_expense_amount;

}

StoreReport.addNewStoreReport = function (report_details,request,result){

    sql.query('INSERT INTO store_report SET ?',report_details, function(err,res){
        if(err){
            result(err,null);
        }else{
            var new_cash_detail = new CashDetailModel(report_details);
            new_cash_detail.store_report_id=res.insertId;
            CashDetailModel.addCashDetail(new_cash_detail,function(err,CashDetailModel){
                if(err){

                  // I NEED TO ROLLBACK IF ERROR OCCURED IN THIS PHASE
                    res.send(err);
                }else{
                    result(null,res.inserted);
                }
            })
        }
    })
}

module.exports = StoreReport;

Answer 1

这里解释得很好:https://know-thy-code.com/transactions-with-multiple-queries-nodejs-mysql/ .

您在第一个查询之前调用 sql.beginTransaction() 并将您的查询写入回调中。然后您可以使用 sql.rollback() 回滚您的事务或使用 sql.commit() 提交更改。