Decode360's Blog

业精于勤而荒于嬉 QQ:150355677 MSN:decode360@hotmail.com

  BlogJava :: 首页 :: 新随笔 :: 联系 ::  :: 管理 ::
  397 随笔 :: 33 文章 :: 29 评论 :: 0 Trackbacks
创建自己的锁定
 
    对于锁定来说,尽管其概念比较复杂,但是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
    from v$lock
  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
    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,我们可以很方便地在自己的应用程序中实现串行化控制。
 
 
posted on 2009-03-14 22:42 decode360 阅读(152) 评论(0)  编辑  收藏 所属分类: 06.PLSQL

只有注册用户登录后才能发表评论。


网站导航: