为什么在使用 pg-promise 的事务中不能解锁咨询锁？

Question

我遇到了以下代码并试图调试它，但我不明白为什么在这种情况下无法解锁锁：

const db = pgp(opts)

await db.one('SELECT pg_try_advisory_lock(1) AS lock') // returns true, and I can see the lock in the DB

// no await 
db.tx(async t => {
      const fingerprintIds = fingerprints.map(item => item.id)
      sql = `UPDATE fingerprint SET blah=1 WHERE id IN ($(fingerprintIds:list)) RETURNING id`
      const updatedFingerprintIds = await db.query(sql, { fingerprintIds }) // yes, it is not using the transaction object 

      // some other database calls
    })

result = await db.one('SELECT pg_advisory_unlock(1) AS lock')
// result.lock === false, database logs the error: 'WARNING:  you don't own a lock of type ExclusiveLock'
// lock still stays in the database (until the session ends)

当然，当我在db.tx 调用前面添加await，并在事务回调中使用t 时，它会按预期工作。

这是因为调用unlock 时 pg-promise 库处于事务状态吗？因为当我调用这一系列查询时，锁会按预期解锁：

SELECT pg_try_advisory_lock(1) AS lock;
BEGIN;
SELECT * FROM table;
SELECT pg_advisory_unlock(1) AS lock;

Answer 1

这些锁定操作是当前连接会话所独有的，因此它们必须在同一个事务块内执行：

await db.tx(async t => {

    await t.func('pg_try_advisory_lock', [1]);

    // execute all queries here, against 't' context;
    // ...

    await t.func('pg_advisory_unlock', [1]);

});

• 我们在这里使用func 方法只是为了缩短语法。

但是，如果事务失败，则不会执行解锁，所以如果这是一个问题，那么您将需要手动捕获事务中的错误：

await db.tx(async t => {

    await t.func('pg_try_advisory_lock', [1]);

    let result, err;

    try {
        // execute all queries here, against 't' context;
        // and set the 'result'...

    } catch(e) {
        err = e;
    }

    await t.func('pg_advisory_unlock', [1]);

    if(e) {
        throw e;
    }
    return result;
});

更新

我正在使用咨询锁，因为在这个数据库事务之外还有很多其他事情（非幂等、非数据库）发生，并且由于有多个应用程序实例正在运行，因此锁是防止其他实例同时做同样的工作

我不确定这种类型的锁如何帮助跨多个数据库甚至多个应用程序，因为这些锁只能在同一个会话中工作。

但是，如果您确实需要在事务之外执行这些锁，并且针对相同的连接，那么您将需要手动管理连接：

// Somewhere in the beginning of your chain logic,
// you allocate a manually-managed connection:
const dbm = await db.connect();

// Then your lock happens:
await dbm.func('pg_try_advisory_lock', [1]);


// Then you transaction happens...
await dbm.tx(async t => {
    // transaction queries
});

// Then your unlock query:
await dbm.func('pg_advisory_unlock', [1]);

// Then you release the connection:
dbm.done();

你只需要小心这个，不要泄漏连接;）

• 见方法connect。