创建自己的锁定
对于锁定来说,尽管其概念比较复杂,但是Oracle将这些复杂性都屏蔽在Oracle的内核中。Oracle会自动完成锁的管理,通常并不需要我们对锁定进行很多的管理工作。不仅如此,Oracle还提供了相关的工具包:dbms_lock,使得我们可以创建自己的锁定。
通过dbms_lock,我们可以控制对某个设备(比如打印机)的串行访问,或者控制对某个文件的串行写入等。比如通过我们自己的应用程序打印数据时,要求在任意的时间点上,只能有一个用户使用打印机。在具体实现时,我们可以创建一个打印机控制表。发出打印命令之前,先到该表里查询打印标记,如果已经被设置为已打印,则说明其他用户已经开始打印了,必须等待。如果打印标记还没有被设置,则将打印标记更新为已打印,然后打印。在实现过程中,还要考虑多个用户进程同时要求打印机时,所使用的排队机制(通常都是先进先出)。通过这种借助表的方式,我们可以实现对打印机的串行访问。不过,这种方式要执行SQL语句读写数据文件,相对性能较差。我们还可以有另一个选择,就是调用dbms_lock创建自己的打印机锁定。在打印前,获得该打印机锁定,打印以后释放锁定。在打印过程中,其他要获得打印机的用户进程进入队列等待,并按照先进先出的方式管理该队列。
我们以上面描述的打印机为例,来说明如何使用dbms_lock包。
分配打印机锁定
使用dbms_lock.allocate_unique存储过程分配一个自定义的锁定。如下所示:
SQL> create or replace function get_lockhandle return varchar2
2 is
3 printer_lockname VARCHAR2(128) := 'printer_lock';
4 printer_handle VARCHAR2(128);
5 begin
6 if printer_handle is null then
7 dbms_lock.allocate_unique
8 (lockname => printer_lockname,
9 lockhandle => printer_handle);
10 end if;
11 return printer_handle;
12 end;
13 /
SQL> grant execute on get_lockhandle to public;
我们在这里创建了一个函数,该函数中创建了一个名为printer_lock的函数。在调用dbms_lock. allocate_unique过程时,会返回该锁定的句柄(lockhandle)。
请求锁定
我们创建一个用于申请锁定的存储过程,如下所示:
SQL> create or replace procedure lock_printer
2 (p_return_code out integer)
3 is
4 v_temp_lockhandle varchar2(128);
5 v_call_status integer;
6 begin
7 v_temp_lockhandle := get_lockhandle;
8 v_call_status := dbms_lock.request
9 (lockhandle => v_temp_lockhandle,
10 lockmode => dbms_lock.x_mode,
11 timeout => 5,
12 release_on_commit => true);
13 p_return_code := v_call_status;
14 end lock_printer;
15 /
SQL> grant execute on lock_printer to public;
在该存储过程中,我们调用dbms_lock.request来申请打印机锁定。在调用时,参数lockhandle为打印机锁定的句柄;timeout表示请求锁定时,如果5秒内不能获得,则放弃获得,而进入等待;release_on_commit表示发出commit或rollback命令时是否释放锁定。true为是,false为否;lockmode为打印模式,可选值如下表所示。
锁定模式
|
描 述
|
对应到TM锁中的模式
|
nl_mode
|
null锁定模式
|
Null
|
ss_mode
|
subshared锁定模式
|
RS
|
sx_mode
|
subexclusive锁定模式
|
RX
|
s_mode
|
shared锁定模式
|
S
|
ssx_mode
|
subshared exclusive锁定模式
|
RSX
|
x_mode
|
exclusive锁定模式
|
X
|
调用dbms_lock.request函数以后的返回值包括:
返回值
|
含义
|
0
|
申请锁定成功
|
1
|
申请锁定时超时
|
2
|
申请锁定时发生死锁
|
3
|
传入参数错误
|
4
|
已经获得了锁定,重复申请了锁
|
5
|
传入的锁定句柄错误
|
释放锁定
我们创建如下的存储过程来释放打印机锁定,其中调用了dbms_lock.release存储过程。
SQL> create or replace procedure release_printer
2 (p_return_code out integer)
3 is
4 v_temp_lockhandle varchar2(128);
5 v_call_status integer;
6 begin
7 v_temp_lockhandle := get_lockhandle;
8 v_call_status := dbms_lock.release
9 (lockhandle => v_temp_lockhandle);
10 p_return_code := v_call_status;
11 end release_printer;
12 /
SQL> grant execute on release_printer to public;
调用dbms_lock.release函数以后的返回值包括:
返回值
|
含义
|
0
|
释放锁定成功
|
3
|
传入参数错误
|
4
|
并没有获得要释放的锁定
|
5
|
传入的锁定句柄错误
|
在创建了所有需要的存储过程以后,我们来调用它们。打印前,执行下面的语句:
SQL> select sid from v$mystat where rownum=1;
SID
----------
158
SQL> var v_out number
SQL> exec sys.lock_printer(:v_out);
SQL> print v_out
V_OUT
----------
0
申请锁定以后,传出参数的值为0,说明申请锁定成功。然后我们检查v$lock视图:
SQL> select sid,type,id1,id2,decode(lmode,0,'None',1,'Null',2,'Row share',
2 3,'Row Exclusive',4,'Share',5,'Share Row Exclusive',6,'Exclusive')lock_mode,
3 decode(request,0,'None',1,'Null',2,'Row share',
4 3,'Row Exclusive',4,'Share',5,'Share Row Exclusive',6,'Exclusive')request_ mode,block
5 from v$lock
6 where sid=158;
SID TYPE ID1 ID2 LOCK_MODE REQUEST_MODE BLOCK
---- ----- ----------- --------- -------------- ------------- -------
158 UL 1073742164 0 Exclusive None 0
可以看到,获得的锁定类型为UL,表示用户自定义的锁定(User Lock)。只要是我们通过dbms_lock申请的锁定,其type列都为UL;ID1表示锁定的句柄;锁定模式为排他锁。根据ID1我们可以到dbms_lock_allocation视图(该视图显示了已经分配的用户自定义的锁定信息)中找到该锁定。
SQL> select * from dbms_lock_allocated where lockid=1073742164;
NAME LOCKID EXPIRATION
------------- ---------------- -------------------
printer_lock 1073742164 2007-12-25 04:53:53
然后我们再启动一个session,并再次申请相同的打印机锁定。
SQL> select sid from v$mystat where rownum=1;
SID
----------
159
SQL> var v_out number
SQL> exec sys.lock_printer(:v_out);
在执行lock_printer存储过程时,会明显感到延迟(其延迟时间长度就是我们前面在调用dbms_lock.request时指定的timeout参数,这里就是5秒钟)。在延迟过程中,我们查询v$lock视图,会发现下面的信息:
SQL> select sid,type,id1,id2,decode(lmode,0,'None',1,'Null',2,'Row share',
2 3,'Row Exclusive',4,'Share',5,'Share Row Exclusive',6,'Exclusive') lock_mode,
3 decode(request,0,'None',1,'Null',2,'Row share',
4 3,'Row Exclusive',4,'Share',5,'Share Row Exclusive',6,'Exclusive') request_ mode,block
5 from v$lock6 where sid=158;
SID TYPE ID1 ID2LOCK_MODE REQUEST_MODE BLOCK
---- ----- ----------- ------- -------------- ------------- -------
158 UL 1073742164 0 Exclusive None 1
159 UL 1073742164 0 None Exclusive 0
很明显,159号session在以Exclusive模式申请打印机锁定时,由于158号session已经持有该锁定,因此发生等待。等待5秒钟后,该存储过程执行完毕,我们显示v_out参数值:
SQL> print v_out
V_OUT
----------
1
返回值为1,说明申请锁定时发生超时,因为其他进程已经获得了该锁定。
从以上过程中,我们可以看到,通过使用dbms_lock,我们可以很方便地在自己的应用程序中实现串行化控制。