MySQL基础篇(06)：事务管理，锁机制案例详解

时间  2020-03-19
标签 mysql 基础 事务管理 机制 案例 详解 栏目 MySQL 繁體版
原文   原文链接

本文源码：GitHub·点这里 || GitEE·点这里mysql

1、锁概念简介

一、基础描述

锁机制核心功能是用来协调多个会话中多线程并发访问相同资源时，资源的占用问题。锁机制是一个很是大的模块，贯彻MySQL的几大核心难点模块：索引，锁机制，事务。这里是基于MySQL5.6演示的几种典型场景，对面MySQL这几块问题时，有分析流程和思路是比较关键的。在MySQL中常见这些锁概念：共享读锁、排它写锁 ; 表锁、行锁、间隙锁。git

二、存储引擎和锁

  • MyISAM引擎：基于读写两种模式，支持表级锁 ;
  • InnoDB引擎：支持行级别读写锁，跨行的间隙锁,InnoDB也支持表锁 ;

三、锁操做API

  • LOCK TABLE name [READ,WRITE] ;加表锁
  • UNLOCK TABLES ; 释放标所

2、MyISAM锁机制

一、基础描述

MySQL的表级锁有两种模式：共享读锁（Read-Lock）和排它写锁（Write-Lock）。针对MyISAM表的读操做，不会阻塞其余线程对同一表的读请求，但阻塞对同一表的写请求；针对MyISAM表的写操做，会阻塞其余线程对同一表的读和写操做；MyISAM引擎读写操做之间，以及写与写操做之间是串行化。当一次会话线程获取表的写锁后，只有当前持有锁的会话线程能够对表进行操做。其它线程的读、写操做都会等待，直到锁被释放为止。github

二、验证案例

基于上面的表锁机制特色，使用下面两个案例验证。算法

  • 基础表结构
CREATE TABLE `dc_user` (
  `id` int(11) NOT NULL AUTO_INCREMENT COMMENT 'id',
  `user_name` varchar(20) DEFAULT NULL COMMENT '用户名',
  `tell_phone` varchar(20) DEFAULT NULL COMMENT '手机号',
  PRIMARY KEY (`id`)
) ENGINE=MyISAM DEFAULT CHARSET=utf8 COMMENT='用户表';
CREATE TABLE `dc_user_info` (
  `user_id` int(11) NOT NULL COMMENT '用户ID',
  `city` varchar(20) DEFAULT NULL COMMENT '城市',
  `country` varchar(20) DEFAULT NULL COMMENT '国家',
  PRIMARY KEY (`user_id`)
) ENGINE=MyISAM DEFAULT CHARSET=utf8 COMMENT='用户信息表';
  • 共享读锁

会话窗口一sql

-- 一、加读锁
LOCK TABLE dc_user READ ;
-- 二、当前会话查询，OK
SELECT * FROM dc_user ;
-- 四、当前会话写入，Error
INSERT INTO dc_user (user_name,tell_phone) VALUES ('lock01','13267788998');
-- 六、查询其余表,Error
SELECT * FROM dc_user_info ;
-- 七、释放锁
UNLOCK TABLES ;

会话窗口二数据库

-- 三、其余会话查询，OK
SELECT * FROM dc_user ;
-- 五、其余会话写入，Error
INSERT INTO dc_user (user_name,tell_phone) VALUES ('lock01','13267788998');
-- 八、再次执行写入读取，OK
INSERT INTO dc_user (user_name,tell_phone) VALUES ('lock01','13267788998');
SELECT * FROM dc_user ;

这里验证表锁的共享读机制。api

  • 排它写锁

这里验证表锁的排它写机制。session

  • 查询锁争用

经过下面语句查看配置，多线程

show status like 'table%';

Table_locks_waited的值越大，锁争用状况越严重，效率则越低下。并发

三、并发写入问题

针对排它写锁的测试案例再说明：在必定条件下，MyISAM表也支持查询和插入操做的并发执行。经过配置系统变量concurrent_insert的值[0,1,2]，能够实现并发写入。

  • concurrent_insert=0，禁止并发写入;
  • concurrent_insert=1，默认配置AUTO，在MyISAM表中没有空洞，即表的中间没有被删除的行，例如[1,2,3],删除2以后[1,,3]，则容许在读表的同时，另外一个线程从表尾写入记录。
  • concurrent_insert=2，不管MyISAM表中有没有空洞，都容许在表尾并发插入记录。
    在下面的例子中，session_1得到了一个表的READ LOCAL锁，该线程能够对表进行查询操做，但不能对表进行更新操做；其余的线程（session_2），虽然不能对表进行删除和更新操做，但却能够对该表进行并发插入操做，这里假设该表中间不存在空洞。

四、优先级问题

MyISAM存储引擎的读锁和写锁是互斥的，读写操做是串行的。可是当一个读操做和写操做同时请求，写数据会优先得到锁，这一机制能够经过配置修改，指定配置参数low-priority-updates，使MyISAM引擎默认给予读请求以优先的权利。
经过执行命令SET

  • LOW_PRIORITY_UPDATES=1，使该会话的写操做优先级下降。
  • 指定INSERT、UPDATE、DELETE语句的LOW_PRIORITY属性，下降该语句的优先级。

五、表锁应用

数据一致性校验问题，好比销售量+剩余库存=货品总量，在校验时就要在一次会话中同时锁住订单表和库存表，省得在读取订单表的时候，库存表被修改，致使数据偏差出现。

3、InnoDB锁机制

一、事务基础概念

  • 事务概念

事务是指做为单个逻辑工做单元执行的一系列操做（SQL语句）。这些操做要么所有成功，要么所有不成功。

  • 事务特性ACID

原子性(Atomicity)：事务中的多个操做要么都成功要么都失败

一致性(consistency)：事务的执行的先后数据的完整性保持一致

隔离性(isolation)：事务执行的过程当中,不该该受到其余事务的干扰

持久性(durability)：事务一旦结束,数据就持久到数据库

  • 事务问题

脏读：一个事务读到另外一个事务没有提交的数据

不可重复读：一个事务先后屡次读取相同数据，数据内容不一致，update场景问题

虚读(幻读)：一个事务先后屡次读取，数据总量不一致，insert场景问题

  • 隔离级别

read uncommitted:事务能够读取另外一个未提交事务的数据。

read committed：事务要等另外一个事务提交后才能读取数据,解决脏读。

repeatable read：在开始读取数据时,事务开启,再也不容许修改操做,解决：脏读、不可重复读。

serializable：最高事务隔离级别，事务串行化顺序执行，解决脏读、不可重复读、幻读。可是效率低下，耗数据库性能。

二、锁机制描述

InnoDB与MyISAM的最大不一样有两点：一是支持事务TRANSACTION,二是采用了行级锁。行级锁与表级锁原本就有许多不一样之处，另外，事务的引入也带来新问题：并发，死锁等。

  • 共享锁：又称读锁。容许一个事务去读一行，阻止其余事务得到相同数据集的排他锁。若事务T对数据对象A加上共享锁，则事务T能够读A但不能修改A，其余事务只能再对A加共享锁，而不能加写锁，直到T释放A上的共享锁。这保证了其余事务能够读A，但在T释放A上的S锁以前不能对A作任何修改。

  • 排他锁：又称写锁。容许获取排他锁的事务更新数据，阻止其余事务取得相同的资源的共享读锁和排他锁。若事务T对数据对象A加上写锁，事务T能够读A也能够修改A，其余事务不能再对A加任何锁，直到T释放A上的写锁。

三、验证案例

  • 基础表结构
CREATE TABLE `dc_user_in01` (
  `id` int(11) DEFAULT NULL COMMENT 'id',
  `user_name` varchar(20) DEFAULT NULL COMMENT '用户名',
  `tell_phone` varchar(20) DEFAULT NULL COMMENT '手机号'
) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='用户表';

CREATE TABLE `dc_user_in02` (
  `id` int(11) NOT NULL AUTO_INCREMENT COMMENT 'id',
  `user_name` varchar(20) DEFAULT NULL COMMENT '用户名',
  `tell_phone` varchar(20) DEFAULT NULL COMMENT '手机号',
  PRIMARY KEY (`id`)
) ENGINE=INNODB DEFAULT CHARSET=utf8 COMMENT='用户表';

注意结构：表dc_user_in01主键没有索引。表dc_user_in02主键有索引，可是都使用INNODB存储引擎，下面验证案例会有不一样。

  • 无索引结构表

会话窗口一

-- 一、关闭自动提交
SET AUTOCOMMIT = 0 ;
-- 二、查询id=1，OK
SELECT * FROM dc_user_in01 WHERE id=1 ;
-- 三、添加写锁失败
SELECT * FROM dc_user_in01 
WHERE id=1 FOR UPDATE ;
-- 四、恢复事务提交
SET AUTOCOMMIT = 1 ;

会话窗口二

-- 一、关闭自动提交
SET AUTOCOMMIT = 0 ;
-- 二、查询id=2，OK
SELECT * FROM dc_user_in01 WHERE id=2 ;
-- 三、写入失败(等待)
INSERT INTO dc_user_in01 (id,user_name,tell_phone) 
VALUES (3,'lock01','13267788998');
-- 四、写锁失败(等待)
SELECT * FROM dc_user_in01 
WHERE id=2 FOR UPDATE ;
-- 五、恢复事务提交
SET AUTOCOMMIT=1 ;
  • 索引结构表

会话窗口一

-- 一、关闭自动提交
SET AUTOCOMMIT = 0 ;
-- 二、查询id=1，OK
SELECT * FROM dc_user_in02 WHERE id=1 ;
-- 三、添加写锁成功
SELECT * FROM dc_user_in02 WHERE id=1 FOR UPDATE ;
-- 执行到这里，再执行窗口2
-- 四、恢复事务提交
SET AUTOCOMMIT = 1 ;

会话窗口二

-- 一、关闭自动提交
SET AUTOCOMMIT = 0 ;
-- 二、查询id=2，OK
SELECT * FROM dc_user_in02 WHERE id=2 ;
-- 三、查询id=1，OK，加读锁
SELECT * FROM dc_user_in02 WHERE id=1 ;
-- 四、写入成功
INSERT INTO dc_user_in02 (user_name,tell_phone) VALUES ('lock01','13267788998');
-- 五、加写锁成功，id为2的
SELECT * FROM dc_user_in02 
WHERE id=2 FOR UPDATE ;
-- 六、加写锁失败(等待)，占用id为1的
SELECT * FROM dc_user_in02 WHERE id=1 FOR UPDATE ;
-- 七、恢复事务提交
SET AUTOCOMMIT=1 ;
  • 索引失效问题

这里要注意索引是否被使用问题，在不少查询中，可能由于种种缘由致使索引不执行。

explain SELECT * FROM dc_user_in02 WHERE id=1 ;
  • 查询锁争用
show status like 'innodb_row_lock%';

Innodb_row_lock_waits和Innodb_row_lock_time_avg的值越大，锁争用状况越严重，效率则越低下。

四、Next-Key锁

  • 官方文档说明

为了防止幻读，InnoDB使用了一种名为Next-Key锁定的算法，它将记录锁和间隙锁定结合在一块儿即：InnoDB在执行行级锁的时候，会用这种方式-扫描索引记录，会在符合索引条件的记录上加共享锁或者独占锁。

[Next-Key]=[Record-lock]+[Gap-lock]

若是说上面的几种锁机制给人的感受是昏天暗地，那个这个Next-Key算法就会叫人怀疑人生。

  • 验证案例

这里主要验证Gap-lock间隙锁的存在机制。

CREATE TABLE `dc_gap` (
  `id` int(11) NOT NULL AUTO_INCREMENT COMMENT 'id',
  `id_index` int(11) NOT NULL COMMENT 'index',
  PRIMARY KEY (`id`),
  KEY `id_index` (`id_index`)
) ENGINE=InnoDB AUTO_INCREMENT=7 DEFAULT CHARSET=utf8 COMMENT='间隙表';
INSERT INTO `dc_gap` (`id`, `id_index`) VALUES ('1', '2');
INSERT INTO `dc_gap` (`id`, `id_index`) VALUES ('3', '4');
INSERT INTO `dc_gap` (`id`, `id_index`) VALUES ('6', '7');
INSERT INTO `dc_gap` (`id`, `id_index`) VALUES ('8', '7');
INSERT INTO `dc_gap` (`id`, `id_index`) VALUES ('9', '9');

会话窗口一

-- 一、开始事务
START TRANSACTION ;
-- 三、锁定id_index=7的两条记录
SELECT * FROM dc_gap 
WHERE id_index=7 FOR UPDATE ;
-- 九、提交
COMMIT ;

会话窗口二

-- 二、开始事务
START TRANSACTION ;
-- 四、写入等待,id_index=6
INSERT INTO `dc_gap` (`id`, `id_index`) VALUES ('4', '6');
-- 五、写入等待,id_index=4
INSERT INTO `dc_gap` (`id`, `id_index`) VALUES ('4', '4');
-- 六、写入成功,id_index=3
INSERT INTO `dc_gap` (`id`, `id_index`) 
VALUES ('4', '3');
-- 七、写入等待,id_index=9
INSERT INTO `dc_gap` (`id`, `id_index`) VALUES ('7', '9');
-- 八、写入成功,id_index=10
INSERT INTO `dc_gap` (`id`, `id_index`) VALUES ('7', '10');

7向上到4有间隙，7向下到9有间隙，因此间隙锁定[4,9]，且包含首尾值。

五、Dead-Lock锁

  • 基础描述

两个或者多个事务在同一个资源上相互占用，并请求锁定对方占用的资源，从而致使死循环现象，也就是死锁。

  • 验证案例

会话窗口一

-- 一、开启事务
START TRANSACTION ;
-- 三、占用id=6的资源
SELECT * FROM dc_gap WHERE id=6 FOR UPDATE ;
-- 五、占用id=9的资源等待
SELECT * FROM dc_gap WHERE id=9 FOR UPDATE ;

会话窗口二

-- 二、开启事务
START TRANSACTION ;
-- 四、占用id=9的资源
SELECT * FROM dc_gap WHERE id=9 FOR UPDATE ;
-- 六、占用id=6的资源抛死锁
SELECT * FROM dc_gap WHERE id=6 FOR UPDATE ;

补刀一句：数据库实现各类死锁检测机制，或者死锁超时等待结束，InnoDB存储引擎在检测到死锁后，会当即返回错误，否则两个事务会隔空对望，一眼万年。

注意：死锁在事务型业务中，是没法绝对避免的，锁定资源少，粒度细，尽可能避免该状况出现。

4、源代码地址

GitHub·地址
https://github.com/cicadasmile/mysql-data-base
GitEE·地址
https://gitee.com/cicadasmile/mysql-data-base

相关文章
相关标签/搜索
每日一句
    每一个你不满意的现在，都有一个你没有努力的曾经。
本站公众号
   欢迎关注本站公众号,获取更多信息
联系我们 最近搜索 最新文章 沪ICP备13005482号-10 MyBatis教程 SQL 教程 MySQL教程 Java 教程 Thymeleaf 教程 Hibernate教程 Spring教程 Redis教程