mysql - 如何使用 knex.js 使用事务

Question

我已经使用 knex 在数据库表中输入了多个记录，但我没有任何反应。我的代码如下:

  addApi : (data,CustomerId) => {
    knex.transaction(function(trx) {
      knex('books').transacting(trx).insert({name: 'Old Books'})
        .then(function(resp) {
          var id = resp[0];
          return someExternalMethod(id, trx);
        })
        .then(trx.commit)
        .catch(trx.rollback);
    })
    .then(function(resp) {
      console.log('Transaction complete.');
    })
    .catch(function(err) {
      console.error(err);
    });
  }

Answer 1

从你的问题来看，我假设交易是成功的，尽管你没有得到返回值。

您正在丢失您的 return someExternalMethod(id, trx); 响应值。相反，您得到的是 .then(trx.commit) 的响应值。您在 console.log('Transaction complete.'); 代码部分再次执行相同操作。

试试这个(编辑:代码现在已经过测试):

function testIt() {
    const knex  = require("knex")(dbcfg); // you will need your configuration

    function createBooksTable(table) {
        table.increments('id');
        table.string('name', 128);
    };

    function someExternalMethod(id, trx) {
        console.log("DBG02 .someExternalMethod Executed.");
        return [id];
    }

    function insertBooksRec() {
        return knex.transaction(function(trx) {
            knex('books').transacting(trx).insert({name: 'Old Books'})
            .then(function(resp) {
            var id = resp[0];
            return someExternalMethod(id, trx);
            })
            .then(function(extMethodReturn) {
            // return the value from the above .then
            console.log('DBG03 .extMethodReturn Returns:', extMethodReturn);
            return trx.commit()
                .then(function() { 
                    console.log('DBG04 .extMethodReturn Returns:', extMethodReturn);
                    return extMethodReturn; 
                });
            })
            .catch(trx.rollback)
            .then(function(resp) {
                console.log('DBG99 Insert Transaction complete. Returns:', resp);
                return resp; // if you want the value returned.
            })
            .catch(function(err) {
                console.error('DBG89 Insert Transaction ERROR:', err);
            });
        });
    };

    let tbl = knex.schema.createTableIfNotExists("books", createBooksTable)
    .then(function() {
        console.log('DBG01 BOOKS Table Creation complete:');
    })
    .catch(function(err) {
        console.error("DBG81 ERROR creating books table:", err);
    })
    .then(function() {
        return insertBooksRec()
    });

};
testIt();