mysql乐观锁总结和实践

那么为了使用乐观锁，我们首先修改t_goods表，增加一个version字段，数据默认version值为1。

t_goods表初始数据如下：

  

1. mysql> select * from t_goods;  
2. +----+--------+------+---------+  
3. | id | status | name | version |  
4. +----+--------+------+---------+  
5. |  1 |      1 | 道具 |       1 |  
6. |  2 |      2 | 装备 |       2 |  
7. +----+--------+------+---------+  
8. 2 rows in set  
9.   
10. mysql>  

对于乐观锁的实现，我使用MyBatis来进行实践，具体如下：

Goods实体类：

  

1. /** 
2.  * ClassName: Goods <br/> 
3.  * Function: 商品实体. <br/> 
4.  * date: 2013-5-8 上午09:16:19 <br/> 
5.  * @author chenzhou1025@126.com 
6.  */  
7. public class Goods implements Serializable {  
8.   
9.     /** 
10.      * serialVersionUID:序列化ID. 
11.      */  
12.     private static final long serialVersionUID = 6803791908148880587L;  
13.       
14.     /** 
15.      * id:主键id. 
16.      */  
17.     private int id;  
18.       
19.     /** 
20.      * status:商品状态：1未下单、2已下单. 
21.      */  
22.     private int status;  
23.       
24.     /** 
25.      * name:商品名称. 
26.      */  
27.     private String name;  
28.       
29.     /** 
30.      * version:商品数据版本号. 
31.      */  
32.     private int version;  
33.       
34.     @Override  
35.     public String toString(){  
36.         return "good id:"+id+",goods status:"+status+",goods name:"+name+",goods version:"+version;  
37.     }  
38.   
39.     //setter and getter  
40.   
41. }  

GoodsDao

  

1. /** 
2.  * updateGoodsUseCAS:使用CAS(Compare and set)更新商品信息. <br/> 
3.  * 
4.  * @author chenzhou1025@126.com 
5.  * @param goods 商品对象 
6.  * @return 影响的行数 
7.  */  
8. int updateGoodsUseCAS(Goods goods);  

mapper.xml

  

1. <update id="updateGoodsUseCAS" parameterType="Goods">  
2.     <![CDATA[ 
3.         update t_goods 
4.         set status=#{status},name=#{name},version=version+1 
5.         where id=#{id} and version=#{version} 
6.     ]]>  
7. </update>  

GoodsDaoTest测试类

  

1. @Test  
2. public void goodsDaoTest(){  
3.     int goodsId = 1;  
4.     //根据相同的id查询出商品信息，赋给2个对象  
5.     Goods goods1 = this.goodsDao.getGoodsById(goodsId);  
6.     Goods goods2 = this.goodsDao.getGoodsById(goodsId);  
7.       
8.     //打印当前商品信息  
9.     System.out.println(goods1);  
10.     System.out.println(goods2);  
11.       
12.     //更新商品信息1  
13.     goods1.setStatus(2);//修改status为2  
14.     int updateResult1 = this.goodsDao.updateGoodsUseCAS(goods1);  
15.     System.out.println("修改商品信息1"+(updateResult1==1?"成功":"失败"));  
16.       
17.     //更新商品信息2  
18.     goods1.setStatus(2);//修改status为2  
19.     int updateResult2 = this.goodsDao.updateGoodsUseCAS(goods1);  
20.     System.out.println("修改商品信息2"+(updateResult2==1?"成功":"失败"));  
21. }  

输出结果：

  

1. good id:1,goods status:1,goods name:道具,goods version:1  
2. good id:1,goods status:1,goods name:道具,goods version:1  
3. 修改商品信息1成功  
4. 修改商品信息2失败  

说明：

在GoodsDaoTest测试方法中，我们同时查出同一个版本的数据，赋给不同的goods对象，然后先修改good1对象然后执行更新操作，执行成功。然后我们修改goods2，执行更新操作时提示操作失败。此时t_goods表中数据如下：

  

1. mysql> select * from t_goods;  
2. +----+--------+------+---------+  
3. | id | status | name | version |  
4. +----+--------+------+---------+  
5. |  1 |      2 | 道具 |       2 |  
6. |  2 |      2 | 装备 |       2 |  
7. +----+--------+------+---------+  
8. 2 rows in set  
9.   
10. mysql>   

我们可以看到 id为1的数据version已经在第一次更新时修改为2了。所以我们更新good2时update where条件已经不匹配了，所以更新不会成功，具体sql如下：

  

1. update t_goods   
2. set status=2,version=version+1  
3. where id=#{id} and version=#{version};  

这样我们就实现了乐观锁

mysql乐观锁总结和实践

标签：