Node mysql TypeError：conn.beginTransaction 不是函数

我有一个 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.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

});

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

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