节点/蓝鸟/ MySQL交易

过去一周里，我一直在为蓝鸟承诺库和MySQL而努力。我经常发现，假设我完全沉浸在他们的术语中，并且往往只给出一半的答案，或者根本没有答案。让我停下来试图弄清楚如何使用它。节点/蓝鸟/ MySQL交易

目前我正试图执行一系列SQL命令来创建事务内的数据库记录。我使用此代码：

var Promise = require('bluebird'); 
var mysql = require('mysql'); 
Promise.promisifyAll(mysql); 
Promise.promisifyAll(require('mysql/lib/Connection').prototype); 
Promise.promisifyAll(require('mysql/lib/Pool').prototype); 

function getConnection() { 
    return pool.getConnectionAsync().disposer(function (connection) { 
     connection.release(); 
    }); 
} 

function getTransaction(connection) { 
    return connection.beginTransactionAsync().disposer(function (tx, promise) { 
     if (promise.isFulfilled()) { 
      tx.commitAsync(); 
     } else { 
      tx.rollbackAsync(); 
     } 
    }); 
} 

Database.prototype.addStory = function (projectId, title, text) { 
    return Promise.using(getConnection(), function (connection) { 
     return Promise.using(getTransaction(connection), function() { 
      return connection.queryAsync('INSERT INTO story SELECT ?, MAX(storyNumber) + 1, ?, ?, 0 FROM story WHERE projectID = ?', 
       [projectId, title, text, projectId]) 
       .then(connection.queryAsync('select LAST_INSERT_ID()')) 
       .then(function (rows) { 
        debug("Returning story for %s", rows[0]); 
        return getStory(connection, rows[0]); 
      }); 
     }); 
    }); 
}

而且目前我得到这个错误：

TypeError: tx.rollbackAsync is not a function

从我读过我的代码应该工作。有人知道它有什么问题吗？

来源

2016-06-28 drekka

其中是'pool'定义？ – flaviodesousa

感谢您的答案家伙。

我现在发现了Knex API，它可以用较少的代码解决我所有的问题。

来源

2016-06-29 10:56:02 drekka

节点/蓝鸟/ MySQL交易

回答

相关问题