👉 这是一个或许对你有用的社群
🐱 一对一交流/面试小册/简历优化/求职解惑,欢迎加入芋道快速开发平台知识星球。下面是星球提供的部分资料:
👉这是一个或许对你有用的开源项目
国产 Star 破 10w+ 的开源项目,前端包括管理后台 + 微信小程序,后端支持单体和微服务架构。
功能涵盖 RBAC 权限、SaaS 多租户、数据权限、商城、支付、工作流、大屏报表、微信公众号等等功能:
  • Boot 地址:https://gitee.com/zhijiantianya/ruoyi-vue-pro
  • Cloud 地址:https://gitee.com/zhijiantianya/yudao-cloud
  • 视频教程:https://doc.iocoder.cn

前言

前几天一个小伙伴问了我一个问题:在MySQL中,事务A中使用select...for update where id=1锁住了,某一条数据,事务还没提交,此时,事务B中去用select ... where id=1查询那条数据,会阻塞等待吗?
select...for update在MySQL中,是一种悲观锁的用法,一般情况下,会锁住一行数据,但如果没有使用正确的话,也会把整张表锁住。
其实,我之前也在实际项目中试过用,比如:积分兑换礼品的功能。
今天跟大家一起聊聊select...for update这个话题,希望对你会有所帮助。
基于 Spring Boot + MyBatis Plus + Vue & Element 实现的后台管理系统 + 用户小程序,支持 RBAC 动态权限、多租户、数据权限、工作流、三方登录、支付、短信、商城等功能
  • 项目地址:https://github.com/YunaiV/ruoyi-vue-pro
  • 视频教程:https://doc.iocoder.cn/video/

1. 为什么要用行锁?

假如现在有这样一种业务场景:用户A给你转账了2000元,用户B给你转账了3000元,而你的账户初始化金额是1000元。
在事务1中会执行下面这条sql:
update account set money=money+
2000
where id=
123
;

在事务2中执行下面这条sql:
update account set money=money+
3000
where id=
123
;

这两条sql执行成功之后,你的money可能是:3000、4000、6000,这三种情况中的一种。
你之前的想法是,用户A和用户B总共给你转账5000,最终你账户的钱应该是6000才对,3000和4000是怎么来的?
假如事务1在执行update语句的过程中,事务2同时也在执行update语句。
事务1中查询到money是1000,此外事务2也查询到money是1000。
如果事务1先执行update语句,事务2后执行update语句,第一次update的3000,会被后面的4000覆盖掉,最终结果为4000。
如果事务2先执行update语句,事务1后执行update语句,第一次update的4000,会被后面的3000覆盖掉,最终结果为3000。
这两种情况都产生了严重的数据问题。
我们需要有某种机制,保证事务1和事务2要顺序执行,不要一起执行。
这就需要加锁了。
目前MySQL中使用比较多的有:表锁、行锁和间隙锁。
我们这个业务场景,非常时候使用行锁
在事务1执行update语句的过程中,先要把某一行数据锁住,此时,其他的事务必须等待事务1执行完,提交了事务,才能获取那一行的数据。
在MySQL中是通过select...for update语句来实现的行锁的功能。
但如果你在实际工作中使用不正确,也容易把整张表锁住,严重影响性能。
select...where...for update语句的用法是否正确,跟where条件中的参数有很大的关系。
我们一起看看下面几种情况。
假如user表现在有这样的数据库,数据库的版本是:8.0.21,数据库的隔离级别是:REPEATABLE-READ。
创建的索引如下:
其中id是主键字段,code是唯一索引字段,name是普通索引字段,其他的都是普通字段。
基于 Spring Cloud Alibaba + Gateway + Nacos + RocketMQ + Vue & Element 实现的后台管理系统 + 用户小程序,支持 RBAC 动态权限、多租户、数据权限、工作流、三方登录、支付、短信、商城等功能
  • 项目地址:https://github.com/YunaiV/yudao-cloud
  • 视频教程:https://doc.iocoder.cn/video/

2. 主键

当where条件用的数据库主键时。
例如开启一个事务1,在事务中更新id=1的用户的年龄:
begin;

select * from user where id=
1for
 update;

update user set age=
22
 where id=
1
;

where条件中的id是数据库的主键,并且使用for update关键字,加了一个行锁,这个事务没有commit。
此时,开启了另外一个事务2,也更新id=1的用户的年龄:
begin;

update user set age=
23
 where id=
1
;

commit;

在执行事务2的sql语句的过程中,会一直等待事务1释放锁。
如果事务1一直都不释放行锁,事务2最后会报下面这个异常:
如果此时开始一个事务3,更新id=2的用户的年龄:
begin;

update user set age=
23
 where id=
2
;

commit;

执行结果如下:
由于事务3中更新的另外一行数据,因此可以执行成功。
说明使用for update关键字,锁住了主键id=1的那一行数据,对其他行的数据并没有影响。

3. 唯一索引

当where条件用的数据库唯一索引时。
开启一个事务1,在事务中更新code=101的用户的年龄:
begin;

select * from user where code=
'101'for
 update;

update user set age=
22
 where code=
'101'
;

where条件中的code是数据库的唯一索引,并且使用for update关键字,加了一个行锁,这个事务没有commit。
此时,开启了另外一个事务2,也更新code=101的用户的年龄:
begin;

update user set age=
23
 where code=
'101'
;

commit;

执行结果跟主键的情况是一样的。

4. 普通索引

当where条件用的数据库普通索引时。
开启一个事务1,在事务中更新name=周星驰的用户的年龄:
begin;

select * from user where name=
'周星驰'for
 update;

update user set age=
22
 where name=
'周星驰'
;

where条件中的name是数据库的普通索引,并且使用for update关键字,加了一个行锁,这个事务没有commit。
此时,开启了另外一个事务2,也更新name=周星驰的用户的年龄:
begin;

update user set age=
23
 where name=
'周星驰'
;

commit;

执行结果跟主键的情况也是一样的。

5. 主键范围

当where条件用的数据库主键范围时。
开启一个事务1,在事务中更新id in (1,2)的用户的年龄:
begin;

select * 
from user where id in(1,2)for update
;

update user set age=
22where id in(1,2)
;

where条件中的id是数据库的主键范围,并且使用for update关键字,加了多个行锁,这个事务没有commit。
此时,开启了另外一个事务2,也更新id=1的用户的年龄:
begin;

update user set age=
23
 where id=
1
;

commit;

执行结果跟主键的情况也是一样的。
此时,开启了另外一个事务2,也更新id=2的用户的年龄:
begin;

update user set age=
23
 where id=
2
;

commit;

执行结果跟主键的情况也是一样的。

6. 普通字段

当where条件用的数据库普通字段时。
该字段既不是主键,也不是索引。
开启一个事务1,在事务中更新age=22的用户的年龄:
begin;

select * from user where age=
22for
 update;

update user set age=
22
 where age=
22
 ;

where条件中的age是数据库的普通字段,并且使用for update关键字,加的是表锁,这个事务没有commit。
此时,开启了另外一个事务2,也更新age=22的用户的年龄:
begin;

update user set age=
23
 where age=
22
 ;

commit;

此时,执行事务2时,会一直阻塞等待事务1释放锁。
调整一下sql条件,查询条件改成age=23:
begin;

update user set age=
23
 where age=
23
 ;

commit;

此时,行事务3时,也会一直阻塞等待事务1释放锁。
也就是说,在for update语句中,使用普通字段作为查询条件时,加的是表锁,而并非行锁。

7. 空数据

当where条件查询的数据不存在时,会发生什么呢?
开启一个事务1,在事务中更新id=66的用户的年龄:
begin;

select * from user where id=
66for
 update;

update user set age=
22
 where id=
66
 ;

这条数据是不存在的。
此时,开启了另外一个事务2,也更新id=66的用户的年龄:
begin;

update user set age=
23
 where id=
66
 ;

commit;

执行结果:
执行成功了,说明这种情况没有加锁。

总结

最后给大家总结一下select...for update加锁的情况:
  1. 主键字段:加行锁。
  2. 唯一索引字段:加行锁。
  3. 普通索引字段:加行锁。
  4. 主键范围:加多个行锁。
  5. 普通字段:加表锁。
  6. 查询空数据:不加锁。
如果事务1加了行锁,一直没有释放锁,事务2操作相同行的数据时,会一直等待直到超时。
如果事务1加了表锁,一直没有释放锁,事务2不管操作的是哪一行数据,都会一直等待直到超时。

欢迎加入我的知识星球,全面提升技术能力。
👉 加入方式,长按”或“扫描”下方二维码噢
星球的内容包括:项目实战、面试招聘、源码解析、学习路线。
文章有帮助的话,在看,转发吧。
谢谢支持哟 (*^__^*)
继续阅读
阅读原文