[MySQL 学习] Innodb锁系统(2)关键函数路径

本文涉及的产品
云数据库 RDS MySQL,集群系列 2核4GB
推荐场景:
搭建个人博客
RDS MySQL Serverless 基础系列,0.5-2RCU 50GB
云数据库 RDS MySQL,高可用系列 2核4GB
简介:

前提:

以下分析基于标准的配置选项:

tx_isolation = REPEATABLE-READ

innodb_locks_unsafe_for_binlog = OFF

lock->type_mode用来表示锁的类型,实际上lock->type_mode包含了几乎所有锁的模式信息,例如锁类型判断是X锁还是S锁 lock->type_mode &LOCK_TYPE_MASK

LOCK_MODE_MASK

0xFUL

用于表示锁模式掩码

LOCK_TYPE_MASK

0xF0UL

用于表示锁类型,LOCK_TABLE或者LOCK_REC

LOCK_WAIT

256

表示需要锁等待,还没有获得锁,只是在等待队列中等待

LOCK_ORDINARY

0

普通的next-key锁,锁记录,并锁记录前面的gap,这样可以防止幻读。

假设索引包括10,11,13,20,则next-key锁为:

(negative infinity, 10], (10, 11], (11, 13], (13, 20], (20, positive infinity)

我们经常在innodb_locks表中看到的supremum pseudo-record就是锁住了最大值往后的gap.

LOCK_GAP

512

只持有记录前的gap锁,例如,在一个gap上的x锁无法修改bit被设置的记录

在从索引记录链上移除记录时会加该类型的锁。

LOCK_REC_NOT_GAP

1024

也就是普通记录锁,只锁住记录,因此不会阻塞向该记录之前的gap中插入记录。

LOCK_INSERT_INTENTION

2048

插入意图锁,目的是让插入索引记录时等待,直到在gap上没有其他冲突的锁

记住,即使获得了等待的锁,也依然会持有插入意图锁

不同锁模式

enum lock_mode {

    LOCK_IS = 0, /* intention shared */

    LOCK_IX, /* intention exclusive */

    LOCK_S, /* shared */

    LOCK_X, /* exclusive */

    LOCK_AUTO_INC, /* locks the auto-inc counter of a table

            in an exclusive mode */

    LOCK_NONE, /* this is used elsewhere to note consistent read */

    LOCK_NUM = LOCK_NONE/* number of lock modes */

};

当使用唯一键或主键来检索数据时,gap锁是没有必要的(但如果查找的where条件中只包含了唯一索引的部分列时,则需要gap锁)

INSERT INTENTION锁在INSERT数据之前,它也是一种GAP锁,当多个事务同时插入记录到同一个索引gap时,如果不是GAP中的同一个位置,则无需等待。例如索引中有两个记录4和7,两个并发事务同时插入5和6,都会各自在获取记录排他锁之前先锁住INSERT INTENTION锁,但互相并不阻塞。

1.创建测试表

drop table section;

CREATE TABLE `section` (

  `id` int(11) NOT NULL AUTO_INCREMENT,

  `title` varchar(255) NOT NULL,

  `tree_left` int(11) DEFAULT NULL,

  `tree_right` int(11) DEFAULT NULL,

  `tree_level` int(11) DEFAULT NULL,

  PRIMARY KEY (`id`),

  KEY `tree_left` (`tree_left`) ,

  KEY `tree_right` (`tree_right`)

) ENGINE=InnoDB;


INSERT INTO `section` VALUES (‘1′, ‘root’, ‘1’, ’14’, ‘0’);

INSERT INTO `section` VALUES (‘4′, ‘left tree’, ‘8’, ’13’, ‘1’);

INSERT INTO `section` VALUES (’10’, ‘left tree3′, ’11’, ’11’, ‘3’);

INSERT INTO `section` VALUES (’11’, ‘right Tree’, ‘2’, ‘7’, ‘1’);

INSERT INTO `section` VALUES (’16’, ‘right Tree 2′, ‘3’, ‘6’, ‘2’);

INSERT INTO `section` VALUES (’27’, ‘right Tree 3′, ‘4’, ‘5’, ‘3’);

 

2.场景测试,目的是找出关键函数

断点:

lock_rec_create

sel_set_rec_lock

lock0lock.c:1050

 

a.根据主键值删除记录

delete from section where id =8;

这里会根据主键扫描,堆栈如下:

ha_innobase::index_read

 ->row_search_for_mysql

     |–>sel_set_rec_lock (第4280行)

          –>二级索引lock_sec_rec_read_check_and_lock

          –>聚集索引lock_clust_rec_read_check_and_lock

             ->lock_rec_lock

                   |–>lock_rec_lock_fast->lock_rec_lock_fast->lock_rec_create

                   |–>lock_rec_lock_slow


传递参数type_mode = 1027 =  3+1024 =  LOCK_X +LOCK_REC_NOT_GAP

lock->type_mode = (type_mode & ~LOCK_TYPE_MASK) | LOCK_REC = 1059 = LOCK_X | LOCK_REC_NOT_GAP | LOCK_REC

不过如果是根据范围(或者where条件不是确定主键时)来删除记录,则在主键记录上加LOCK_X锁(锁模式值为3)

b.根据二级索引值删除记录

delete from section where tree_left = 8;

首先根据二级索引查找记录,对二级索引记录加锁

ha_innobase::index_read->row_search_for_mysql->sel_set_rec_lock->lock_sec_rec_read_check_and_lock->lock_rec_lock->lock_rec_lock_fast->lock_rec_create

type_mode=3 = LOCK_X

lock->type_mode = (type_mode & ~LOCK_TYPE_MASK) | LOCK_REC = 35 = LOCK_REC | LOCK_X

第二次,根据二级索引记录回查聚集索引

row_sel_get_clust_rec_for_mysql->lock_clust_rec_read_check_and_lock->lock_rec_lock->lock_rec_lock_fast->lock_rec_create

type_mode=1027

lock->type_mode = LOCK_X | LOCK_REC_NOT_GAP | LOCK_REC

获得主键记录后,就可以执行更新了(row_update_for_mysql)

第三次,扫描下一条记录,看看是否满足条件。

ha_innobase::general_fetch->row_search_for_mysql->sel_set_rec_lock->lock_sec_rec_read_check_and_lock->lock_rec_lock->lock_rec_lock_slow->lock_rec_create

type_mode=515

lock->type_mode = 547 = LOCK_GAP | LOCK_X |  LOCK_REC

 

 

 

 

 



从show engine innodb status里的信息来看,也符合

TABLE LOCK table `test`.`section` trx id E1885D33 lock mode IX

RECORD LOCKS space id 109 page no 4 n bits 80 index `tree_left` of table `test`.`section` trx id E1885D33 lock_mode X

RECORD LOCKS space id 109 page no 3 n bits 80 index `PRIMARY` of table `test`.`section` trx id E1885D33 lock_mode X locks rec but not gap

RECORD LOCKS space id 109 page no 4 n bits 80 index `tree_left` of table `test`.`section` trx id E1885D33 lock_mode X locks gap before rec


c.二级索引上存在重复值

测试表:

drop table t1;

create table t1 (a int primary key , b int ,key(b));

insert into t1 values (1,10),(2,20),(3,20),(4,30);

delete from t1 where b = 20;

lock_sec_rec_read_check_and_lock->lock_rec_lock->lock_rec_lock_fast->lock_rec_create

heap_no=3

type_mode=3,lock->type_mode=35

row_sel_get_clust_rec_for_mysql->lock_clust_rec_read_check_and_lock->lock_rec_lock->lock_rec_lock_fast->lock_rec_create

type_mode=1027

lock->type_mode = 1059

row_update_for_mysql

继续查下一条数据。

sel_set_rec_lock->lock_sec_rec_read_check_and_lock->lock_rec_lock->lock_rec_lock_fast

type_mode=3,

row_sel_get_clust_rec_for_mysql->lock_clust_rec_read_check_and_lock->lock_rec_lock->lock_rec_lock_fast

mode=1027

row_update_for_mysql

row_search_for_mysql

lock_sec_rec_read_check_and_lock->lock_rec_lock->lock_rec_lock_slow->lock_rec_create

type_mode=547

show engine innodb status的结果:

4 lock struct(s), heap size 1248, 5 row lock(s), undo log entries 2

MySQL thread id 389, OS thread handle 0x7fa35e53c700, query id 1545 localhost root

TABLE LOCK table `test`.`t1` trx id E1885D8E lock mode IX

RECORD LOCKS space id 118 page no 4 n bits 72 index `b` of table `test`.`t1` trx id E1885D8E lock_mode X

RECORD LOCKS space id 118 page no 3 n bits 72 index `PRIMARY` of table `test`.`t1` trx id E1885D8E lock_mode X locks rec but not gap

RECORD LOCKS space id 118 page no 4 n bits 72 index `b` of table `test`.`t1` trx id E1885D8E lock_mode X locks gap before rec

 

因此,如果事务不提交的话,试图插入tree_left值为[4,11)范围的值都会被阻塞掉。


c.二级索引上存在重复值

测试表:

drop table t1;

create table t1 (a int primary key , b int ,key(b));

insert into t1 values (1,10),(2,20),(3,20),(4,30);

delete from t1 where b = 20;

lock_sec_rec_read_check_and_lock->lock_rec_lock->lock_rec_lock_fast->lock_rec_create

heap_no=3

type_mode=3,lock->type_mode=35

row_sel_get_clust_rec_for_mysql->lock_clust_rec_read_check_and_lock->lock_rec_lock->lock_rec_lock_fast->lock_rec_create

type_mode=1027

lock->type_mode = 1059

row_update_for_mysql

继续查下一条数据。

sel_set_rec_lock->lock_sec_rec_read_check_and_lock->lock_rec_lock->lock_rec_lock_fast

type_mode=3,

row_sel_get_clust_rec_for_mysql->lock_clust_rec_read_check_and_lock->lock_rec_lock->lock_rec_lock_fast

mode=1027

row_update_for_mysql

row_search_for_mysql

lock_sec_rec_read_check_and_lock->lock_rec_lock->lock_rec_lock_slow->lock_rec_create

type_mode=547

show engine innodb status的结果:

4 lock struct(s), heap size 1248, 5 row lock(s), undo log entries 2

MySQL thread id 389, OS thread handle 0x7fa35e53c700, query id 1545 localhost root

TABLE LOCK table `test`.`t1` trx id E1885D8E lock mode IX

RECORD LOCKS space id 118 page no 4 n bits 72 index `b` of table `test`.`t1` trx id E1885D8E lock_mode X

RECORD LOCKS space id 118 page no 3 n bits 72 index `PRIMARY` of table `test`.`t1` trx id E1885D8E lock_mode X locks rec but not gap

RECORD LOCKS space id 118 page no 4 n bits 72 index `b` of table `test`.`t1` trx id E1885D8E lock_mode X locks gap before rec

 

这里只是通过几个gdb挖掘出几个关键的函数,下回将开始深入分析这些函数的执行流程。

相关实践学习
如何快速连接云数据库RDS MySQL
本场景介绍如何通过阿里云数据管理服务DMS快速连接云数据库RDS MySQL,然后进行数据表的CRUD操作。
全面了解阿里云能为你做什么
阿里云在全球各地部署高效节能的绿色数据中心,利用清洁计算为万物互联的新世界提供源源不断的能源动力,目前开服的区域包括中国(华北、华东、华南、香港)、新加坡、美国(美东、美西)、欧洲、中东、澳大利亚、日本。目前阿里云的产品涵盖弹性计算、数据库、存储与CDN、分析与搜索、云通信、网络、管理与监控、应用服务、互联网中间件、移动服务、视频服务等。通过本课程,来了解阿里云能够为你的业务带来哪些帮助     相关的阿里云产品:云服务器ECS 云服务器 ECS(Elastic Compute Service)是一种弹性可伸缩的计算服务,助您降低 IT 成本,提升运维效率,使您更专注于核心业务创新。产品详情: https://www.aliyun.com/product/ecs
目录
打赏
0
0
0
0
10011
分享
相关文章
MySQL底层概述—2.InnoDB磁盘结构
InnoDB磁盘结构主要包括表空间(Tablespaces)、数据字典(Data Dictionary)、双写缓冲区(Double Write Buffer)、重做日志(redo log)和撤销日志(undo log)。其中,表空间分为系统、独立、通用、Undo及临时表空间,分别用于存储不同类型的数据。数据字典从MySQL 8.0起不再依赖.frm文件,转而使用InnoDB引擎存储,支持事务原子性DDL操作。
281 100
MySQL底层概述—2.InnoDB磁盘结构
MySQL底层概述—1.InnoDB内存结构
本文介绍了InnoDB引擎的关键组件和机制,包括引擎架构、Buffer Pool、Page管理机制、Change Buffer、Log Buffer及Adaptive Hash Index。
312 97
MySQL底层概述—1.InnoDB内存结构
【YashanDB知识库】MySQL field 函数的改写方法
【YashanDB知识库】MySQL field 函数的改写方法
MySQL底层概述—10.InnoDB锁机制
本文介绍了:锁概述、锁分类、全局锁实战、表级锁(偏读)实战、行级锁升级表级锁实战、间隙锁实战、临键锁实战、幻读演示和解决、行级锁(偏写)优化建议、乐观锁实战、行锁原理分析、死锁与解决方案
167 24
MySQL底层概述—10.InnoDB锁机制
MySQL底层概述—5.InnoDB参数优化
本文介绍了MySQL数据库中与内存、日志和IO线程相关的参数优化,旨在提升数据库性能。主要内容包括: 1. 内存相关参数优化:缓冲池内存大小配置、配置多个Buffer Pool实例、Chunk大小配置、InnoDB缓存性能评估、Page管理相关参数、Change Buffer相关参数优化。 2. 日志相关参数优化:日志缓冲区配置、日志文件参数优化。 3. IO线程相关参数优化: 查询缓存参数、脏页刷盘参数、LRU链表参数、脏页刷盘相关参数。
127 12
MySQL底层概述—5.InnoDB参数优化
MySQL底层概述—4.InnoDB数据文件
本文介绍了InnoDB表空间文件结构及其组成部分,包括表空间、段、区、页和行。表空间是最高逻辑层,包含多个段;段由若干个区组成,每个区包含64个连续的页,页用于存储多条行记录。文章还详细解析了Page结构,分为通用部分(文件头与文件尾)、数据记录部分和页目录部分。此外,文中探讨了行记录格式,包括四种行格式(Redundant、Compact、Dynamic和Compressed),重点介绍了Compact行记录格式及其溢出机制。最后,文章解释了不同行格式的特点及应用场景,帮助理解InnoDB存储引擎的工作原理。
MySQL底层概述—4.InnoDB数据文件
MySQL底层概述—3.InnoDB线程模型
InnoDB存储引擎采用多线程模型,包含多个后台线程以处理不同任务。主要线程包括:IO Thread负责读写数据页和日志;Purge Thread回收已提交事务的undo日志;Page Cleaner Thread刷新脏页并清理redo日志;Master Thread调度其他线程,定时刷新脏页、回收undo日志、写入redo日志和合并写缓冲。各线程协同工作,确保数据一致性和高效性能。
MySQL底层概述—3.InnoDB线程模型
【YashanDB知识库】MySQL field 函数的改写方法
本文来自YashanDB官网,介绍将MySQL的FIELD函数改写到YashanDB的方法。MySQL中,FIELD函数用于自定义排序;而在YashanDB中,可使用DECODE或CASE语句实现类似功能。示例展示对表`t1`按指定顺序排序的过程,提供两种改写方式,结果均符合预期。
MySQL原理简介—2.InnoDB架构原理和执行流程
本文介绍了MySQL中更新语句的执行流程及其背后的机制,主要包括: 1. **更新语句的执行流程**:从SQL解析到执行器调用InnoDB存储引擎接口。 2. **Buffer Pool缓冲池**:缓存磁盘数据,减少磁盘I/O。 3. **Undo日志**:记录更新前的数据,支持事务回滚。 4. **Redo日志**:确保事务持久性,防止宕机导致的数据丢失。 5. **Binlog日志**:记录逻辑操作,用于数据恢复和主从复制。 6. **事务提交机制**:包括redo日志和binlog日志的刷盘策略,确保数据一致性。 7. **后台IO线程**:将内存中的脏数据异步刷入磁盘。
156 12
Mysql-常用函数及其用法总结
以上列举了MySQL中一些常用的函数及其用法。这些函数在日常的数据库操作中非常实用,能够简化数据查询和处理过程,提高开发效率。掌握这些函数的使用方法,可以更高效地处理和分析数据。
131 19

热门文章

最新文章