select...for update
作用:
select for update 是为了在查询时,避免其他用户以该表进行插入,修改或删除等操作,造成表的不一致性.
该语句用来锁定特定的行(如果有where子句,就是满足where条件的那些行)。当这些行被锁定后,其他会话可以选择这些行,但不能更改或删除这些行,直到该语句的事务被commit语句或rollback语句结束为止。
for update的使用场景
如果遇到存在高并发并且对于数据的准确性很有要求的场景,是需要了解和使用for update的。
比如涉及到金钱、库存等。一般这些操作都是很长一串并且是开启事务的。如果库存刚开始读的时候是1,而立马另一个进程进行了update将库存更新为0了,而事务还没有结束,会将错的数据一直执行下去,就会有问题。所以需要for upate 进行数据加锁防止高并发时候数据出错。
- 记住一个原则:一锁二判三更新
SELECT…FOR UPDATE 语句的语法如下:
1 | SELECT ... FOR UPDATE [OF column_list][WAIT n|NOWAIT][SKIP LOCKED]; |
使用”FOR UPDATE WAIT”子句的优点如下:
- 1 防止无限期地等待被锁定的行;
- 2 允许应用程序中对锁的等待时间进行更多的控制。
- 3 对于交互式应用程序非常有用,因为这些用户不能等待不确定
- 4 若使用了skip locked,则可以越过锁定的行,不会报告由wait n 引发的‘资源忙’异常报告
For Example:
- select * from t for update 会等待行锁释放之后,返回查询结果。
- select * from t for update nowait 不等待行锁释放,提示锁冲突,不返回结果
- select * from t for update wait 5 等待5秒,若行锁仍未释放,则提示锁冲突,不返回结果
- select * from t for update skip locked 查询返回查询结果,但忽略有行锁的记录
排他锁的申请前提
没有线程对该结果集中的任何行数据使用排他锁或共享锁,否则申请会阻塞。
for update仅适用于InnoDB,且必须在事务块(BEGIN/COMMIT)中才能生效。在进行事务操作时,通过“for update”语句,MySQL会对查询结果集中每行数据都添加排他锁,其他线程对该记录的更新与删除操作都会阻塞。排他锁包含行锁、表锁。
场景分析
假设有一张商品表 goods,它包含 id,商品名称,库存量三个字段,表结构如下:
1 | CREATE TABLE `goods` ( |
插入如下数据:
1 | INSERT INTO `goods` VALUES ('1', 'prod11', '1000'); |
一、数据一致性
假设有A、B两个用户同时各购买一件 id=1 的商品,用户A获取到的库存量为 1000,用户B获取到的库存量也为 1000,用户A完成购买后修改该商品的库存量为 999,用户B完成购买后修改该商品的库存量为 999,此时库存量数据产生了不一致。
有两种解决方案:
- 悲观锁方案:
每次获取商品时,对该商品加排他锁。也就是在用户A获取获取 id=1 的商品信息时对该行记录加锁,期间其他用户阻塞等待访问该记录。悲观锁适合写入频繁的场景。
1 | begin; |
- 乐观锁方案:
每次获取商品时,不对该商品加锁。在更新数据的时候需要比较程序中的库存量与数据库中的库存量是否相等,如果相等则进行更新,反之程序重新获取库存量,再次进行比较,直到两个库存量的数值相等才进行数据更新。乐观锁适合读取频繁的场景。
1 | #不加锁获取 id=1 的商品对象 |
- 如果我们需要设计一个商城系统,该选择以上的哪种方案呢?
查询商品的频率比下单支付的频次高,基于以上我可能会优先考虑第二种方案(当然还有其他的方案,这里只考虑以上两种方案)。
二、行锁与表锁
InnoDB默认是行级别的锁,当有明确指定的主键时候,是行级锁。否则是表级别。
- for update的注意点
for update 仅适用于InnoDB,并且必须开启事务,在begin与commit之间才生效。
要测试for update的锁表情况,可以利用MySQL的Command Mode,开启二个视窗来做测试。
1、只根据主键进行查询,并且查询到数据,主键字段产生行锁。
1 | begin; |
2、只根据主键进行查询,没有查询到数据,不产生锁。
1 | begin; |
3、根据主键、非主键含索引(name)进行查询,并且查询到数据,主键字段产生行锁,name字段产生行锁。
1 | begin; |
4、根据主键、非主键含索引(name)进行查询,没有查询到数据,不产生锁。
1 | begin; |
5、根据主键、非主键不含索引(name)进行查询,并且查询到数据,如果其他线程按主键字段进行再次查询,则主键字段产生行锁,如果其他线程按非主键不含索引字段进行查询,则非主键不含索引字段产生表锁,如果其他线程按非主键含索引字段进行查询,则非主键含索引字段产生行锁,如果索引值是枚举类型,mysql也会进行表锁,这段话有点拗口,大家仔细理解一下。
1 | begin; |
6、根据主键、非主键不含索引(name)进行查询,没有查询到数据,不产生锁。
1 | begin; |
7、根据非主键含索引(name)进行查询,并且查询到数据,name字段产生行锁。
1 | begin; |
8、根据非主键含索引(name)进行查询,没有查询到数据,不产生锁。
1 | begin; |
9、根据非主键不含索引(stock)进行查询,并且查询到数据,stock字段产生表锁。
1 | begin; |
10、根据非主键不含索引(stock)进行查询,没有查询到数据,stock字段产生表锁。
1 | begin; |
11、只根据主键进行查询,查询条件为不等于,并且查询到数据,主键字段产生表锁。
1 | begin; |
12、只根据主键进行查询,查询条件为不等于,没有查询到数据,主键字段产生表锁。
1 | begin; |
13、只根据主键进行查询,查询条件为 like,并且查询到数据,主键字段产生表锁。
1 | begin; |
14、只根据主键进行查询,查询条件为 like,没有查询到数据,主键字段产生表锁。
1 | begin; |
- 测试环境
数据库版本:5.1.48-community
数据库引擎:InnoDB Supports transactions, row-level locking, and foreign keys
数据库隔离策略:REPEATABLE-READ(系统、会话)
总结
1、InnoDB行锁是通过给索引上的索引项加锁来实现的,只有通过索引条件检索数据,InnoDB才使用行级锁,否则,InnoDB将使用表锁。
2、由于MySQL的行锁是针对索引加的锁,不是针对记录加的锁,所以虽然是访问不同行的记录,但是如果是使用相同的索引键,是会出现锁冲突的。应用设计的时候要注意这一点。
3、当表有多个索引的时候,不同的事务可以使用不同的索引锁定不同的行,另外,不论是使用主键索引、唯一索引或普通索引,InnoDB都会使用行锁来对数据加锁。
4、即便在条件中使用了索引字段,但是否使用索引来检索数据是由MySQL通过判断不同执行计划的代价来决定的,如果MySQL认为全表扫描效率更高,比如对一些很小的表,它就不会使用索引,这种情况下InnoDB将使用表锁,而不是行锁。因此,在分析锁冲突时,别忘了检查SQL的执行计划,以确认是否真正使用了索引。
5、检索值的数据类型与索引字段不同,虽然MySQL能够进行数据类型转换,但却不会使用索引,从而导致InnoDB使用表锁。通过用explain检查两条SQL的执行计划,我们可以清楚地看到了这一点。