Oracle存储过程中如何正确使用行锁


  本文标签:Oracle存储过程

  以下的文章主要是讲述Oracle存储过程中如何正确的使用行锁的实际示例,如果一张入库单表中的相关字段status用来记录相关的入库状态,入库前我们要先判断其入库的标识  。如果没有入库的话,我们则做入库的相关处理  。

  否则则做另一个操作,问题来了,当两个人同时做入库处理时,取得的状态都为未入库,于是,你可以想到,发生了两次入库操作  。在并发问题中,一不小心就可能出现一些不易发现的错误  。这里可以通过一个Oracle存储过程中使用行锁来解决这个问题,通过锁,使该存储过程不能同时被两个线程调用来处理同一条记录  。

  

  1. create or replace procedure P1(pdm in varchar2) is  
  2. var_flag char(1);  
  3. begin  
  4. select status into var_flag from #T where dm=pdm for update wait 5;  

  

  开始事务

  执行业务逻辑

  修改入库标志

  提交事务

  若出异常,回滚

  

  1. end P1; 

  注意:记录被锁定之后不可以在该记录上做操作  。

  SELECT...FOR UPDATE 语句的语法如下:

  

  1. SELECT ... FOR UPDATE [OF column_list][WAIT n|NOWAIT][SKIP LOCKED]; 

  其中:

  OF 子句用于指定即将更新的列,即锁定行上的特定列  。

  WAIT 子句指定等待其他用户释放锁的秒数,防止无限期的等待  。

  “使用FOR UPDATE WAIT”子句的优点如下:

  1防止无限期地等待被锁定的行;

  2允许应用程序中对Oracle存储过程中使用行锁的等待时间进行更多的控制  。

  3对于交互式应用程序非常有用,因为这些用户不能等待不确定

  4 若使用了skip locked,则可以越过锁定的行,不会报告由wait n 引发的‘资源忙’异常报告

  示例:

  

  1. create table t(a varchar2(20),b varchar2(20));  
  2. insert into t values(1,1);  
  3. insert into t values(2,2);  
  4. insert into t values(3,3);  
  5. insert into t values(4,4);  

  

  现在执行如下操作:

  在plsql develope中打开两个sql窗口,

  在1窗口中运行sql

  

  1. select * from t where a=1 for update; 

  在2窗口中运行sql1q

  1.

  1. select * from t where a=1

  这一点问题也没有,因为行级锁不会影响纯粹的select语句

  再运行sql2

  2.

  1. select * from t where a=1 for update;  

  则这一句sql在执行时,永远处于等待状态,除非窗口1中sql被提交或回滚  。

  如何才能让sql2不等待或等待指定的时间呢? 我们再运行sql3

  3.

  1. select * from t where a=1 for update nowait;  

  则在执行此sql时,直接报资源忙的异常  。

  若执行

  1. select * from t where a=1 for update wait 6;  

  则在等待6秒后,报 资源忙的异常  。

  如果我们执行sql4

  4.

  1. select * from t where a=1 for update nowait skip Locked;  

  则执行sql时,即不等待,也不报资源忙异常  。

  现在我们看看执行如下操作将会发生什么呢?

  在窗口1中执行:

  

  1. select * from t where rownum<=3 nowait skip Locked; 

  在窗口2中执行:

  

  1. select * from t where rownum<=6 nowait skip Locked; 

  select for update 也就如此了吧,insert、update、delete操作默认加行级锁,其原理和操作与select for update并无两样  。

  select for update of,这个of子句在牵连到多个表时,具有较大作用,如不使用of指定锁定的表的列,则所有表的相关行均被锁定,若在of中指定了需修改的列,则只有与这些列相关的表的行才会被Oracle存储过程中使用行锁定  。