MySQL MVCC的详解之Read View

文章目录

    • 概要
    • 一、基于UNDO LOG的版本链
        • 1.1、行记录结构
        • 1.2、了解UNDO LOG
        • 1.3、版本链
    • 二、Read View
        • 2.1、判定机制
        • 2.2、源码
    • 三、参考

概要

在上文中，我们提到了MVCC（Multi-Version Concurrency Control)多版本并发控制，是通过undo log来实现的。那具体是如何实现的呢？将在本文一一道来。

MVCC是为了实现非阻塞读，即提高数据库并发读能力的一种机制。

通常来说，A事务正在修改数据行X，在修改未结束前，B事务要读数据行X,为了避免读到脏数据，B就会被阻塞,直到A事务修改完数据行X，MVCC很好的避免了这种情况的发生。

MVCC是通过保存数据在某个时间点的快照来实现的，即保存一个数据行的多个变更版本（空间换时间）。这些版本就是undo log了，每一行的变更记录就存在undo log中，通过链表联系在一起，构成了一个完整的版本链，供MVCC实现非阻塞读。

例如在可重复读隔离级别下，A事务正在修改数据行X，在修改数据行X前会把其当前记录插入到版本链中，B事务要读数据行X就到版本链中找符合的，这样B就不会被阻塞了。

ps:MySQL的MVCC只作用于在REPEATABLE READ和READ COMMITED两个隔离级别下执行普通的SELECT操作。

在高性能MySQL第三版一书中对MVCC的操作描述如下：
高性能MySQL第三版一书中对MVCC的操作描述下面来一起探索下具体实现吧。

本文背景：MySQL InnoDB存储引擎。

一、基于UNDO LOG的版本链

在了解版本链之前，首先看一下InnoDB存储引擎的行记录。

1.1、行记录结构

提到MySQL的行记录，肯定会想到行ID、用户数据列等内容，除了这些信息外，还有一些隐藏信息，比如事务ID、回滚指针等其他额外信息，那我们可以得出下图：
MySQL行记录结构简单示意图
其中事务ID(trx_id)、回滚指针(rollback_ptr)是本文要讲的核心。

ps:InnoDB的行记录是存储在聚族索引中的

1.2、了解UNDO LOG

                                            MySQL undo log结构示意图

MySQL undo log结构示意图

MySQL的undo log分为两大类：

  1. insert undo:insert 操作产生的，记录了table_id、trx_id、主键各列数据等信息。
  2. update undo:update和delete操作产生的，

虽说update和delete操作产生的undo log都会记录到update undo这个大类，但其记录内容是有很大差距的。
delete操作产生的undo log会记录table_id、trx_id、rollback_ptr、主键各列数据等信息，而update操作产生的undo log会记录更新table_id、trx_id、rollback_ptr、被更新列旧值、主键各列数据等信息。

ps:可以看到undo log中并没有记录用户列数据

1.3、版本链

我们现在在test库下有一个test表：
MySQL 测试表下面我们经过一系列插入，删除，更新来演示版本链的变迁：
假设当前全局trx_id = 101。

  1. 插入一条数据
insert into test (id,num,name,key_id) values (1,1,"bob",11);

此时有：
插入一条数据

  1. 更新数据
    1）令id=1的数据name=tom
update test set name = "tom" where id = 1;

此时有：
更新一条数据
2）令id=1的数据name=join

update test set name = "join" where id = 1;

此时有：
更新一条数据

  1. 删除数据，删除id=1的数据
delete from test where id = 1;

此时有：
删除一条数据
如上图，在对id=1这一条记录的插入，更新，删除的过程中构建了一个版本链。其中删除操作，只是在聚簇索引上的记录中打了删除标记，并不会立即删除，而是当没有Read View持有该事务ID时才会有purge线程去真的去删除，之后这块空间才能被使用，为什么不能立即删除呢，主要是因为undo log中并不保存所有的用户列数据，甚至不保存，都是基于聚簇索引中的记录行，在结合undo log内容，在回滚过程中构造某个版本的数据。

另外，我们在1.2小节中强调了 undo log中并不记录用户列数据，这里只是为了表示方便才画了出来，其实MySQL是基于聚簇索引上的记录内容，通过从聚簇索引上的记录roll_ptr开始，依次回滚，直到遇到符合要求的事务ID，构造出最终数据。

假设第二次更新操作开始但未提交时，有个trx_id=107的事务要读id=1的数据，此时发现ID=1的数据trx_id=106且处于活跃状态，则需要沿着版本链回滚，当遇到trx_id=102的记录，结合聚簇索引上的记录和trx_id=102的undo记录,构造出trx_id=102的完整数据，对于trx_id=107的事务来说，该事务是已提交的事务，则读取即可。其实这就是Read View了，详情请看下一章节。

二、Read View

对于READ COMMITED隔离级别，需要读已经提交的数据，那当A事务修改完聚簇索引上的记录X后尚未提交，此时B事务读取记录X，按照定义，此时聚簇索引上的记录是不允许读取的，如何判定呢？就依赖Read View机制了

对于REPEATABLE READ隔离级别，需要重复读数据，那当A事务读取记录X后，B事务修改完聚簇索引上的记录X并提交，此时A事务需要在此读取记录X，按照定义，此时聚簇索引上的记录是不允许读取的，如何判定呢？也就依赖Read View机制了

Read View也称作一致性视图，其主要包含4个主要的内容：

  • m_ids：在生成Read View时，当前系统中活跃的读写事务的事务ID列表；
  • min_trx_id：在生成Read View时，当前系统中活跃的读写事务中最小的事务ID，即m_ids中的最小值；
  • max_trx_id：在生成Read View时，当前系统中活跃的读写事务中最大的事务ID，即系统应该分配给下一个事务的事务ID（全局事务ID的值）；
  • creator_trx_id：在生成Read View时，当前事务的事务ID。

其中max_trx_id要注意下，并不一定是m_ids中的最大值，而是生成Read View时的全局事务ID值。因为事务ID时递增（循环）分配的，在RR隔离级别下，假设当前活跃的事务ID有1,2,3，事务ID=3的事务提交后，再开启一个事务A，发起读操作，此时Read View时m_ids=[1,2,4],min_trx_id=1，max_trx_id=4,如果有另一个写事务B提交了，消耗了一个事务ID=4，那么此时事务A进行写操作，就会出现creator_trx_id=5的情况。

为什么会这样呢？我们要明白事务ID的生成并不是开启事务（执行begin操作）时就确定的，而是第一次执行写操作时确定的。
而Read View生成时机是在读操作前确定的，但RC与RR还不同，RC是每次读操作前都生成一个Read View（保证可以读已提交数据），而RR是在第一次读操作前生成一个Read View，就不会变动了（保证可重复读）。

2.1、判定机制

MySQL根据Read View读要访问的记录依次进行以下判定，来决定是否可访问：

  1. 如果被访问记录的trx_id等于creator_trx_id相等，这意味当前事务在访问它自己修改的记录，允许被访问；
  2. 如果被访问记录的trx_id小于min_trx_id，这意味被访问记录在当前事务生成Read View时已经提交了，允许被访问；
  3. 如果被访问记录的trx_id大于等于max_trx_id,这意味被访问记录在当前事务生成Read View之后产生的，不允许被访问；
  4. 如果被访问记录的trx_id在m_ids中，说明在当前事务生成Read View时被访问记录所属的事务还是活跃的，不允许被访问；
  5. 如果被访问记录的trx_id不在m_ids中，说明在当前事务生成Read View时被访问记录所属的事务已经提交了，允许被访问；

以上的判定机制，是实现RC和RR的基础。

select trx_id,trx_state,trx_started,trx_rows_locked from INFORMATION_SCHEMA.INNODB_TRX; #可以查看当前活跃的事务id等信息

针对1.3小节的版本链案例：
我们依次执行下面四个语句，看看效果如何(RR隔离级别)：
1:

insert into test (id,num,name,key_id) values (1,1,"bob",11);#事务id = 101

2:

begin;
update test set name = "tom" where id = 1; #事务id = 102

3:

insert into test (id,num,name,key_id) values (2,2,"2ob",22);#事务id = 103
insert into test (id,num,name,key_id) values (3,3,"3ob",33);#事务id = 104

4：

begin;                    
update test set name = "uuu" where id = 2; #事务id = 105

5:

begin;
select * from test where id = 1;
update test set name = "uuu" where id = 3; #事务id = 106

那么第五句select * from test where id = 1;的Read View如下：
m_ids=[102,105]，min_trx_id=102，max_trx_id=106, creator_trx_id = 0

针对id=1这条记录，此时test表聚簇索引中的记录是 (1,1,"tom",11)，隐藏字段trx_id=102。但是102在m_ids中，所以不可见，根据其undo log得到最终结果 (1,1,"bob",11)

2.2、源码

MySQL V8.0.32
MySQL READ VIEW 源码

  1. 生成Read View
/*调用链如下
trx_assign_read_viewtrx_sys->mvcc->view_open(MVCC::view_open)view->prepare(ReadView::prepare)*///下面来看看核心的prepare函数干了什么/*
Opens a read view where exactly the transactions serialized before this
point in time are seen in the view.
@param id               Creator transaction id */
void ReadView::prepare(trx_id_t id) {ut_ad(trx_sys_mutex_own());m_creator_trx_id = id; //赋值creator_trx_idm_low_limit_no = trx_get_serialisation_min_trx_no(); m_low_limit_id = trx_sys_get_next_trx_id_or_no();//系统应该分配给下一个事务的事务ID，即max_trx_id ut_a(m_low_limit_no <= m_low_limit_id);if (!trx_sys->rw_trx_ids.empty()) { copy_trx_ids(trx_sys->rw_trx_ids); //将此刻全局活跃跃事务列表ids 赋值给当前READ VIEW的m_ids属性} else {m_ids.clear();}/* The first active transaction has the smallest id. */m_up_limit_id = !m_ids.empty() ? m_ids.front() : m_low_limit_id;//获取当前活跃事务列表中的最小事务id,即min_trx_idut_a(m_up_limit_id <= m_low_limit_id);ut_d(m_view_low_limit_no = m_low_limit_no);m_closed = false;
}
  1. Read View判定
 /** Check whether the changes by id are visible.@param[in]    id      transaction id to check against the view@param[in]    name    table name@return whether the view sees the modifications of id. */[[nodiscard]] bool changes_visible(trx_id_t id,const table_name_t &name) const {ut_ad(id > 0);if (id < m_up_limit_id || id == m_creator_trx_id) {//小于min_trx_id 或等于 creator_trx_id 则允许访问return (true);}check_trx_id_sanity(id, name);if (id >= m_low_limit_id) { //大于max_trx_id 则不允许访问return (false);} else if (m_ids.empty()) {//m_ids为空则允许访问return (true);}const ids_t::value_type *p = m_ids.data();return (!std::binary_search(p, p + m_ids.size(), id));//二分查找，在m_ids不允许访问，不在则允许访问}

三、参考

1]:庖丁解InnoDB之Undo LOG
2]:正确的理解MySQL的MVCC及实现原理

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/52212.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

【校招VIP】TCP/IP模型之常用协议和端口

【校招VIP】TCP/IP模型之常用协议和端口

考点介绍&#xff1a; 大厂测试校招面试里经常会出现TCP/IP模型的考察&#xff0c;TCP/IP协议是网络基础知识&#xff0c;是互联网的基石&#xff0c;不管你是做开发、运维还是信息安全的&#xff0c;TCP/IP 协议都是你绕不过去的一环&#xff0c;程序员需要像学会看书写字一样…
阅读更多...
174-地下城游戏

174-地下城游戏

题目 恶魔们抓住了公主并将她关在了地下城 dungeon 的 右下角 。地下城是由 m x n 个房间组成的二维网格。我们英勇的骑士最初被安置在 左上角 的房间里&#xff0c;他必须穿过地下城并通过对抗恶魔来拯救公主。 骑士的初始健康点数为一个正整数。如果他的健康点数在某一时刻…
阅读更多...
element-ui中的el-table合并单元格

element-ui中的el-table合并单元格

描述&#xff1a; 在写项目的时候有时候会经常遇到把行和列合并起来的情况&#xff0c;因为有些数据是重复渲染的&#xff0c;不合并行列会使表格看起来非常的混乱&#xff0c;如下&#xff1a; 而我们想要的数据是下面这种情况&#xff0c;将重复的行进行合并&#xff0c;使表…
阅读更多...
升级Go 版本到 1.19及以上，Goland： file.Close() 报错： Unresolved reference ‘Close‘

升级Go 版本到 1.19及以上，Goland： file.Close() 报错： Unresolved reference ‘Close‘

错误截图 解决方法 File -> Settings -> Go -> Build Tags & Vendoring -> Custom tags -> 添加值 “unix” 原因 Go 1.19 引入了unix构建标签。因此&#xff0c;需要添加unix到自定义标签。 参考 https://blog.csdn.net/weixin_43940592/article/det…
阅读更多...
any、unknown、never 和 void区别

any、unknown、never 和 void区别

any 类型&#xff1a; any 类型是 TypeScript 中的顶级类型&#xff0c;它可以接受任何类型的值&#xff0c;相当于取消了类型检查。 当将变量声明为 any 类型时&#xff0c;可以赋予它任何值&#xff0c;无论是数字、字符串、布尔值还是其他类型的值。 使用 any 类型可能会降…
阅读更多...
MySql增量恢复

MySql增量恢复

一、 使用二进制日志的时间点恢复 注意 本节和下一节中的许多示例都使用mysql客户端来处理mysqlbinlog生成的二进制日志输出。如果您的二进制日志包含\0&#xff08;null&#xff09;字符&#xff0c;那么mysql将无法解析该输出&#xff0c;除非您使用--binary模式选项调用它。…
阅读更多...
高速收费站的智慧之选，工控机助力顺畅通行！

高速收费站的智慧之选，工控机助力顺畅通行！

2020年初取消高速公路省界收费站后&#xff0c;全国高速公路进入“一张网运行、一体化服务”的新阶段。随着ETC用户量快速增长、驾乘人员对收费站高效通行需求不断提升&#xff0c;收费数据在线化运营及精准化、智能化、人性化的收费服务将成为主流。如何提高收费系统集成度、降…
阅读更多...
软考高级系统架构设计师系列论文八十五：论软件产品线技术

软考高级系统架构设计师系列论文八十五：论软件产品线技术

软考高级系统架构设计师系列论文八十五：论软件产品线技术 一、摘要二、正文三、总结一、摘要 根据“十五”国防科技重点实验室—“机载XXPD火控雷达性能开发与评估实验室”的建设需求。我所在的中国x集团公司x所电子对抗研究部组织了用于该实验室目布式联网试验，主要任务是试…
阅读更多...
h5逻辑_调用手机拨号功能

h5逻辑_调用手机拨号功能

有时点击页面某个按钮&#xff0c;希望能掉起手机拨号页&#xff0c;实现步骤如下&#xff1a; [1] 在index.html中添加如下代码<meta name"format-detection" content"telephoneyes" />[2] 点击按钮调用函数callPhone (phoneNumber) {window.locat…
阅读更多...
Java与Modbus-TCP/IP网络通讯

Java与Modbus-TCP/IP网络通讯

1.需求样例 举例5&#xff1a;浮点数参数读取&#xff08;读取温度测量值&#xff09;查看参数列表&#xff0c;温度测量值地址为320&#xff0c;根据Modbus协议&#xff0c;读取参数地址转换为16进制为&#xff1a;00H A0H&#xff0c;读取长度为2个字&#xff1a;00H 02H。 …
阅读更多...
腾讯云服务器价格表大全_轻量服务器_CVM云服务器报价明细

腾讯云服务器价格表大全_轻量服务器_CVM云服务器报价明细

腾讯云服务器租用费用表&#xff1a;轻量应用服务器2核2G4M带宽112元一年&#xff0c;540元三年、2核4G5M带宽218元一年&#xff0c;2核4G5M带宽756元三年、云服务器CVM S5实例2核2G配置280.8元一年、GPU服务器GN10Xp实例145元7天&#xff0c;腾讯云服务器网长期更新腾讯云轻量…
阅读更多...
在Ubuntu上启动一个简单的用户登录接口服务

在Ubuntu上启动一个简单的用户登录接口服务

一个简单的用户登录接口 我使用 Python 和 Flask 框架来创建这个接口 首先&#xff0c;确保你已经安装了 Python 和 Flask。如果没有安装&#xff0c;可以通过以下命令在 Ubuntu 上安装&#xff1a; sudo apt update sudo apt install python3 python3-pip pip3 install Fla…
阅读更多...
KASLR 内核随机地址配置开启

KASLR 内核随机地址配置开启

CONFIG_RANDOMIZE_BASE kernel features ---> Randomize of module region independently from the core kernel 参考链接&#xff1a;KASLR 内核动态地址 - kk Blog —— 通用基础 (abcdxyzk.github.io)
阅读更多...
5G网关如何提升智慧乡村农业生产效率

5G网关如何提升智慧乡村农业生产效率

得益于我国持续推进5G建设&#xff0c;截至今年5月&#xff0c;我国5G基站总数已达284.4万个&#xff0c;覆盖全国所有地级市、县城城区和9成以上的乡镇镇区&#xff0c;实现“镇镇通5G”&#xff0c;全面覆盖了从城市到农村的延伸。 依托5G网络的技术优势&#xff0c;智慧乡村…
阅读更多...
5.6.webrtc三大线程

5.6.webrtc三大线程

那今天呢&#xff1f;我们来介绍一下web rtc的三大线程&#xff0c;那为什么要介绍这三大线程呢&#xff1f;最关键的原因在于web rtc的所有其他线程都是由这三大线程所创建的。那当我们将这三个线程理解清楚之后呢&#xff1f;我们就知道其他线程与它们之间是怎样关系&#xf…
阅读更多...
机器学习之Adam（Adaptive Moment Estimation）自适应学习率

机器学习之Adam（Adaptive Moment Estimation）自适应学习率

Adam&#xff08;Adaptive Moment Estimation&#xff09;是一种常用的优化算法&#xff0c;特别适用于训练神经网络和深度学习模型。它是一种自适应学习率的优化算法&#xff0c;可以根据不同参数的梯度信息来动态调整学习率&#xff0c;以提高训练的效率和稳定性。 Adam算法…
阅读更多...
如何提取视频的音频到手机？这个音频提取方法很简单

如何提取视频的音频到手机？这个音频提取方法很简单

提取视频中的音频可以帮助您获得视频的声音部分&#xff0c;而无需观看整个视频。这对于那些只想听视频的声音或想将视频的声音与其他音频内容混合使用的人来说非常方便。此外&#xff0c;提取音频也可以为需要创建音频剪辑或混音的音频制作者提供帮助。那么怎么提取呢&#xf…
阅读更多...
Java接入支付宝支付

Java接入支付宝支付

本文只接入了支付宝中的APP支付&#xff0c;如果要拓展更多支付方式的的话&#xff0c;请看文末补充 项目支付流程 前端发起创建订单请求后端接受请求创建订单&#xff0c;并将订单参数进行支付宝对应签名并返回前端拿到签名后调起支付宝支付 本文主要写的就是2的过程 前期准…
阅读更多...
报名倒计时！| 基于RflySim平台飞控底层算法开发专题培训（第二期）

报名倒计时！| 基于RflySim平台飞控底层算法开发专题培训（第二期）

RflySim 暑期学校 飞思实验室“基于RflySim平台飞控底层算法开发”系列专题培训第二期开启报名了&#xff01;专题培训由戴训华副教授以及飞思实验室学生&工程师团队主讲&#xff0c;采用“线上线下”集中授课形式&#xff0c;培训时间为8月28日-9月3日&#xff1b;课程内…
阅读更多...
基于XL32F003单片机的可控硅调光方案

基于XL32F003单片机的可控硅调光方案

可控硅调光是一种用于调节电源输出电压的技术&#xff0c;被广泛应用于各种场景。它主要通过改变波形的导通角度来调节输出电压的大小&#xff0c;从而实现对照明设备亮度的控制。在照明市场占据了很大的调光市场。 可控硅调光的兼容性强&#xff0c;应用范围广。例如&#xff…
阅读更多...
最新文章

Copyright @ 2022~2023