捷凌网安Oracle频道
中国IT教育
首页 入门基础 安装配置 体系架构 PLSQL 备份恢复 性能调优 开发技术 资讯动态 考试认证 讨论
　您现在的位置： 捷凌网安 >> Oracle >> 开发技术 >> 正文
一种并发控制的精典案例

作者：佚名 责任编辑：左决 点击数： 更新时间：2008-4-30 5:20:26

并发控制一直是个比较头痛的问题，下文演示了一种并发案例，希望大家能从中有所收获。

SQL> create table t(id number,nick varchar2(32),status number,email varchar2(32),gmt_modified date);

Table created.

SQL> desc t;
 Name                                      Null?    Type
 ----------------------------------------- -------- ----------------------------
 ID                                                 NUMBER
 NICK                                               VARCHAR2(32)
 STATUS                                             NUMBER
 EMAIL                                              VARCHAR2(32)
 GMT_MODIFIED                                       DATE

SQL> begin  
  2      for i in 1..5 loop
  3           insert into t values(i,'test',0,'test@taobao.com',sysdate);
  4      end loop;
  5      commIT;
  6  end;
  7  /

PL/SQL procedure successfully completed.

SQL> alter session set nls_date_format='YYYY-MM-DD HH24:MI:SS';

Session altered.

SQL> select * from t;

ID NICK       STATUS EMAIL               GMT_MODIFIED
-- ------ ---------- ------------------- -------------------
 1 test            0 test@taobao.com     2008-04-09 13:28:27
 2 test            0 test@taobao.com     2008-04-09 13:28:27
 3 test            0 test@taobao.com     2008-04-09 13:28:27
 4 test            0 test@taobao.com     2008-04-09 13:28:27
 5 test            0 test@taobao.com     2008-04-09 13:28:27
        
--session 1执行,但不提交        
SQL> update t set status=1,gmt_modified=sysdate where id in (
  2                                         select id from (select id from t where nick='test' and status=0 order by id asc)
  3                                                          where rownum < 2)
                                           and status=0;

1 row updated.

SQL> select * from t;

ID NICK       STATUS EMAIL                GMT_MODIFIED
-- ------ ---------- -------------------- -------------------
 1 test            1 test@taobao.com      2008-04-09 13:36:31
 2 test            0 test@taobao.com      2008-04-09 13:28:27
 3 test            0 test@taobao.com      2008-04-09 13:28:27
 4 test            0 test@taobao.com      2008-04-09 13:28:27
 5 test            0 test@taobao.com      2008-04-09 13:28:27

--session 2也执行这样的语句,出现等待。
SQL> update t set status=1,gmt_modified=sysdate where id in (
  2                                         select id from (select id from t where nick='test' and status=0 order by id asc)
  3                                                          where rownum < 2)
                                                and status=0;

--session 1提交
commIT;

--session 2执行完成，查看结果
SQL> select * from t;

 ID NICK      STATUS EMAIL               GMT_MODIFIED
--- ----- ---------- ------------------- -------------------
  1 test           1 test@taobao.com     2008-04-09 13:48:30  --session 1更新了这条
  2 test           1 test@taobao.com     2008-04-09 13:48:37  --session 2更新了这条
  3 test           0 test@taobao.com     2008-04-09 13:28:27
  4 test           0 test@taobao.com     2008-04-09 13:28:27
  5 test           0 test@taobao.com     2008-04-09 13:28:27

　　上面运行的更新语句

update t set status=1,gmt_modified=sysdate where id in (                                                              
                                       select id from (select id from t where nick='test' and status=0 order by id asc)
                                                        where rownum < 2)                                             
                                           and status=0;  --注意此条件

　　当session 1执行，但并不提交后，session 2执行相同的语句，由于update语句中有select子查询，众所周知，select要进行一致性读，即也会读取到记录1,但这又是一个update语句，会进行当前读，session 2也想去更新这一行，但发现这一行已被另外一个事务更新，所以出现等待。但当session 1提交后，通过以上实验，证明session 2会再次触发一致性读与当前读，去更新了满足条件的第二行,而不是第一行。

　　大家还可以做其它实验，比如说session 1执行如下的语句：

update t set status=1,gmt_modified=sysdate where id in (                                                              
                                       select id from (select id from t where nick='test' and status=0 order by id asc)
                                                        where rownum < 2)                                             
                                           and status=0;  --注意此条件

　　session 2执行如下的语句：

update t set status=1,gmt_modified=sysdate where id in (                                                              
                                       select id from (select id from t where nick='test' and status=0 order by id asc)
                                                        where rownum < 4)                                             
                                           and status=0;  --注意此条件

　　结果是sesion 1更新了1条;session 2更新了2条,而session 2实际想更新3条。

　　本篇实验也提供了一个很好处理并发的方法,使用此方法，可以保证多个更新在并发时不会更新同一行，不过要在更新后，加一个判断，如果实际更新的条数 != 想要更新的条数(即sql语句中的rownum),那就说明出现了并发，并且剩余的满足条件的记录数不满足应用要求，这时候就需要在应用层加上进一步的并发处理了。我们在实际中出现的一个案例，恰好就是没有对实际更新的条目进行判断，导致出现了应用层数据逻辑错误。
  • 上一篇文章：

  • 下一篇文章：
    •  
     最进更新
    普通文章如何获得Oracle DBA工作？05-11
    普通文章分别删除数据表记录的方法05-11
    普通文章实例讲解删除表空间时存在的05-11
    普通文章Oracle Wait Event:Data fil05-11
    普通文章重复利用这个外部表的表结构05-11
    普通文章Oracle 9i数据库的用户创建以05-11
    普通文章Oracle数据库应用程序中RAID05-11
    普通文章如何更改监听器设置05-11
    普通文章Oracle中SQL语句执行效率的查05-11
    普通文章掌握数据库链路的建立和使用05-11
     
     推荐文章
    推荐文章研究人员发现攻击Oracle数据04-30
    推荐文章研究人员找到新方法黑掉Orac04-30
    推荐文章数据库产业商业模式大猜想04-30
    推荐文章一种并发控制的精典案例04-30
    推荐文章讲解Oracle在Solaris下的性能04-30
    推荐文章Oracle中为什么会产生回滚与04-30
    推荐文章实例讲解sql_trace和access 04-30
    推荐文章Oracle数据库9i和10g环境下使04-30
    推荐文章Oracle数据库后台进程的具体04-30
    推荐文章Oracle数据库中Undo数据段的04-30
     
     热点文章
    普通文章PB内置Oracle数据库接口的使03-27
    普通文章用最简单的方法记录Oracle语03-27
    推荐文章教你快速掌握Oracle数据库的03-27
    推荐文章详细讲解"Oracle"数据库的“03-27
    普通文章深入讲解Oracle数据库的多栏03-27
    推荐文章教你快速掌握一个简单的Orac03-27
    推荐文章初学者应该如何理解Oracle的03-27
    普通文章怎样将"Oracle"的外部表汉字03-27
    推荐文章解决不同字符集数据库间的数03-27
    普通文章Oracle的window服务启动时并03-27

    | 设为首页 | 加入收藏 | 联系站长 | 广告服务 | 友情链接 | 版权申明 | 网站地图 |

    在线交流 捷凌网安主群:51649627
    Copyright 2007-2008 © 捷凌网安. All rights reserved.
    备案序号:蜀ICP备08001812号