节点mysql TypeError: conn.beginTransaction不是一个函数

Question

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

TypeError: conn.beginTransaction is not a function

这是交易代码:

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。查询的方法是:

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();
        });
      });
    });
  });
};