pg_dbms_lock
为PG添加对 Oracle DBMS_LOCK 的完整兼容性支持
仓库
HexaCluster/pg_dbms_lock
https://github.com/HexaCluster/pg_dbms_lock
源码
pg_dbms_lock-2.0.tar.gz
pg_dbms_lock-2.0.tar.gz
概览
| 扩展包名 | 版本 | 分类 | 许可证 | 语言 |
|---|---|---|---|---|
pg_dbms_lock | 2.0 | SIM | PostgreSQL | SQL |
| ID | 扩展名 | Bin | Lib | Load | Create | Trust | Reloc | 模式 |
|---|---|---|---|---|---|---|---|---|
| 9250 | pg_dbms_lock | 否 | 否 | 否 | 是 | 否 | 否 | dbms_lock |
| 相关扩展 | pg_background orafce session_variable pg_dbms_metadata pg_dbms_job oracle_fdw pgtt pg_statement_rollback mysql_fdw |
|---|
Requires pg_background >= 2.0; the PIGSTY DEB carries a downstream pg_background v2 API compatibility patch.
版本
| 类型 | 仓库 | 版本 | PG 大版本 | 包名 | 依赖 |
|---|---|---|---|---|---|
| EXT | MIXED | 2.0 | 1817161514 | pg_dbms_lock | pg_background |
| RPM | PGDG | 2.0 | 1817161514 | pg_dbms_lock_$v | pg_background_$v |
| DEB | PIGSTY | 2.0 | 1817161514 | postgresql-$v-pg-dbms-lock | postgresql-$v-pg-background |
构建
您可以使用 pig build 命令构建 pg_dbms_lock 扩展的 DEB 包：
pig build pkg pg_dbms_lock # 构建 DEB 包
安装
您可以直接安装 pg_dbms_lock 扩展包的预置二进制包，首先确保 PGDG 和 PIGSTY 仓库已经添加并启用：
pig repo add pgsql -u # 添加仓库并更新缓存
使用 pig 或者是 apt/yum/dnf 安装扩展：
pig install pg_dbms_lock; # 当前活跃 PG 版本安装
pig ext install -y pg_dbms_lock -v 18 # PG 18
pig ext install -y pg_dbms_lock -v 17 # PG 17
pig ext install -y pg_dbms_lock -v 16 # PG 16
pig ext install -y pg_dbms_lock -v 15 # PG 15
pig ext install -y pg_dbms_lock -v 14 # PG 14
dnf install -y pg_dbms_lock_18 # PG 18
dnf install -y pg_dbms_lock_17 # PG 17
dnf install -y pg_dbms_lock_16 # PG 16
dnf install -y pg_dbms_lock_15 # PG 15
dnf install -y pg_dbms_lock_14 # PG 14
apt install -y postgresql-18-pg-dbms-lock # PG 18
apt install -y postgresql-17-pg-dbms-lock # PG 17
apt install -y postgresql-16-pg-dbms-lock # PG 16
apt install -y postgresql-15-pg-dbms-lock # PG 15
apt install -y postgresql-14-pg-dbms-lock # PG 14
创建扩展：
CREATE EXTENSION pg_dbms_lock CASCADE; -- 依赖: pg_background
用法
使用 PostgreSQL 咨询锁模拟 Oracle DBMS_LOCK 行为。
启用
CREATE EXTENSION pg_dbms_lock;
ALLOCATE_UNIQUE
为命名锁分配唯一锁标识符：
DO $$
DECLARE
lockhandle varchar;
BEGIN
CALL dbms_lock.allocate_unique(
lockname => 'printer_lock',
lockhandle => lockhandle
);
RAISE NOTICE 'Handle: %', lockhandle;
END;
$$;
REQUEST
以指定模式请求锁（Exclusive=6，Shared=4）：
DO $$
DECLARE
lock_res int;
BEGIN
lock_res := dbms_lock.request(
id => 123,
lockmode => 6, -- 排他锁
timeout => 300,
release_on_commit => false
);
IF lock_res <> 0 THEN
RAISE EXCEPTION 'Lock request failed: %', lock_res;
END IF;
END;
$$;
返回值：0=成功，1=超时，3=参数错误，4=已持有锁，5=非法句柄。
RELEASE
显式释放之前获取的锁：
DO $$
DECLARE
lock_res int;
BEGIN
lock_res := dbms_lock.release(id => 123);
IF lock_res <> 0 THEN
RAISE EXCEPTION 'Release failed: %', lock_res;
END IF;
END;
$$;
SLEEP
暂停会话指定时长：
CALL dbms_lock.sleep(0.70); -- 休眠 0.7 秒
完整示例
DO $$
DECLARE
lock_res int;
printer_lockhandle varchar;
BEGIN
CALL dbms_lock.allocate_unique('printer_lock', printer_lockhandle);
lock_res := dbms_lock.request(lockhandle => printer_lockhandle, lockmode => 6, timeout => 5);
IF lock_res <> 0 THEN
RAISE EXCEPTION 'REQUEST failed: %', lock_res;
END IF;
-- 在此执行排他操作
lock_res := dbms_lock.release(lockhandle => printer_lockhandle);
END;
$$;