1. 什么是MVCC
普通的select语句在read committed 和 repeatable read隔离级别下会使用MVCC读取记录
- 在read committed隔离级别下, 一个事务在执行过程中每次执行select操作时都会生成一个read View, ReadView的存在本身就保证了事务不可以读取到未提交的事务所做的更改, 也就是避免了脏读现象.
- 在repeatable read隔离级别下, 一个事务在执行过程中只有第一次执行select操作才会生成一个ReadView, 之后的select操作都复用这个Read View, 这样也就避免了不可重复读和幻读的问题
MVCC没有正式标准, 这里讲解innodb中的实现机制
2. 快照读与当前读
2.1 快照读
SELECT * FROM player WHERE ...
之所以出现快照读的情况,是基于提高并发性能的考虑,快照读的实现是基于MVCC,它在很多情况下,避免了加锁操作,降低了开销。
2.2 当前读
SELECT * FROM student LOCK IN SHARE MODE; # 共享锁
SELECT * FROM student FOR UPDATE; # 排他锁
INSERT INTO student values ... # 排他锁
DELETE FROM student WHERE ... # 排他锁
UPDATE student SET ... # 排他锁
3. 复习
3.1 再谈隔离级别
我们知道事务有 4 个隔离级别,可能存在三种并发问题:
在MysQL中,默认的隔离级别是可重复读,可以解决脏读和不可重复读的问题,如果仅从定义的角度来看,它并不能解决幻读问题。如果我们想要解决幻读问题,就需要采用串行化的方式,也就是将隔离级别提升到最高,但这样一来就会大幅降低数据库的事务并发能力。
MVCC可以不采用锁机制,而是通过乐观锁的方式来解决不可重复读和幻读问题!它可以在大多数情况下替代行级锁,降低系统的开销。
3.2 隐藏字段、Undo Log版本链
- trx_id :每次一个事务对某条聚簇索引记录进行改动时,都会把该事务的 事务id 赋值给 trx_id 隐藏列(最近一次更新该数据的事务id)。
- roll_pointer :每次对某条聚簇索引记录进行改动时,都会把旧的版本写入到 undo日志 中,然后这个隐藏列就相当于一个指针,可以通过它来找到该记录修改前的信息。
举例: student表数据如下:
假设插入该记录的事 务id为8, 那么此刻该条记录的示意图如下所示:
insert undo 只在事务回滚时起作用,当事务提交后,该类型的 undo 日志就没用了,它占用的 Undo Log Segment 也会被系统回收(也就是该 undo 日志占用的 Undo 页面链表要么被重用,要么被释 放)
假设之后两个事务id分别为 10 、 20 的事务对这条记录进行 UPDATE 操作,操作流程如下
能不能在两个事务中交叉更新同一条记录呢? 不能, 这不就是一个事务修改了另一个未提交事务修改过的数据, 脏写
InnoDB使用锁来保证不会有脏写情况的发生, 也就是在第一个事务更新了某条记录后, 就会给这条记录加锁, 另一个事务再次更新时就需要等待第一个事务提交了, 把锁释放之后才可以继续更新.
4. MVCC实现原理之ReadView
4.1 什么是ReadView
在MVCC机制中,多个事务对同一个行记录进行更新会产生多个历史快照,这些历史快照保存在Undo Log里。如果一个事务想要查询这个行记录,需要读取哪个版本的行记录呢?这时就需要用到ReadView了,它帮我们解决了行的可见性问题。
ReadView就是事务在使用MVcc机制进行快照读操作时产生的读视图。当事务启动时,会生成数据库系统当前的一个快照,InnoDB为所有事务构造了一个数组,用来记录并维护系统当前活跃事务的ID(“活跃"指的就是,启动了但还没提交)。
4.2 设计思路
- creator_trx_id ,创建这个 Read View 的事务 ID。 说明:只有在对表中的记录做改动时(执行INSERT、DELETE、UPDATE这些语句时)才会为 事务分配事务id(递增的),否则在一个只读事务中的事务id值都默认为0。
- trx_ids ,表示在生成ReadView时当前系统中活跃的读写事务的 事务id列表 。
- up_limit_id ,活跃的事务中最小的事务 ID。
- low_limit_id ,表示生成ReadView时系统中应该分配给下一个事务的 id 值。low_limit_id 是系统最大的事务id值,这里要注意是系统中的事务id,需要区别于正在活跃的事务ID。
注意:low_limit_id并不是trx_ids中的最大值,事务id是递增分配的。比如,现在有id为1, 2,5这三个事务,之后id为5的事务提交了。那么一个新的读事务在生成ReadView时, trx_ids就包括1和2,up_limit_id的值就是1,low_limit_id的值就是6。
4.3 ReadView的规则
- 如果被访问版本的trx_id属性值与ReadView中的 creator_trx_id 值相同,意味着当前事务在访问它自己修改过的记录,所以该版本可以被当前事务访问。
- 如果被访问版本的trx_id属性值小于ReadView中的 up_limit_id 值,表明生成该版本的事务在当前事务生成ReadView前已经提交,所以该版本可以被当前事务访问。
- 如果被访问版本的trx_id属性值大于或等于ReadView中的 low_limit_id 值,表明生成该版本的事务在当前事务生成ReadView后才开启,所以该版本不可以被当前事务访问。
- 如果被访问版本的trx_id属性值在ReadView的 up_limit_id 和 low_limit_id 之间,那就需要判 断一下trx_id属性值是不是在 trx_ids 列表中。
- 如果在,说明创建ReadView时生成该版本的事务还是活跃的,该版本不可以被访问。
- 如果不在,说明创建ReadView时生成该版本的事务已经被提交,该版本可以被访问。
4.4 MVCC整体操作流程
- 首先获取事务自己的版本号,也就是事务 ID;
- 获取 ReadView;
- 查询得到的数据,然后与 ReadView 中的事务版本号进行比较;
- 如果不符合 ReadView 规则,就需要从 Undo Log 中获取历史快照;
- 最后返回符合规则的数据。
5. 举例说明
假设现在student表中只有一条由事务id 为 8 的事务插入的一条记录:
MVCC只能在Read Committed 和repeatable read 两个隔离级别下工作. 接下来看一下read committed 和 repeatable read 所谓的生成Read View的时机不同 到底不同在哪里
5.1 READ COMMITTED隔离级别下
此刻,表student 中 id 为 1 的记录得到的版本链表如下所示: 假设现在有一个使用 READ COMMITTED 隔离级别的事务开始执行:这个SELECT1的执行过程如下:
- 在执行 SELECT 语句时会先生成一个 ReadView ,ReadView的 trx_ids 列表的内容就是 [10,20],up_limit_id 为10, low_limit_id 为21, creator_trx_id 为0。
- 从版本链中挑选可见的记录,从图中看出,最新版本的列 name 的内容是 '王五',该版本的trx_id 值为10,在 trx_ids 列表内,所以不符合可见性要求,根据 roll_pointer 跳到下一个版本。
- 下一个版本的列 name 的内容是 ‘李四’,该版本的 trx_id 值也为10,也在 trx_ids 列表内,所以也不符合要求,继续跳到下一个版本。
- 下一个版本的列 name 的内容是 '张三',该版本的 trx_id 值为8,小于ReadView中的up_limit_id 值 10,所以这个版本是符合要求的,最后返回给用户的版本就是这条列 name 为 '张三' 的记录。
之后,我们把 事务id 为 10 的事务提交一下:
然后再到 事务id 为 20 的事务中更新一下表 student 中 id 为 1 的记录:
此刻,表student中 id 为 1 的记录的版本链就长这样:
然后再到刚才使用 READ COMMITTED 隔离级别的事务中继续查找这个 id 为 1 的记录,如下:这个SELECT2的执行过程如下:
步骤1:在执行SELECT语句时会又会单独生成一个ReadView ,该 ReadView 的 trx_ids 列表的内容就是 [20] , up_limit_id 为 20 , low_limit_id 为 21 , creator_trx_id 为 0。
步骤2:从版本链中挑选可见的记录,从图中看出,最新版本的列 name 的内容是 '宋八',该版本的trx_id 值为 20,在 trx_ids 列表内,所以不符合可见性要求,根据 roll_pointer 跳到下一个版本。
步骤3:下一个版本的列 name 的内容是 '钱七',该版本的 trx_id 值为 20,也在 trx_ids 列表内,所以也不符合要求,继续跳到下一个版本。
步骤4:下一个版本的列 name 的内容是 '王五',该版本的 trx_id 值为 10,小于 ReadView 中的up_limit_id 值 20,所以这个版本是符合要求的,最后返回给用户的版本就是这条列 name 为 '王五' 的记录。
以此类推, 如果之后事务 id 为 20 的记录也提交了, 再次在使用 read committed 隔离级别的事务中查询表 student 中 id 值为 1 的记录时, 得到的结果就是 '宋八' 了, 具体流程我们就不分析了
强调: 使用read committed 隔离级别的事务在每次查询开始时都会生成一个独立的readView
5.2 REPEATABLE READ隔离级别下
此刻,表student 中 id 为 1 的记录得到的版本链表如下所示: 假设现在有一个使用 REPEATABLE READ 隔离级别的事务开始执行:
这个SELECT1的执行过程如下:
- 在执行 SELECT 语句时会先生成一个 ReadView ,ReadView的 trx_ids 列表的内容就是 [10,20],up_limit_id 为10, low_limit_id 为21, creator_trx_id 为0。
- 从版本链中挑选可见的记录,从图中看出,最新版本的列 name 的内容是 '王五',该版本的trx_id 值为10,在 trx_ids 列表内,所以不符合可见性要求,根据 roll_pointer 跳到下一个版本。
- 下一个版本的列 name 的内容是 ‘李四’,该版本的 trx_id 值也为10,也在 trx_ids 列表内,所以也不符合要求,继续跳到下一个版本。
- 下一个版本的列 name 的内容是 '张三',该版本的 trx_id 值为8,小于ReadView中的up_limit_id 值 10,所以这个版本是符合要求的,最后返回给用户的版本就是这条列 name 为 '张三' 的记录。
之后,我们把 事务id 为 10 的事务提交一下,就像这样:
然后再到 事务id 为 20 的事务中更新一下表 student 中 id 为 1 的记录:
然后再到刚才使用 REPEATABLE READ 隔离级别的事务中继续查找这个 id 为 1 的记录,如下:
这个SELECT2的执行过程如下:
- 因为当前事务的隔离级别为repeatable read 在执行 SELECT1 语句时已经生成一个 ReadView ,所以直接服用之前的ReadView, 之前的ReadView的 trx_ids 列表的内容是 [10,20],up_limit_id 为10, low_limit_id 为21, creator_trx_id 为0。
- 然后从版本链中挑选可见的记录,从图中可以看出,最新版本的列name的内容是'宋八',该版本的 trx_id 值为20,在 trx_ids 列表内,所以不符合可见性要求,根据 roll_pointer 跳到下一个版本。
- 下一个版本的列 name 的内容是 '钱七',该版本的 trx_id 值为 20,也在 trx_ids 列表内,所以也不符合要求,继续跳到下一个版本。
- 下一个版本的列 name 的内容是 '王五',该版本的 trx_id 值为 10,而 trx_ids 列表中是包含值为 10 的事务id的,所以该版本也不符合要求,同理下一个列 name 的内容是 '李四' 的版本也不符合要求。继续跳到下一个版本。
- 下一个版本的列 name 的内容是 '张三',该版本的 trx_id 值为 8,小于 ReadView 中的up_limit_id 值10,所以这个版本是符合要求的,最后返回给用户的版本就是这条列c为‘张三'的记录
5.3 如何解决幻读
- 首先 id=1 的这条数据,前面已经说过了,可以被事务 A 看到。
- 然后是 id=2 的数据,它的 trx_id=30,此时事务 A 发现,这个值处于 up_limit_id 和 low_limit_id 之间,因此还需要再判断 30 是否处于 trx_ids 数组内。由于事务 A 的 trx_ids=[20,30],因此在数组内,这表 示 id=2 的这条数据是与事务 A 在同一时刻启动的其他事务提交的,所以这条数据不能让事务 A 看到。
- 同理,id=3 的这条数据,trx_id 也为 30,因此也不能被事务 A 看见。
- READ COMMITTD 在每一次进行普通SELECT操作前都会生成一个ReadView
- REPEATABLE READ 只在第一次进行普通SELECT操作前生成一个ReadView,之后的查询操作都重复 使用这个ReadView就好了。
通过 MVCC 我们可以解决:
- 读写之间阻塞的问题。通过McC可以让读写互相不阻塞,即读不阻塞写,写不阻塞读,这样就可以提升事务并发处理能力。
- 降低了死锁的概率。这是因为MVCC采用了乐观锁的方式,读取数据时并不需要加锁,对于写操作,也只锁定必要的行。
- 解决快照读的问题。当我们查询数据库在某个时间点的快照时,只能看到这个时间点之前事务提交更新的结果,而不能看到这个时间点之后事务提交的更新结果。