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

前提:

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

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挖掘出几个关键的函数,下回将开始深入分析这些函数的执行流程。

时间: 2024-11-17 09:06:06

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

[MySQL学习] Innodb锁系统(3)关键结构体及函数

1.锁对象的定义: 关键结构体: UNIV_INTERN lock_sys_t* lock_sys = NULL; lock_sys是一个全局变量,用于控制整个Innodb锁系统的全部锁结构,其对应的结构体为lock_sys_t,该结构体只包含两个成员: struct lock_sys_struct{     hash_table_t* rec_hash;     ulint rec_num; }; 从函数lock_rec_create可以很容易看出这两个变量的作用: quoted code:

[MySQL 学习] Innodb锁系统(1)之如何阅读死锁日志

前言: 最近经常碰到死锁问题,由于对这块代码不是很熟悉,而常持有对文档怀疑的观点.决定从几个死锁问题着手,好好把Innodb锁系统的代码过一遍. 以下的内容不敢保证完全正确.只是我系统学习的过程. /////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////// 最近有同学发现,走二级索引删除数据时,两条delete

[MySQL学习] Innodb锁系统(4) Insert/Delete 锁处理及死锁示例分析

A.INSERT 插入操作在函数btr_cur_optimistic_insert->btr_cur_ins_lock_and_undo->lock_rec_insert_check_and_lock这里进行锁的判断,我们简单的看看这个函数的流程: 1.首先先看看欲插入记录之后的数据上有没有锁,    next_rec = page_rec_get_next_const(rec);    next_rec_heap_no = page_rec_get_heap_no(next_rec);  

Mysql学习笔记(四)字符串函数

原文:Mysql学习笔记(四)字符串函数 PS:终于看完了字符串函数,心都快碎了...涉及的函数真是太多了...感觉这里的字符串函数和JAVA里的基本都差不多了...基本上算是掌握了,但是想全记住那是不太可能的... 学习内容: 字符串函数的掌握和应用.. ASCii(str) 返回字符串的最左边的ascii码值..如果str为NULL,那么返回NULL...如果字符串为0,那么返回也为0...   mysql>select ascii('2'); mysql>select ascii('dx

【MySQL】InnoDB锁机制之二

一 前言    之前的文章<InnoDB锁机制之一>介绍了InnoDB锁中的三种锁:record lock, gap lock,next-key lock ,本文继续介绍另外两种锁 Insert Intention Locks和AUTO-INC Locks二 常见的锁类型2.1 根据锁持有的时间粒度,分为 1. 内存级别:类似mutex,很快释放 2. 语句级别:statement结束,释放 3. 事务级别:transaction提交或者回滚才释放 4. 会话级别:session级别,连接断开

[MySQL学习] Innodb change buffer(2) 相关函数及流程

简单的代码跟踪,顺便弄清了之前一直困惑的bp->watch的用途.... //////////////////////////////// A.相关结构体 在介绍ibuf在Innodb中的使用前,我们先介绍下相关的结构体及全局变量. 我们知道通过Ibuf可以缓冲多种操作类型,每种操作类型,在内部都有一个宏与之对应: IBUF_OP_INSERT IBUF_OP_DELETE_MARK IBUF_OP_DELETE 至于对update操作的缓冲,由于二级索引记录的更新是先delete-mark,再

[MySQL学习] Innodb change buffer(1)之初识篇

从MySQL5.5版本开始,Insert buffer更名为change buffer,除了缓冲对二级索引的insert操作,还包括update/delete/后台purge操作,由参数innodb_change_buffering来控制.因此这里统一称为change buffer. ////////////////////////////////////////////////////////// 当更新/插入的非聚集索引的数据所对应的页不在内存中时(对非聚集索引的更新操作通常会带来随机IO)

高性能MySql学习笔记——锁、事务、隔离级别(转)

为什么需要锁? 因为数据库要解决并发控制问题.在同一时刻,可能会有多个客户端对Table1.rown进行操作,比如有的在读取该行数据,其他的尝试去删除它.为了保证数据的一致性,数据库就要对这种并发操作进行控制,因此就有了锁的概念. 锁的分类 从对数据操作的类型(读\写)分 读锁(共享锁):针对同一块数据,多个读操作可以同时进行而不会互相影响. 写锁(排他锁):当当前写操作没有完成前,它会阻断其他写锁和读锁. 从锁定的数据范围分 表锁 行锁 为了尽可能提高数据库的并发度,每次锁定的数据范围越小越好

[MySQL 学习] Innodb Optimistic Delete 简述

接口函数是btr_cur_optimistic_delete Innodb的Optimistic Delete操作主要是由purge线程来进行的,用户线程仅仅做了删除标记(包括删除记录,更新二级索引以及更新主键), 另外如果插入/更新操作回滚了,用户也会调用到函数btr_cur_optimistic_delete 例如回滚insert操作的调用栈为 trx_general_rollback_for_mysql–>-..->row_undo->row_undo_ins->row_un