MySQL 8.0 新特性之 InnoDB 锁定读取选项

文章目录

锁定读取语句

如果在同一个事务中，先查询数据，然后再插入或修改相关的数据，普通的 SELECT 语句无法提供足够的数据保护。其他的事务可能会更新或删除该事务刚刚查询过的数据。InnoDB 提供了两种锁定读取（locking read）语句，能够提供更高的安全性：

SELECT … FOR SHARE

在读取的行上设置一个共享锁。其他的会话可以读取这些行，但是在当前事务提交之前不能修改这些数据。如果其他事务修改了当前查询需要读取的任何数据，并且没有提交，查询需要等待其他事务结束，然后返回最新的数据。

注意：SELECT … FOR SHARE 替代了之前的 SELECT … LOCK IN SHARE MODE，但是为了后向兼容，仍然支持 LOCK IN SHARE MODE。这两个语句是等价的。不过，FOR SHARE 支持 OF table_name、NOWAIT 以及 SKIP LOCKED 选项。参见后文。
SELECT … FOR UPDATE

对于查询涉及的索引记录，锁定相应的数据行和索引项，效果和执行 UPDATE 语句一样。其他事务如果需要更新这些行，或者执行这些数据上的 SELECT … FOR SHARE，或者使用某些事务隔离级别读取这些数据，都会被阻塞。一致性读将会忽略读视图（read view）中存在的数据记录上的锁。（记录的旧版本数据不能被锁定；它们通过记录在内存中的拷贝，加上回滚日志进行重构。）

这些选项主要用于处理树状结构或图结构的数据，可以是单个表或跨多个表存储的数据。可以通过图的边界或树的分支从一个位置移动到另一个位置，同时可以反向移动并修改这些“指针”数据。

事务提交或者回滚时，释放 FOR SHARE 和 FOR UPDATE 设置的所有锁。

注意
锁定读取只有在禁用了 autocommit 时才会生效（使用 START TRANSACTION 开始一个事务或者将 autocommit 设置为 0）。

外部查询中的锁定读取子句不会锁定子查询中的表数据，除非在子查询中也指定了锁定读取。例如，以下查询不会锁定 t2 表中的行：

SELECT * FROM t1 WHERE c1 = (SELECT c1 FROM t2) FOR UPDATE;

要想锁定 t2 表中的数据行，需要在子查询中增加一个锁定读取子句：

SELECT * FROM t1 WHERE c1 = (SELECT c1 FROM t2 FOR UPDATE) FOR UPDATE;

锁定读取示例

假如你想要为 child 表插入一个行新的数据，并且想要确保在 parent 表中存在对应的父级数据。应用程序可以通过以下系列操作确保参照完整性。

首先，执行一个一致性读取，查询 PARENT 表并验证存在相应的父级行。然后可以安全地在 CHILD 表中插入子记录吗？不可以，因为其他的会话可能在你的 SELECT 语句和 INSERT 语句之间删除了父记录，而你并不知道。

为了避免这个潜在的问题，可以执行以下 SELECT … FOR SHARE 语句：

SELECT * FROM parent WHERE NAME = 'Jones' FOR SHARE;

在 FOR SHARE 语句返回父记录 ‘Jones’ 之后，你可以安全地在 CHILD 表中增加子记录，并且提交事务。任何相应获取 PARENT 表中该记录上的排他锁的事务都需要等待你的事务结束，也就是等待所有表中的数据到达一致性的状态。

再看一个示例，CHILD_CODES 表中存在一个整数计数器字段，用于为 CHILD 表中的每个子记录指定一个唯一标识符。不要使用一致性读或共享模式读的方式获取计数器的当前值，因为两个用户可能同时读取了相同的值，如果两个事务使用相同的标识符为 CHILD 表增加数据，将会产生重复键值错误。

这种情况下，FOR SHARE 并不是一个好的解决方法，因为如果两个用户同时读取了计数器的值，至少有一个用户在更新计数器的时候会死锁。

为了实现计数器的读取和增长，首先使用带 FOR UPDATE 选项的锁定读取操作，然后再修改计数器的值。例如：

SELECT counter_field FROM child_codes FOR UPDATE;
UPDATE child_codes SET counter_field = counter_field + 1;

SELECT … FOR UPDATE 语句读取数据的最新值，为每行数据设置一个排他锁。因此，它和 UPDATE 语句设置的是相同的行锁。

前面的示例只是为了演示 SELECT … FOR UPDATE 的工作过程。在 MySQL 中，实际上可以通过一条简单的语句生成唯一的标识符：

UPDATE child_codes SET counter_field = LAST_INSERT_ID(counter_field + 1);
SELECT LAST_INSERT_ID();

SELECT 语句只是为了返回标识符的值（与当前会话相关的值）。它不会访问任何表。

NOWAIT 和 SKIP LOCKED 选项

如果某个行被其他事务锁定，访问该行数据的 SELECT … FOR UPDATE 或者 SELECT … FOR SHARE 事务必须等待其他事务释放数据行上的锁。这种行为可以防止事务更新或删除其他事务正在查询更新的数据行。不过，如果在请求的数据行已经被锁定的情况下希望立即返回，或者可以接受只返回没有被锁定的数据行，就不需要一直等待其他事务释放行锁。

为了避免需要等待其他事务释放锁，可以为锁定读取语句 SELECT … FOR UPDATE 或 SELECT … FOR SHARE 增加 NOWAIT 和 SKIP LOCKED 选项。

NOWAIT

使用 NOWAIT 选项的锁定读取不会等待获取行锁。查询立即执行，如果请求的行被锁定，返回一个错误信息。
SKIP LOCKED

使用 SKIP LOCKED 选项的锁定读取不会等待获取行锁。查询立即执行，并且从结果中排除了被锁定的行。

注意
跳过锁定行的查询返回数据的不一致性视图。因此，SKIP LOCKED 不适合用于常见的交易系统。但是，它可以用于避免多个会话访问同一个队列表时的锁竞争。

NOWAIT 和 SKIP LOCKED 选项只适用于行级锁。

使用 NOWAIT 或 SKIP LOCKED 选项的锁定读取对于基于语句的复制而言并不安全。

以下示例演示了 NOWAIT 和 SKIP LOCKED 选项的使用。会话 1 开始了一个事务，获取了单个记录上的行锁。会话 2 使用 NOWAIT 选项尝试针对同一条记录的带锁读取操作。由于请求的数据已经被会话 1 锁定，会话 2 中的锁定读取操作立即返回一个错误。在会话 3中，使用锁定读取的 SKIP LOCKED 选项返回没有被会话 1 锁定的其他数据。

# Session 1:

mysql> CREATE TABLE t (i INT, PRIMARY KEY (i)) ENGINE = InnoDB;

mysql> INSERT INTO t (i) VALUES(1),(2),(3);

mysql> START TRANSACTION;

mysql> SELECT * FROM t WHERE i = 2 FOR UPDATE;
+---+
| i |
+---+
| 2 |
+---+

# Session 2:

mysql> START TRANSACTION;

mysql> SELECT * FROM t WHERE i = 2 FOR UPDATE NOWAIT;
ERROR 3572 (HY000): Do not wait for lock.

# Session 3:

mysql> START TRANSACTION;

mysql> SELECT * FROM t FOR UPDATE SKIP LOCKED;
+---+
| i |
+---+
| 1 |
| 3 |
+---+

人生本来短暂，你又何必匆匆！点个赞再走吧！

原文地址：https://tonydong.blog.csdn.net

MySQL 8.0 新特性之 InnoDB 锁定读取选项

文章目录

锁定读取语句

锁定读取示例

NOWAIT 和 SKIP LOCKED 选项

相关推荐