mysql - Node-Mysql 事务回滚不起作用

Question

js 以及 mysql。我在交易方面遇到麻烦。

在下面的函数中，我完全按照他们所说的那样做 https://github.com/mysqljs/mysql#transactions 。但它不起作用:|

function insertMemoTransaction(){
  pool.getConnection(function(error, connection){
    if(error){
      alert("Somthing is wrong with your connection");
    }
    connection.beginTransaction(function(error){
      if(error) { throw error; }
      var idfield = scope.find('input[name="Party_Id"]');
      var Party_Id;
      if(idfield.val() == '-1'){
        var newParty = {
          // An object
        };
        connection.query("INSERT INTO ?? SET ?",['Party', newParty],function(error, result, fields){
          if(error){
            return connection.rollback(function(){
              throw error;
            });
          }
          else{
            Party_Id = result.insertId;
            var infoObj = {
              // an Object
            }


            connection.query('INSERT INTO ?? SET ?', ['Memo_Info', infoObj], function(error, result, fields){
              if(error){
                return connection.rollback(function(){
                  throw error;
                });
              }
            });
          }
        });
      }
      else{
        Party_Id = idfield.val();
        var infoObj = {
          // an Object
        }

        connection.query('INSERT INTO ?? SET ?', ['Memo_Info', infoObj], function(error, result, fields){
          if(error){
            return connection.rollback(function(){
              throw error;
            });
          }
        });
      }
      connection.commit(function(error) {
        if (error) { 
          return connection.rollback(function() {
            throw error;
          });
        }
        console.log('Transaction Complete.');
        connection.release();
      });
    });
  });
}

我写这段代码是为了在node-mysql中进行事务，但是如果，

 connection.query('INSERT INTO ?? SET ?', ['Memo_Info', infoObj], function(error, result, fields)

此查询不知何故无法运行，影响

connection.query("INSERT INTO ?? SET ?",['Party', newParty],function(error, result, fields)

这个不会回滚。

[我已设置自动提交 = 0]

Answer 1

问题#1

检查您的表正在使用哪个引擎:

show table status;

如果您的相关表设置为 MyISAM，那么您就发现了问题。 MyISAM不支持事务，因此无法回滚。您可以更改表以使用 InnoDB 作为引擎来解决问题:

ALTER TABLE table_name ENGINE = InnoDB;

或者在创建表时设置它:

CREATE TABLE table_name (
...
) ENGINE = InnoDB;

陷阱＃2

如果您使用的是池连接，请确保您的回滚查询使用相同的连接。

调用 pool.query() 不保证使用相同的连接，尽管在开发和测试期间可能看起来如此。

请参阅 pool.getConnection() 的文档使其发挥作用。