Oracle之DBMS_LOCK包用法详解

Posted 依然是等待

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了Oracle之DBMS_LOCK包用法详解相关的知识,希望对你有一定的参考价值。

概述与背景

 

某些并发程序,在高并发的情况下,必须控制好并发请求的运行时间和次序,来保证处理数据的正确性和完整性。对于并发请求的并发控制,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_LOCKProcedure

 

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$‘字符串开头,OracleProducts保留。如果lockname已分配LockID,则返回handle;否则,生成一个新的LockID,并返回handle

Lockhandle:返回值,requestconvertrelease调用。

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

参数:Lockhandleallocate_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

参数:Lockhandleallocate_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

参数:Lockhandleallocate_unique取得的handle

Lockmode:加锁模式。

Timeout:转换等待时间。

release_on_commitcommit或者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;

 

  • 技术分享
  • 大小: 41.9 KB
  • 技术分享
  • 大小: 35.7 KB




以上是关于Oracle之DBMS_LOCK包用法详解的主要内容,如果未能解决你的问题,请参考以下文章

Oracle 延时执行问题求指教:

ORACLE中dual用法详解

oracle merge into 用法详解

微信小程序第七天WXML语法之模板用法

微信小程序第七天WXML语法之模板用法

oracle中的exists 和not exists 用法详解