概述与背景
某些并发程序,在高并发的情况下,必须控制好并发请求的运行时间和次序,来保证处理数据的正确性和完整性。对于并发请求的并发控制,EBS系统可以通过Concurrent Program定义界面的Incompatibilities功能配置实现。但是Incompatibilities功能存在其局限性,它只能把整个并发请求作为一个整体来判断,并不能细化到并发请求的请求参数。而某些并发程序,只需要对其中某几个参数做并发控制,例如时间段,OU等。对于这种业务需求,可以使用标准包DBMS_LOCK,把需要做并发控制的参数,加上锁,实现并发控制。
DBMS_LOCK相关知识介绍
锁模式
名字 |
描述 |
数据类型 |
值 |
nl_mode |
Null |
INTEGER |
1 |
ss_mode |
Sub Shared: used on an aggregate object to indicate that share locks are being acquired on subparts of the object (对象的子部分,加上了Share锁) |
INTEGER |
2 |
sx_mode |
Sub Exclusive: used on an aggregate object to indicate that exclusive locks are being acquired on subparts of the object (对象的子部分,加上了Exclusive锁) |
INTEGER |
3 |
s_mode |
Shared: indicates that the entire aggregate object has a share lock, but some of the sub-parts may additionally have exclusive locks (对象加上了Share锁) |
INTEGER |
4 |
ssx_mode |
Shared SubExclusive (对象加上了Share锁,其子部分加上了Exclusive锁) |
INTEGER |
5 |
x_mode |
Exclusive (对象加上了Exclusive锁) |
INTEGER |
6 |
锁兼容性
|
NL |
SS |
SX |
S |
SSX |
X |
NL |
SUCC |
SUCC |
SUCC |
SUCC |
SUCC |
SUCC |
SS |
SUCC |
SUCC |
SUCC |
SUCC |
SUCC |
fail |
SX |
SUCC |
SUCC |
SUCC |
fail |
fail |
fail |
S |
SUCC |
SUCC |
fail |
SUCC |
fail |
fail |
SSX |
SUCC |
SUCC |
fail |
fail |
fail |
fail |
X |
SUCC |
fail |
fail |
fail |
fail |
fail |
DBMS_LOCK Procedure
1、ALLOCATE_UNIQUE
dbms_lock.request(lockhandle IN VARCHAR2, lockmode IN INTEGER DEFAULT x_mode, timeout IN INTEGER DEFAULT maxwait, release_on_commit IN BOOLEAN DEFAULT FALSE) RETURN INTEGER;
说明:锁模式转换。
类型:Procedure
参数:
lockname :产生唯一的LockID。大小不超过128B,大小写敏感。不能以'ORA$'字符串开头,Oracle Products保留。如果lockname已分配LockID,则返回handle;否则,生成一个新的LockID,并返回handle。
Lockhandle :返回值,request,convert,release调用。
expiration_secs:执行'allocate_unique'后,Clean Up的时间间隔。
2、 CONVERT
dbms_lock.convert(lockhandle IN VARCHAR2, lockmode IN INTEGER, timeout IN NUMBER DEFAULT maxwait) RETURN INTEGER;
说明:锁模式转换。
类型:Function
参数:Lockhandle:allocate_unique取得的handle。
Lockmode :转换的锁模式。
Timeout :转换等待时间。
返回值:
Return Values |
|
0 |
Success |
1 |
Timeout |
2 |
Deadlock |
3 |
Parameter error |
4 |
Don't own lock specified by id or lockhandle |
5 |
Illegal lock handle |
3、RELEASE
dbms_lock.release(lockhandle IN VARCHAR2) RETURN INTEGER;
说明:释放锁。
类型:Function
参数:Lockhandle:allocate_unique取得的handle。
返回值:
Return Values |
|
0 |
Success |
3 |
Parameter error |
4 |
Don't own lock specified by id or lockhandle |
5 |
Illegal lock handle |
4、REQUEST
dbms_lock.request(lockhandle IN VARCHAR2, lockmode IN INTEGER DEFAULT x_mode, timeout IN INTEGER DEFAULT maxwait, release_on_commit IN BOOLEAN DEFAULT FALSE) RETURN INTEGER;
说明:请求锁。
类型:Function
参数:Lockhandle :allocate_unique取得的handle。
Lockmode :加锁模式。
Timeout :转换等待时间。
release_on_commit:在commit或者rollback之后释放锁,默认False。
返回值:
Return Values |
|
0 |
Success |
1 |
Timeout |
2 |
Deadlock |
3 |
Parameter error |
4 |
Don't own lock specified by id or lockhandle |
5 |
Illegal lock handle |
5、SLEEP
dbms_lock.sleep(seconds IN NUMBER);
说明:Session睡眠。
类型:Procedure
参数:seconds:睡眠时间。
例子:
DECLARE -- lock l_lockname VARCHAR2(100); l_lockhandle VARCHAR2(200); l_lock_output NUMBER; l_locked BOOLEAN := FALSE; g_pkg_name VARCHAR2(240) := 'test_package'; g_org_id NUMBER := 125; BEGIN /* 定义按何种方式并发(此处为同一个OU不能同时执行) * lockname类似于定义一个唯一的名字,当并发程序执行时就会去判断是否这个唯一标识已经存在*/ l_lockname := g_pkg_name || '_' || g_org_id; --根据l_lockname获取唯一标识l_lockhandle dbms_lock.allocate_unique(lockname => l_lockname, lockhandle => l_lockhandle); /*用l_lockhandle这个唯一标识去给当前请求加锁 -- Return value: -- 0 - success -- 1 - timeout -- 2 - deadlock -- 3 - parameter error -- 4 - already own lock specified by 'id' or 'lockhandle' -- 5 - illegal lockhandle*/ l_lock_output := dbms_lock.request(l_lockhandle, 6, 60, FALSE); IF l_lock_output <> 0 THEN --Output lock failure message RAISE apps.fnd_api.g_exc_error; END IF; --此处添加请求的业务逻辑 --dbms_lock.sleep(seconds => 50); /*特别注意的是一定要将lockname释放掉 否则这个并发就永远别想再执行了*/ IF l_lock_output = 0 THEN l_lock_output := dbms_lock.release(l_lockhandle); END IF; EXCEPTION WHEN apps.fnd_api.g_exc_error THEN IF l_lock_output = 0 THEN l_lock_output := dbms_lock.release(l_lockhandle); END IF; WHEN OTHERS THEN IF l_lock_output = 0 THEN l_lock_output := dbms_lock.release(l_lockhandle); END IF; END;
相关推荐
oracle dbms_lob
ORACLE数据库使用dbms_stats包手动收集关于表的、索引的统计信息。
作用:DBMS_STATS.GATHER_TABLE_STATS统计表,列,索引的统计信息. DBMS_STATS.GATHER_TABLE_STATS的语法如下: DBMS_STATS.GATHER_TABLE_STATS ( ownname VARCHAR2, tabname VARCHAR2, partname VARCHAR2, estimate_...
NULL 博文链接:https://wushuangyan26.iteye.com/blog/1307514
ORA-04063: package body SYS.DBMS_REGISTRY_SYS has errors
dbms_obfuscation_toolkit加密解密数据
Oracle DOM编程 文档,有要的没 Start from toc.htm DBMS_XMLDOM DBMS_XMLPARSER DBMS_XMLQUERY
DBMS_XPLAN是Oracle提供的一个用于查看SQL计划,包括执行计划和解释计划的包;在以前查看SQL执行计划的时候,我都是使用set autotrace命令,不过现在看来,DBMS_XPLAN包给出了更加简化的获取和显示计划的方式。 这5...
给大家详细介绍了dbms_job的用法,用于安排和管理作业队列,通过使用作业,可以使ORACLE数据库定期执行特定的任务。有需要的朋友们可以参考借鉴。
DBMS_RANDOM是Oracle提供的一个PL/SQL包,用于生成随机数据和字符。它具有以下函数。 其中,initialize,random,terminate函数在Oracle11g中已不推荐使用,主要用于向后兼容。下面对各个函数进行举例说明 1. ...
详细介绍DBMS_JOB包的各函数操作,以及各函数对job的使用作用等。
以下是对Oracle中dbms_metadata.get_ddl的用法进行了详细的分析介绍,需要的朋友参考下
Oracle实用工具RMAN的应用为DBA管理多个Oracle数据库提供了集中备份管理与恢复控制的机制,大大地减轻了DBA的工作压力,而DBMS_JOB包的使用增强了存储过程的应用功能,这样,他们就可以从备份数据及重复处理数据的...
主要介绍了ORACLE随机数DBMS_RANDOM包,通过dbms_random包调用随机数的方法大致有4种,具体哪4种请看本篇文章吧
oracle中DBMS_SQL的使用,详细讲解oracle DBMS_SQL的使用办法
DBMS JOB包创建ORACLE定时任务
用Oracle的DBMS_JOB来实现任务计划管理.pdf
通过此版本可以把oracle时区版本调整到为最新版本,一般配合时区补丁使用 可以参考https://blog.csdn.net/weixin_43885834/article/details/105745901 https://download.csdn.net/download/weixin_43885834/12360971...