1

我正在使用pg-promisenode.js，我想确保我正确理解有关交易的文档。

假设我执行了以下交易：

db.tx(function(t) {
  t.any('SELECT * FROM users')
  .then(function(users) {
    var queries = [];
    for (var i =0; i < users.length; i++) {
      queries.push(t.any("INSERT INTO stocks_owned (ticker, shares, user_id) VALUES ('GOOG', 10, $1)", users[i].user_id));
    }
    return t.batch(queries);
  })
})

这最终会执行哪些 postgres 查询？

postgres 交易将是：

BEGIN;
SELECT * FROM users;
SAVEPOINT my_savepoint;
INSERT INTO stocks_owned (ticker, shares, user_id) VALUES ('GOOG', 10, 1);
INSERT INTO stocks_owned (ticker, shares, user_id) VALUES ('GOOG', 10, 2);
...
INSERT INTO stocks_owned (ticker, shares, user_id) VALUES ('GOOG', 10, 999);
COMMIT;

换句话说，包含在其他查询中的子查询是否包含在同一个BEGIN/COMMIT块中？

4

1 回答 1

0

这最终会执行哪些 postgres 查询？

您列出的那些，除了不会有任何SAVEPOINT，因为保存点仅用于代替嵌套事务。

包含在其他查询中的子查询是否包含在同一个 BEGIN/COMMIT 块中？

没有子查询这种东西，从驱动的角度来看，只有查询，所有在事务内部执行的都会在BEGIN/ COMMITblock 内部。

要查看pg-promise确切执行的内容，您应该使用pg-monitor，或者至少 - 处理事件查询：

var pgOptions = {
    query: function (e) {
        console.log(e.query); // log the query being executed
    }
};

var pgp = require('pg-promise')(pgOptions);

以下是您的代码中的错误：

t.any('SELECT * FROM users')

这应该是：

return t.any('SELECT * FROM users')

否则那里没有事务逻辑，因为您没有从回调中返回任何内容。

做你在那里尝试的最短和最有效的方法：

db.tx(t => {
    return t.map('SELECT * FROM users', [], user => {
        return t.none("INSERT INTO stocks_owned(ticker, shares, user_id) VALUES('GOOG', 10, ${user_id})", user);
    }).then(t.batch);
})
    .then(data => {
        // success, data = [null, null, ...]
    })
    .catch(error => {
        // error
    });

更新

上面的示例不再是最有效的方法。最有效的方法是执行一次选择，然后执行一次多行插入。请参阅多行插入。

于 2016-08-07T23:15:29.087 回答