本文摘自PHP中文网,作者coldplay.xixi,侵删。
mysql乐观锁是相对悲观锁而言,乐观锁假设认为数据一般情况下不会造成冲突,所以在数据进行提交更新的时候,才会正式对数据的冲突与否进行检测,如果发现冲突了,则让返回用户错误的信息,让用户决定如何去做。

mysql乐观锁是( Optimistic Locking )相对悲观锁而言,乐观锁假设认为数据一般情况下不会造成冲突,所以在数据进行提交更新的时候,才会正式对数据的冲突与否进行检测,如果发现冲突了,则让返回用户错误的信息,让用户决定如何去做。
那么我们如何实现乐观锁呢,一般来说有以下2种方式:
1、使用数据版本(Version)记录机制实现,这是乐观锁最常用的一种实现 方式。何谓数据版本?即为数据增加一个版本标识,一般是通过为数据库表增加一个数字类型的 “version” 字段来实现。当读取数据时,将version字段的值一同读出,数据每更新一次,对此version值加一。
当我们提交更新的时候,判断数据库表对应记录 的当前版本信息与第一次取出来的version值进行比对,如果数据库表当前版本号与第一次取出来的version值相等,则予以更新,否则认为是过期数 据。用下面的一张图来说明:

如上图所示,如果更新操作顺序执行,则数据的版本(version)依次递增,不会产生冲突。但是如果发生有不同的业务操作对同一版本的数据进行修 改,那么,先提交的操作(图中B)会把数据version更新为2,当A在B之后提交更新时发现数据的version已经被修改了,那么A的更新操作会失败。
2、乐观锁定的第二种实现方式和第一种差不多,同样是在需要乐观锁控制的table中增加一个字段,名称无所谓,字段类型使用时间戳 (timestamp), 和上面的version类似,也是在更新提交的时候检查当前数据库中数据的时间戳和自己更新前取到的时间戳进行对比,如果一致则OK,否则就是版本冲突。
相关学习推荐:mysql视频教程
使用举例:
以MySQL InnoDB
为例
还是拿之前的实例来举:商品goods表中有一个字段status,status为1代表商品未被下单,status为2代表商品已经被下单,那么我们对某个商品下单时必须确保该商品status为1。假设商品的id为1。
下单操作包括3步骤:
1、查询出商品信息
1 | select (status,status,version) from t_goods where id=#{id}
|
2、根据商品信息生成订单
3、修改商品status为2
1 2 3 | update t_goods
set status=2,version=version+1
where id=#{id} and version=#{version};
|
那么为了使用乐观锁,我们首先修改t_goods表,增加一个version字段,数据默认version值为1。
t_goods
表初始数据如下:
1 2 3 4 5 6 7 8 9 10 | mysql> select * from t_goods;
+----+--------+------+---------+
| id | status | name | version |
+----+--------+------+---------+
| 1 | 1 | 道具 | 1 |
| 2 | 2 | 装备 | 2 |
+----+--------+------+---------+
2 rows in set
mysql>
|
对于乐观锁的实现,我使用MyBatis来进行实践,具体如下:
Goods实体类:
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 |
public class Goods implements Serializable {
private static final long serialVersionUID = 6803791908148880587L;
private int id;
private int status;
private String name;
private int version;
@Override
public String toString(){
return "good id:" +id+ ",goods status:" +status+ ",goods name:" +name+ ",goods version:" +version;
}
}
|
GoodsDao
1 2 3 4 5 6 7 8 |
int updateGoodsUseCAS(Goods goods);
|
mapper.xml
1 2 3 4 5 6 7 | <update id= "updateGoodsUseCAS" parameterType= "Goods" >
<![CDATA[
update t_goods
set status=#{status},name=#{name},version=version+1
where id=#{id} and version=#{version}
]]>
</update>
|
GoodsDaoTest测试类
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 | @Test
public void goodsDaoTest(){
int goodsId = 1;
Goods goods1 = this.goodsDao.getGoodsById(goodsId);
Goods goods2 = this.goodsDao.getGoodsById(goodsId);
System.out.println(goods1);
System.out.println(goods2);
goods1.setStatus(2);
int updateResult1 = this.goodsDao.updateGoodsUseCAS(goods1);
System.out.println( "修改商品信息1" +(updateResult1==1? "成功" : "失败" ));
goods1.setStatus(2);
int updateResult2 = this.goodsDao.updateGoodsUseCAS(goods1);
System.out.println( "修改商品信息2" +(updateResult2==1? "成功" : "失败" ));
}
|
输出结果:
1 2 3 4 | good id:1,goods status:1,goods name:道具,goods version:1
good id:1,goods status:1,goods name:道具,goods version:1
修改商品信息1成功
修改商品信息2失败
|
说明:
在GoodsDaoTest
测试方法中,我们同时查出同一个版本的数据,赋给不同的goods对象,然后先修改good1对象然后执行更新操作,执行成功。然后我们修改goods2,执行更新操作时提示操作失败。此时t_goods
表中数据如下:
1 2 3 4 5 6 7 8 9 10 | mysql> select * from t_goods;
+----+--------+------+---------+
| id | status | name | version |
+----+--------+------+---------+
| 1 | 2 | 道具 | 2 |
| 2 | 2 | 装备 | 2 |
+----+--------+------+---------+
2 rows in set
mysql>
|
我们可以看到 id为1的数据version已经在第一次更新时修改为2了。所以我们更新good2时update where条件已经不匹配了,所以更新不会成功,具体sql如下:
1 2 3 | update t_goods
set status=2,version=version+1
where id=#{id} and version=#{version};
|
这样我们就实现了乐观锁。
以上就是mysql乐观锁是什么?的详细内容,更多文章请关注木庄网络博客!
相关阅读 >>
mysql workbench怎么用
mysql如何创建存储过程
学习mysql事件如何调用存储过程的方法
mysql数据库使用node.js实现连接功能的示例
mysql 清除表空间碎片的实例详解
mysql详解如何优化查询条件
mysql索引以及查询优化的详细介绍
详解mysql从入门到放弃-安装
mysql的主键命名策略相关
gorm操作mysql的实现
更多相关阅读请进入《mysql》频道 >>
机械工业出版社
本书主要讲述了数据模型、基于对象的数据库和XML、数据存储和查询、事务管理、体系结构等方面的内容。
转载请注明出处:木庄网络博客 » mysql乐观锁是什么?