postgresql中的咨询锁超时

Question

我正在从ORACLE迁移.目前我正在尝试移植此电话:

lkstat := DBMS_LOCK.REQUEST(lkhndl, DBMS_LOCK.X_MODE, lktimeout, true);

此函数尝试获取锁定lkhndl,如果在timeout几秒钟后无法获取锁定,则返回1 .

在postgresql我用

pg_advisory_xact_lock(lkhndl);

但是,它似乎永远等待锁定.pg_try_advisory_xact_lock如果失败则立即返回.有没有办法实现锁定获取的超时版本？

有lock_timeout设置,但我不确定它是否适用于咨询锁定以及pg_advisory_xact_lock超时后的行为方式.

Answer 1

这是一个很难模拟的包装器原型DBMS_LOCK.REQUEST- 仅限于一种类型的锁（事务范围咨询锁）。

为了使函数与 Oracle 的完全兼容，需要数百行。但这只是一个开始。

CREATE OR REPLACE FUNCTION
advisory_xact_lock_request(p_key bigint, p_timeout numeric)
RETURNS integer
LANGUAGE plpgsql AS $$
/*  Imitate DBMS_LOCK.REQUEST for PostgreSQL advisory lock. 
Return 0 on Success, 1 on Timeout, 3 on Parameter Error. */
DECLARE
    t0 timestamptz := clock_timestamp();
BEGIN
    IF p_timeout NOT BETWEEN 0 AND 86400 THEN
        RAISE WARNING 'Invalid timeout parameter';
        RETURN 3;
    END IF;
    LOOP
        IF pg_try_advisory_xact_lock(key) THEN
            RETURN 0;
        ELSIF clock_timestamp() > t0 + (p_timeout||' seconds')::interval THEN
            RAISE WARNING 'Could not acquire lock in % seconds', p_timeout;
            RETURN 1;
        ELSE
            PERFORM pg_sleep(0.01); /* 10 ms */
        END IF;
    END LOOP;
END;
$$;

使用以下代码进行测试：

SELECT CASE 
    WHEN advisory_xact_lock_request(1, 2.5) = 0
    THEN pg_sleep(120)
END; -- and repeat this in parallel session 

/* Usage in Pl/PgSQL */

lkstat := advisory_xact_lock_request(lkhndl, lktimeout);