镁伽科技黄瑜清:智能自动化给生命科学带来巨大变革
06-18
大家好,我是苏三,又和大家见面了。前言 前几天,知识星球的朋友问了我一个问题:在MySQL中,事务A中使用select...for update where id=1被锁定,某条数据还没有提交。
这时候如果在事务B中使用select...where id=1来查询那条数据,会不会阻塞等待呢? Select...for update 是 MySQL 中悲观锁的一种用法。一般情况下,一行数据会被锁定,但如果使用不正确,整个表也会被锁定。
其实我之前在实际项目中也尝试过,比如积分兑换礼物的功能。今天我就和大家聊聊select...for update的话题。
希望对您有所帮助。 1、为什么要使用行锁?假设有这样一个业务场景:用户A给你转账人民币,用户B给你转账人民币,你的账户初始化金额为人民币。
在事务1中,将执行以下sql: 代码语言:javascript copy update account set Money=money0 where id=;事务2中会执行如下sql: 代码语言:javascript copy update account set Money=money0 where id= ;这两条SQL执行成功后,你的钱可能会是:,,,这三种情况之一。你之前的想法是用户A和用户B总共给你转账了。
最后,您帐户中的金额应该是正确的。这笔钱是怎么来的?如果事务1正在执行update语句,则事务2也同时执行update语句。
交易1中找到了钱,交易2中也找到了钱。如果交易1先执行更新语句,交易2稍后执行更新语句,则第一次更新将被后续更新覆盖,最终结果为。
如果事务2先执行更新语句,事务1稍后执行更新语句,则第一次更新会被后续更新覆盖,最终结果为。这两种情况都会造成严重的数据问题。
我们需要某种机制来确保事务 1 和事务 2 顺序执行而不是一起执行。这需要锁定。
目前MySQL中最常用的锁有:表锁、行锁和间隙锁。在我们的业务场景中,经常会用到行锁。
事务1执行update语句的过程中,必须先锁定某行数据。此时其他事务必须等待事务1执行完毕并提交事务后才能获取该行的数据。
在MySQL中,行锁功能是通过select...for update语句实现的。但如果在实际工作中使用不当,很容易锁住整个表,严重影响性能。
select...where...for update语句的用法是否正确与where条件中的参数有很大关系。我们来看看以下几种情况。
如果用户表现在有这样一个数据库,数据库版本为:8.0.21,数据库隔离级别为:REPEATABLE-READ。创建的索引如下:id为主键字段,code为唯一索引字段,name为普通索引字段,其他为普通字段。
2.主键 当数据库主键用于where条件时。例如,启动事务1,并在事务中更新id=1的用户的年龄: 代码语言:javascript copy begin; select * from user where id=1 进行更新;更新用户集年龄=22,其中id=1; in where条件id为数据库主键,使用for update关键字添加行锁。
该事务未提交。此时又开启了另一个交易2,id=1的用户年龄也被更新: 代码语言:javascript copy begin;更新用户集年龄=23,其中id=1;犯罪;在执行事务2的sql语句过程中,会等待事务1释放锁。
如果事务1始终不释放行锁,事务2最终会报如下异常: 如果此时启动事务3,更新id=2的用户年龄: 代码语言: javascript copy begin; update user set Age=23 where id=2;commit;执行结果如下: 由于事务3又更新了一行数据,所以执行可以成功。由此可见,使用for update关键字锁定了主键id=1的行中的数据,对其他行中的数据没有影响。
3、唯一索引 当数据库唯一索引用在where条件中时。开启交易1,在交易中用code=更新用户的年龄:代码语言:javascript copy begin; select * from user where code='' 进行更新;更新用户集年龄=22,其中代码='';在where条件代码中是数据库的唯一索引,并使用for update关键字添加行锁。
该事务未提交。此时又启动了另一个事务2,code=的用户年龄也被更新:代码语言:javascript copy begin;更新用户集年龄=23,其中代码='';提交;执行结果与主键相同。
4.普通索引 当数据库普通索引用于where条件时。开启交易1,在交易中更新name=Stephen Chow用户的年龄: 代码语言:javascript copy begin; select * from user where name='Stephen Chow' 进行更新;更新用户集年龄=22,其中名称='Stephen Chow'; where条件中的名称是数据库的普通索引,for update关键字用于添加行锁。
该事务未提交。此时又开启了另一个交易2,name=Stephen Chow的用户年龄也被更新: 代码语言:javascript copy begin;更新用户集年龄=23,其中名称='Stephen Chow';犯罪;执行结果与主键相同。
的。 5、主键范围 当数据库主键范围用于where条件时。
开启交易1,并在交易中更新(1,2)中id为用户的年龄: 代码语言:javascript copy begin; select * from user where id in (1,2) 进行更新;更新用户集年龄=22,其中 id 在 (1,2) 中; where条件中的id是数据库的主键范围,for update关键字用于添加多个行锁。该事务未提交。
此时又启动了另一个事务2,id=1的用户年龄也被更新: 代码语言:javascript copy begin;更新用户集年龄=23,其中id=1;犯罪;执行结果与主键相同。此时又启动了另一个事务2,id=2的用户年龄也被更新: 代码语言:javascript copy begin;更新用户集年龄=23,其中id=2;犯罪;执行结果与主键相同。
6、where条件使用数据库普通字段时,使用普通字段。该字段既不是主键也不是索引。
开启交易1,在交易中更新用户的年龄为age=22: 代码语言:javascript copy begin; select * from user where age=22 进行更新;更新用户集年龄=22,其中年龄=22; where条件中Age是数据库中的公共字段,使用了for update关键字,并加了表锁。此事务中没有提交。
此时又开启了另一个交易2,同时更新了age=22的用户的年龄: 代码语言:javascript copy begin;更新用户集年龄=23,其中年龄=22;犯罪;此时,当事务2执行时,等待事务1释放锁的Block。调整sql条件,将查询条件改为age=23: 代码语言:javascript copy begin;更新用户集年龄=23,其中年龄=23;犯罪;此时,事务3执行时,也会被阻塞等待事务1释放锁。
。也就是说,在for update语句中,使用普通字段作为查询条件时,加的是表锁,而不是行锁。
7、空数据当where条件查询到的数据不存在时会发生什么情况?开启交易1,在交易中更新id=66的用户年龄: 代码语言:javascript copy begin; select * from user where id=66 进行更新;更新用户集年龄=22,其中id=66;该数据不存在。此时又启动了另一个事务2,id=66的用户年龄也被更新: 代码语言:javascript copy begin;更新用户集年龄=23,其中id=66;犯罪;执行结果:执行成功,说明这种情况没有被锁定。
总结:最后总结一下select...for update的加锁情况: 主键字段:加行锁。唯一索引字段:添加行锁。
普通索引字段:加行锁。主键范围:添加多个行锁。
普通字段:加表锁。查询空数据:不加锁。
如果事务1加了行锁但没有释放锁,那么事务2在操作同一行数据时就会一直等待,直到超时。如果事务1加了表锁但没有释放锁,那么事务2无论操作哪一行数据都会等待直到超时。
版权声明:本文内容由互联网用户自发贡献,本站不拥有所有权,不承担相关法律责任。如果发现本站有涉嫌抄袭的内容,欢迎发送邮件 举报,并提供相关证据,一经查实,本站将立刻删除涉嫌侵权内容。
标签:
相关文章
06-18
06-18
06-18
06-17
最新文章
【玩转GPU】ControlNet初学者生存指南
【实战】获取小程序中用户的城市信息(附源码)
包雪雪简单介绍Vue.js:开学
Go进阶:使用Gin框架简单实现服务端渲染
线程池介绍及实际案例分享
JMeter 注释 18 - JMeter 常用配置组件介绍
基于Sentry的大数据权限解决方案
【云+社区年度征文集】GPE监控介绍及使用