使用事务时，查询中包含的子查询如何在 pg-promise 中工作？

Question

我在 node.js 中使用pg-promise，我想确保我正确理解有关事务的文档。

假设我执行了以下交易：

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 块中？

Answer 1

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

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

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

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

---

要准确查看pg-promise 正在执行的操作，您应该使用pg-monitor，或者至少 - 处理event query：

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
    });

更新

上面的示例不再是最有效的方法。最有效的方法是执行一次选择，然后执行一次多行插入。见Multi-Row Inserts。