pg-promise结合Promise.all()执行事务的内部机制解析

问题1：单连接事务中，Promise.all里的两个查询是否必须串行执行？ #

是的，第二个查询必须等第一个完成后才能执行。核心原因在于：事务会绑定单个数据库连接，而PostgreSQL的单个连接是单线程处理请求的——同一时间只能处理一个查询任务。

你用Promise.all()只是在代码层面发起了两个异步调用，但这两个调用共享同一个事务连接，pg-promise会把它们放到该连接的任务队列里，按顺序串行执行。数据库层面始终是先完成第一个SELECT * FROM table1，才会开始处理第二个SELECT * FROM table2。

问题2：单连接下的事务“并行”查询如何实现？ #

这里的“并行”只是代码写法上的并行，而非数据库层面的真正并行，具体实现逻辑如下：

• 事务对象t与单个数据库连接绑定，所有通过t发起的查询都会关联到这个连接。
• 当你在Promise.all()中调用t.any()时，每个查询请求都会被加入到该连接的内部任务队列。
• pg-promise会维护这个队列，当前一个查询执行完成、释放连接的处理权后，才会从队列中取出下一个查询执行。
• Promise.all()会等待所有查询的Promise状态变为resolved，最终返回两个查询结果组成的数组，让你可以用更简洁的写法处理多个异步查询的结果，但底层执行依然是串行的。

你的示例代码如下：

const {TransactionMode} = pgp.txMode;

// Create a reusable transaction mode (serializable + read-only + deferrable):
const mode = new TransactionMode({
    readOnly: true,
    deferrable: true
});

db.tx({mode}, t => {
    return Promise.all([t.any('SELECT * FROM table1'),t.any('SELECT * FROM table2')]);
})
.then(data => {
   // success;
})
.catch(error => {
   // error
});

内容的提问来源于stack exchange，提问作者Arjun Londhey