node.js - Node mysql TypeError : conn. beginTransaction 不是一个函数

Question

我有一个 mysql 查询，我正在尝试使用使用事务的 node-mysql 执行。它应该在连接对象上，但我得到的错误表明它没有开始事务方法。

TypeError: conn.beginTransaction 不是函数

这是交易代码:

dbutil.transaction(req.db, 

    function(done){

        req.db.query('INSERT INTO answers (question, user, background, importance, comment) values (?, ?, ?, ?, ?)',
            [question, user, background, concurrence, importance, comment],  function (err, result){
                console.log('result from insert query: ', result);
                console.error('error: ', err);
                done();
            // req.db.query('INSERT INTO concurrenceAnswers (concurrence) values (?)',
            //     [concurrence], function (err, result){
            //         console.log('result form insert query: ', result);
            //         console.error('error: ', err);

            // })

        });


    }, function(){}

    );

及交易方式:

exports.transaction = function(conn, body, done) {
    conn.beginTransaction(function(err) {
        if (err) return done(err);

    body(function(err) {
        if (err) return conn.rollback(function() {
            done(err);
        });

        conn.commit(function(err) {
            if (err) return conn.rollback(function() {
                done(err);
            });

            done();
        });
    });
});
};

Req.db.query 是:

var db = mysql.createPool({
connectionLimit: config.db.connectionLimit,
host:            config.db.host,
user:            config.db.user,
password:        config.db.password,
database:        config.db.database,
port:            config.db.port

});

Answer 1

当您使用池时，您首先需要从池中获取连接(您不能像查询一样直接使用池来开始事务):

exports.transaction = function(connection, body, done) {

  connection.getConnection(function(err, conn) {

    conn.beginTransaction(function(err) {
      if (err) return done(err);

      body(function(err) {
        if (err) return conn.rollback(function() {
          done(err);
        });

        conn.commit(function(err) {
          if (err) return conn.rollback(function() {
            done(err);
          });

          done();
        });
      });
    });
  });
};