Sails.js + Postgres:与交易问题

问题描述:

我想在Sails 0.10.5中使用Postgres作为数据库实现一个事务,但是操作在最后没有被提交(或回滚)。Sails.js + Postgres:与交易问题

这是一个简单的交易场景我写下的测试(使用async.js):

testTransaction: function(uri) { 

    var testFile = { 
     uri: uri, 
     details: { 'firstDetail': 'value' } 
    }; 

    async.auto({ 
     begin_transaction: function(callback) { 
      DataFile.query('BEGIN TRANSACTION;', callback); 
     }, 
     new_data_file: ['begin_transaction', function(callback) { 
      DataFile.create(testFile).exec(callback); 
     }], 
    }, function(error, results) { 
     if (error) { 
      console.log(error.message); 
      DataFile.query('ROLLBACK;', function(e, r) { 
       return error.message; 
      }); 
      return; 
     } 
     DataFile.query('COMMIT;', function(e, r) { 
      console.log("Saved file: " + results.new_data_file); 
      if (e) { 
       return "Error during commit"; 
      } 
      return results.new_data_file; 
     }); 
    }); 

} 

然后我运行该服务没有错误;但是没有新的DataFile enetity被添加到Postgres表中。如果我检查Postgres的日志,我找出:

2014-12-04 10:35:01 GMT 7984 548038d0.1f30LOG: statement: BEGIN TRANSACTION; 
2014-12-04 10:35:01 GMT 7977 548038d0.1f29LOG: execute <unnamed>: INSERT INTO "data_file" ("uri", "details", "created_at", "updated_at") values ($1, $2, $3, $4) RETURNING * 
2014-12-04 10:35:01 GMT 7977 548038d0.1f29DETAIL: parameters: $1 = '/just/another/test/uri', $2 = '{"firstDetail":"value"}', $3 = '2014-12-04 10:35:01+00', $4 = '2014-12-04 10:35:01+00' 
2014-12-04 10:35:01 GMT 7983 548038d0.1f2fLOG: statement: COMMIT; 
2014-12-04 10:35:01 GMT 7983 548038d0.1f2fWARNING: there is no transaction in progress 

所以我得到警告:“没有交易正在进行” 在日志中的第三个元素是Process ID。 显然,COMMIT语句是由一个不同的进程(7983)发布的,而不是发布BEGIN(7984)的。这可能是问题吗?如何在处理Sails交易时强制使用相同的流程?

交易依赖于使用相同连接进行的多个查询,但Waterline为每个查询使用不同的连接,这就是为什么您会收到“没有正在处理的事务”消息 - 第二个查询正在使用不同的连接,它没有正在进行的事务。

除了将poolSize设置为1(因此每个查询都必须使用相同的连接)之外,没有办法解决此问题。

下面是我们用于交易的图书馆 - https://github.com/Shyp/pg-transactions。您将无法访问辅助方法 - .find(),.update()等,但至少有可能。