mysql - Node/Bluebird/MySQL 事务

Question

在过去的一周里，我一直在与 Bluebird promise 库和 MySQL 作斗争。我不断发现 doco 假设我完全沉浸在他们的术语中，并且通常只给出示例中一半的答案，或者根本没有。让我绞尽脑汁想弄清楚如何使用它。

目前我正在尝试执行一系列 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

根据我的阅读，我的代码应该可以工作。有谁知道它有什么问题吗？

Answer 1

谢谢大家的回答。

我现在找到了 Knex API 用更少的代码解决了我所有的问题。