百木园-与人分享,
就是让自己快乐。

MySQL学习笔记

作者: Grey

原文地址:MySQL学习笔记

说明

注:本文中的SQL语句如果用到了特定方言,都是基于MySQL数据库。

一条SQL的执行流程

image

如果是查询语句,会走如上流程图,如果是更新语句,同样要走如上逻辑,同时更新语句会把这个表的查询缓存结果都清空。接下来,分析器会通过词法和语法解析知道这是一条更新语句。优化器决定要使用 ID 这个索引。然后,执行器负责具体执行,找到这一行,然后更新。与查询流程不一样的是,更新流程还涉及两个重要的日志模块:redo log(重做日志)和 binlog(归档日志)

Redo Log VS BinLog

Redo Log是引擎层日志

使用了WAL技术,先写日志,再写磁盘,当有一条记录需要更新的时候,InnoDB 引擎就会先把记录写到 redo log(粉板)里面,并更新内存,这个时候更新就算完成了。同时,InnoDB 引擎会在适当的时候,将这个操作记录更新到磁盘里面,而这个更新往往是在系统比较空闲的时候做

redo log是固定大小的,可以配置一组4个文件,每个文件大小1GB,那么可以记录4G记录。

有了 redo log,InnoDB 就可以保证即使数据库发生异常重启,之前提交的记录都不会丢失,这个能力称为 crash-safe。

binlog是Server层日志

  • redo log 是 InnoDB 引擎特有的;binlog 是 MySQL 的 Server 层实现的,所有引擎都可以使用。
  • redo log 是物理日志,记录的是“在某个数据页上做了什么修改”;binlog 是逻辑日志,记录的是这个语句的原始逻辑,比如“给 ID=2 这一行的 c 字段加 1 ”。redo log 是循环写的,空间固定会用完;
  • binlog 是可以追加写入的。“追加写”是指 binlog 文件写到一定大小后会切换到下一个,并不会覆盖以前的日志。
  • 所以,即便有了redo log,binlog还不能去掉,一个原因是,redolog只有InnoDB有,别的引擎没有。另一个原因是,redolog是循环写的,不持久保存,binlog的“归档”这个功能,redolog是不具备的。

    两阶段提交

    MySQL在执行这段更新操作的时候:

    update T set c=c+1 where ID=2;

    image

    图片引用自:MySQL实战45讲

    操作过程如上图: 图中浅色框表示是在 InnoDB 内部执行的,深色框表示是在执行器中执行的。最后三步将 redo log 的写入拆成了两个步骤:prepare 和 commit,这就是\"两阶段提交\"。

    为什么要使用两阶段提交?用前面的 update 语句来做例子。假设当前 ID=2 的行,字段 c 的值是 0,再假设执行 update 语句过程中在写完第一个日志后,第二个日志还没有写完期间发生了 crash,会出现什么情况呢?

  • 先写 redo log 后写 binlog。假设在 redo log 写完,binlog 还没有写完的时候,MySQL 进程异常重启。由于我们前面说过的,redo log 写完之后,系统即使崩溃,仍然能够把数据恢复回来,所以恢复后这一行 c 的值是 1。但是由于 binlog 没写完就 crash 了,这时候 binlog 里面就没有记录这个语句。因此,之后备份日志的时候,存起来的 binlog 里面就没有这条语句。然后你会发现,如果需要用这个 binlog 来恢复临时库的话,由于这个语句的 binlog 丢失,这个临时库就会少了这一次更新,恢复出来的这一行 c 的值就是 0,与原库的值不同。

  • 先写 binlog 后写 redo log。如果在 binlog 写完之后 crash,由于 redo log 还没写,崩溃恢复以后这个事务无效,所以这一行 c 的值是 0。但是 binlog 里面已经记录了“把 c 从 0 改成 1”这个日志。所以,在之后用 binlog 来恢复的时候就多了一个事务出来,恢复出来的这一行 c 的值就是 1,与原库的值不同。

  • 可以看到,如果不使用“两阶段提交”,那么数据库的状态就有可能和用它的日志恢复出来的库的状态不一致。

    redo log 用于保证 crash-safe 能力。innodb_flush_log_at_trx_commit 这个参数设置成 1 的时候,表示每次事务的 redo log 都直接持久化到磁盘。这个参数我建议你设置成 1,这样可以保证 MySQL 异常重启之后数据不丢失。

    sync_binlog 这个参数设置成 1 的时候,表示每次事务的 binlog 都持久化到磁盘。这个参数我也建议你设置成 1,这样可以保证 MySQL 异常重启之后 binlog 不丢失。

    关于DDL

    DDL 的英文全称是 Data Definition Language,中文是数据定义语言。它定义了数据库的结构和数据表的结构。在 DDL 中,我们常用的功能是增删改,分别对应的命令是 CREATE、DROP 和 ALTER。

    需要注意的是:在执行 DDL 的时候,不需要 COMMIT,就可以完成执行任务。

    排序规则

    排序规则是utf8_general_ci,代表对大小写不敏感。

    如果设置为utf8_bin,代表对大小写敏感。

    DISTINCT

    DISTINCT其实是对后面所有列名的组合进行去重

    SELECT DISTINCT attack_range, name FROM heros

    其实是对(attack_range,name)这个组合去重。

    约束返回结果的数量

    另外在查询过程中,我们可以约束返回结果的数量,使用 LIMIT 关键字。

    SELECT name, hp_max FROM heros ORDER BY hp_max DESC LIMIT 5

    在不同的 DBMS 中使用的关键字可能不同。在 MySQL、PostgreSQL、MariaDB 和 SQLite 中使用 LIMIT 关键字,而且需要放到 SELECT 语句的最后面。如果是 SQL Server 和 Access,需要使用 TOP 关键字,比如:

    SELECT TOP 5 name, hp_max FROM heros ORDER BY hp_max DESC

    如果是 DB2,使用FETCH FIRST 5 ROWS ONLY这样的关键字:

    SELECT name, hp_max FROM heros ORDER BY hp_max DESC FETCH FIRST 5 ROWS ONLY

    如果是 Oracle,你需要基于 ROWNUM 来统计行数:

    SELECT name, hp_max FROM heros WHERE ROWNUM <=5 ORDER BY hp_max DESC

    需要说明的是,这条语句是先取出来前 5 条数据行,然后再按照 hp_max 从高到低的顺序进行排序, 如果这样写:

    SELECT name, hp_max FROM (SELECT name, hp_max FROM heros ORDER BY hp_max) WHERE ROWNUM <=5

    就表示先执行查询结果,再来过滤结果中的前五条。

    WHERE语句中 AND 和 OR优先级

    WHERE 子句中同时出现 AND 和 OR 操作符的时候,你需要考虑到执行的先后顺序,也就是两个操作符执行的优先级。一般来说 () 优先级最高,其次优先级是 AND,然后是 OR。

    SQL中的命名规范

    MySQL 在 Linux 的环境下,数据库名、表名、变量名是严格区分大小写的,而字段名是忽略大小写的。
    而 MySQL 在 Windows 的环境下全部不区分大小写。

    SQL编写的一个规范:

    • 数据库名、表名、表别名、字段名、字段别名等都小写
    • SQL保留字、函数名、绑定变量等都大写
    • 数据表的字段名推荐采用下划线命名
    • SQL语句必须以分号结尾

    COUNT(字段) , COUNT(*) 和 COUNT(1)

    COUNT(字段)会忽略字段值值为NULL的数据行,而COUNT( * )和COUNT(1)只是统计数据行数,不管某个字段是否为NULL。

    COUNT(*)会因为记录数量增多而变的查询很慢,此时可以通过把COUNT(*)的值存在一个单独的表里面,并且把插入记录/删除记录和更新数量放在同一个事务中,即可准确快速得到COUNT(*)的值。

    AVG、MAX、MIN等聚集函数会自动忽略值为NULL的数据行。

    对于count(主键 id) 来说,InnoDB 引擎会遍历整张表,把每一行的 id 值都取出来,返回给 server 层。server 层拿到 id 后,判断是不可能为空的,就按行累加。
    对于 count(1) 来说,InnoDB 引擎遍历整张表,但不取值。server 层对于返回的每一行,放一个数字“1”进去,判断是不可能为空的,按行累加。单看这两个用法的差别的话,你能对比出来,count(1) 执行得要比 count(主键 id) 快。因为从引擎返回 id 会涉及到解析数据行,以及拷贝字段值的操作。

    对于 count(字段) 来说:如果这个“字段”是定义为 not null 的话,一行行地从记录里面读出这个字段,判断不能为 null,按行累加;
    如果这个“字段”定义允许为 null,那么执行的时候,判断到有可能是 null,还要把值取出来再判断一下,不是 null 才累加。

    count(*) 是例外,并不会把全部字段取出来,而是专门做了优化,不取值。count(*) 肯定不是 null,按行累加。

    所以结论是:按照效率排序的话,count(字段)<count(主键 id)<count(1)≈count(*),所以我建议你,尽量使用 count(*)。

    关联子查询和非关联子查询

    可以依据子查询是否执行多次,从而将子查询划分为关联子查询和非关联子查询。子查询从数据表中查询了数据结果,如果这个数据结果只执行一次,然后这个数据结果作为主查询的条件进行执行,那么这样的子查询叫做非关联子查询。同样,如果子查询需要执行多次,即采用循环的方式,先从外部查询开始,每次都传入子查询进行查询,然后再将结果反馈给外部,这种嵌套的执行方式就称为关联子查询

    一个非关联子查询的例子:

    SELECT player_name, height FROM player WHERE height = (SELECT max(height) FROM player)

    一个关联子查询的例子:

    SELECT player_name, height, team_id FROM player AS a WHERE height > (SELECT avg(height) FROM player AS b WHERE a.team_id = b.team_id)

    (NOT) EXISTS子查询

    SELECT player_id, team_id, player_name FROM player WHERE EXISTS (SELECT player_id FROM player_score WHERE player.player_id = player_score.player_id)

    IN VS EXISTS

    SELECT * FROM A WHERE cc IN (SELECT cc FROM B)

    SELECT * FROM A WHERE EXIST (SELECT cc FROM B WHERE B.cc=A.cc)

    实际上在查询过程中,在我们对 cc 列建立索引的情况下,我们还需要判断表 A 和表 B 的大小。在这里例子当中,表 A 指的是 player 表,表 B 指的是 player_score 表。如果表 A 比表 B 大,那么 IN 子查询的效率要比 EXIST 子查询效率高,因为这时 B 表中如果对 cc 列进行了索引,那么 IN 子查询的效率就会比较高。同样,如果表 A 比表 B 小,那么使用 EXISTS 子查询效率会更高,因为我们可以使用到 A 表中对 cc 列的索引,而不用从 B 中进行 cc 列的查询。
    当 A 小于 B 时,用 EXISTS。因为 EXISTS 的实现,相当于外表循环,实现的逻辑类似于:

    for i in A
    for j in B
    if j.cc == i.cc then ...

    当 B 小于 A 时用 IN,因为实现的逻辑类似于:

    for i in B
    for j in A
    if j.cc == i.cc then ...

    哪个表小就用哪个表来驱动,A 表小就用 EXISTS,B 表小就用 IN。

    其他一些子查询的关键字:EXISTS、IN、ANY、ALL 和 SOME

    函数

    一个简单的函数例子:Leetcode 177. Nth Highest Salary

    CREATE FUNCTION getNthHighestSalary(N INT) RETURNS INT
    BEGIN
    SET N = N - 1;
    RETURN (
    SELECT DISTINCT Salary FROM Employee GROUP BY Salary
    ORDER BY Salary DESC LIMIT 1 OFFSET N
    );
    END

    Employee表数据如下:

    +----+--------+
    | Id | Salary |
    +----+--------+
    | 1 | 100 |
    | 2 | 200 |
    | 3 | 300 |
    +----+--------+

    函数调用:

    SELECT getNthHighestSalary(3);

    结果:

    +------------------------+
    | getNthHighestSalary(3) |
    +------------------------+
    | 100 |
    +------------------------+

    存储过程

    DELIMITER //
    CREATE PROCEDURE `add_num`(IN n INT)
    BEGIN
    DECLARE i INT;
    DECLARE sum INT;

    SET i = 1;
    SET sum = 0;
    WHILE i <= n DO
    SET sum = sum + i;
    SET i = i +1;
    END WHILE;
    SELECT sum;
    END //
    DELIMITER ;

    调用

    CALL add_num(10);

    另一个例子

    CREATE PROCEDURE `get_hero_scores`(
    OUT max_max_hp FLOAT,
    OUT min_max_mp FLOAT,
    OUT avg_max_attack FLOAT,
    s VARCHAR(255)
    )
    BEGIN
    SELECT MAX(hp_max), MIN(mp_max), AVG(attack_max) FROM heros WHERE role_main = s INTO max_max_hp, min_max_mp, avg_max_attack;
    END

    调用

    CALL get_hero_scores(@max_max_hp, @min_max_mp, @avg_max_attack, \'战士\');
    SELECT @max_max_hp, @min_max_mp, @avg_max_attack;

    如何使用游标

    CREATE PROCEDURE `calc_hp_max`()
    BEGIN
    -- 创建接收游标的变量
    DECLARE hp INT;
    -- 创建总数变量
    DECLARE hp_sum INT DEFAULT 0;
    -- 创建结束标志变量
    DECLARE done INT DEFAULT false;
    -- 定义游标
    DECLARE cur_hero CURSOR FOR SELECT hp_max FROM heros;
    -- 指定游标循环结束时的返回值
    DECLARE CONTINUE HANDLER FOR NOT FOUND SET done = true;

    OPEN cur_hero;
    read_loop:LOOP
    FETCH cur_hero INTO hp;
    -- 判断游标的循环是否结束
    IF done THEN
    LEAVE read_loop;
    END IF;
    SET hp_sum = hp_sum + hp;
    END LOOP;
    CLOSE cur_hero;
    SELECT hp_sum;
    END

    更复杂的一个例子

    CREATE PROCEDURE `alter_attack_growth`()
    BEGIN
    -- 创建接收游标的变量
    DECLARE temp_id INT;
    DECLARE temp_growth, temp_max, temp_start, temp_diff FLOAT;
    -- 创建结束标志变量
    DECLARE done INT DEFAULT false;
    -- 定义游标
    DECLARE cur_hero CURSOR FOR SELECT id, attack_growth, attack_max, attack_start FROM heros;
    -- 指定游标循环结束时的返回值
    DECLARE CONTINUE HANDLER FOR NOT FOUND SET done = true;

    OPEN cur_hero;
    FETCH cur_hero INTO temp_id, temp_growth, temp_max, temp_start;
    REPEAT
    IF NOT done THEN
    SET temp_diff = temp_max - temp_start;
    IF temp_growth < 5 THEN
    IF temp_diff > 200 THEN
    SET temp_growth = temp_growth * 1.1;
    ELSEIF temp_diff >= 150 AND temp_diff <=200 THEN
    SET temp_growth = temp_growth * 1.08;
    ELSEIF temp_diff < 150 THEN
    SET temp_growth = temp_growth * 1.07;
    END IF;
    ELSEIF temp_growth >=5 AND temp_growth <=10 THEN
    SET temp_growth = temp_growth * 1.05;
    END IF;
    UPDATE heros SET attack_growth = ROUND(temp_growth,3) WHERE id = temp_id;
    END IF;
    FETCH cur_hero INTO temp_id, temp_growth, temp_max, temp_start;
    UNTIL done = true END REPEAT;

    CLOSE cur_hero;
    END

    自动提交(autocommit)

    set autocommit =0; //关闭自动提交

    set autocommit =1; //开启自动提交

    CREATE TABLE test(name varchar(255), PRIMARY KEY (name)) ENGINE=InnoDB;
    BEGIN;
    INSERT INTO test SELECT \'关羽\';
    COMMIT;
    BEGIN;
    INSERT INTO test SELECT \'张飞\';
    INSERT INTO test SELECT \'张飞\';
    ROLLBACK;
    SELECT * FROM test;

    \"张飞\"这条记录,如果数据库未开启自动提交,则不会入库,如果开启了自动提交,则第二个”张飞“输入会回滚不插入,但是第一条”张飞“数据依然会插入。

    completion_type

    CREATE TABLE test(name varchar(255), PRIMARY KEY (name)) ENGINE=InnoDB;
    SET @@completion_type = 1;
    BEGIN;
    INSERT INTO test SELECT \'关羽\';
    COMMIT;
    INSERT INTO test SELECT \'张飞\';
    INSERT INTO test SELECT \'张飞\';
    ROLLBACK;
    SELECT * FROM test;

    MySQL 中 completion_type 这个参数有 3 种可能:

  • completion=0,这是默认情况。也就是说当我们执行 COMMIT 的时候会提交事务,在执行下一个事务时,还需要我们使用 START TRANSACTION 或者 BEGIN 来开启。

  • completion=1,这种情况下,当我们提交事务后,相当于执行了 COMMIT AND CHAIN,也就是开启一个链式事务,即当我们提交事务之后会开启一个相同隔离级别的事务)。

  • completion=2,这种情况下 COMMIT=COMMIT AND RELEASE,也就是当我们提交后,会自动与服务器断开连接。

  • 关于事务的隔离级别

    ACID,是指数据库管理系统(DBMS)在写入或更新资料的过程中,为保证事务(transaction)是正确可靠的,所必须具备的四个特性:原子性(atomicity,或称不可分割性)、一致性(consistency)、隔离性(isolation,又称独立性)、持久性(durability)。

    当数据库上有多个事务同时执行的时候,就可能出现脏读(dirty read)、不可重复读(non-repeatable read)、幻读(phantom read)的问题,为了解决这些问题,就有了隔离级别的概念。

    脏读(Dirty Read)

    读到了其他事务还没有提交的数据。

    不可重复读(Nnrepeatable Read)

    对某数据进行读取,发现两次读取的结果不同,也就是说没有读到相同的内容。这是因为有其他事务对这个数据同时进行了修改或删除。

    幻读(Phantom Read)

    事务 A 根据条件查询得到了 N 条数据,但此时事务 B 更改或者增加了 M 条符合事务 A 查询条件的数据,这样当事务 A 再次进行查询的时候发现会有 N+M 条数据,产生了幻读。

    SQL-92 标准还定义了 4 种隔离级别来解决这些异常情况。

    这些隔离级别能解决的异常情况如下表所示:

    脏读
    不可重复读
    幻读

    读未提交(READ UNCOMMITTED) 允许 允许 允许
    读已提交(READ COMMITTED) 禁止 允许 允许
    可重复读(REPEATABLE READ) 禁止 禁止 允许
    可串行化(SERIALIZABLE 禁止 禁止 禁止
  • 读未提交,也就是允许读到未提交的数据,这种情况下查询是不会使用锁的,可能会产生脏读、不可重复读、幻读等情况。
  • 读已提交,就是只能读到已经提交的内容,可以避免脏读的产生,属于 RDBMS 中常见的默认隔离级别(比如说 Oracle 和 SQL Server),但如果想要避免不可重复读或者幻读,就需要我们在 SQL 查询的时候编写带加锁的 SQL 语句
  • 可重复读,保证一个事务在相同查询条件下两次查询得到的数据结果是一致的,可以避免不可重复读和脏读,但无法避免幻读。MySQL 默认的隔离级别就是可重复读。
  • 可串行化,将事务进行串行化,也就是在一个队列中按照顺序执行,可串行化是最高级别的隔离等级,可以解决事务读取中所有可能出现的异常情况,但是它牺牲了系统的并发性。
  • 在实现上,数据库里面会创建一个视图,访问的时候以视图的逻辑结果为准。

    在“可重复读”隔离级别下,这个视图是在事务启动时创建的,整个事务存在期间都用这个视图。

    在“读提交”隔离级别下,这个视图是在每个 SQL 语句开始执行的时候创建的。

    “读未提交”隔离级别下直接返回记录上的最新值,没有视图概念;

    “串行化”隔离级别下直接用加锁的方式来避免并行访问。

    我们可以看到在不同的隔离级别下,数据库行为是有所不同的。Oracle 数据库的默认隔离级别其实就是“读提交”,因此对于一些从 Oracle 迁移到 MySQL 的应用,为保证数据库隔离级别的一致,你一定要记得将 MySQL 的隔离级别设置为“读提交”。

    什么时候需要“可重复读”的场景呢?我们来看一个数据校对逻辑的案例。假设你在管理一个个人银行账户表。一个表存了账户余额,一个表存了账单明细。到了月底你要做数据校对,也就是判断上个月的余额和当前余额的差额,是否与本月的账单明细一致。你一定希望在校对过程中,即使有用户发生了一笔新的交易,也不影响你的校对结果。这时候使用“可重复读”隔离级别就很方便。事务启动时的视图可以认为是静态的,不受其他事务更新的影响。

    查看隔离级别

    SHOW VARIABLES LIKE \'transaction_isolation\';

    配置隔离级别

    SET SESSION TRANSACTION ISOLATION LEVEL READ UNCOMMITTED;

    为什么建议尽量不要使用长事务?

    长事务意味着系统里面会存在很老的事务视图。由于这些事务随时可能访问数据库里面的任何数据,所以这个事务提交之前,数据库里面它可能用到的回滚记录都必须保留,这就会导致大量占用存储空间。在 MySQL 5.5 及以前的版本,回滚日志是跟数据字典一起放在 ibdata 文件里的,即使长事务最终提交,回滚段被清理,文件也不会变小。

    除了对回滚段的影响,长事务还占用锁资源,也可能拖垮整个库。

    在 information_schema 库的 innodb_trx 这个表中查询长事务,比如下面这个语句,用于查找持续时间超过 60s 的事务。

    select * from information_schema.innodb_trx where TIME_TO_SEC(timediff(now(),trx_started))>60

    MySQL 的事务启动方式有以下几种:

    显式启动事务语句, begin 或 start transaction。配套的提交语句是 commit,回滚语句是 rollback。

    set autocommit=0,这个命令会将这个线程的自动提交关掉。意味着如果你只执行一个 select 语句,这个事务就启动了,而且并不会自动提交。这个事务持续存在直到你主动执行 commit 或 rollback 语句,或者断开连接。

    有些客户端连接框架会默认连接成功后先执行一个 set autocommit=0 的命令。这就导致接下来的查询都在事务中,如果是长连接,就导致了意外的长事务。因此,我会建议你总是使用 set autocommit=1, 通过显式语句的方式来启动事务。但是有的开发同学会纠结“多一次交互”的问题。对于一个需要频繁使用事务的业务,第二种方式每个事务在开始时都不需要主动执行一次 “begin”,减少了语句的交互次数。如果你也有这个顾虑,建议使用 commit work and chain 语法。在 autocommit 为 1 的情况下,用 begin 显式启动的事务,如果执行 commit 则提交事务。如果执行 commit work and chain,则是提交事务并自动启动下一个事务,这样也省去了再次执行 begin 语句的开销。同时带来的好处是从程序开发的角度明确地知道每个语句是否处于事务中。

    关于MVCC

    在 MySQL 中,实际上每条记录在更新的时候都会同时记录一条回滚操作。记录上的最新值,通过回滚操作,都可以得到前一个状态的值。假设一个值从 1 被按顺序改成了 2、3、4,在回滚日志里面就会有类似下面的记录。

    image

    当前值是 4,但是在查询这条记录的时候,不同时刻启动的事务会有不同的 read-view。如图中看到的,在视图 A、B、C 里面,这一个记录的值分别是 1、2、4,同一条记录在系统中可以存在多个版本,就是数据库的多版本并发控制(MVCC)。对于 read-view A,要得到 1,就必须将当前值依次执行图中所有的回滚操作得到。同时你会发现,即使现在有另外一个事务正在将 4 改成 5,这个事务跟 read-view A、B、C 对应的事务是不会冲突的。

    多版本并发控制技术,是通过数据行的多个版本管理来实现数据库的并发控制,简单来说它的思想就是保存数据的历史版本。这样我们就可以通过比较版本号决定数据是否显示出来,读取数据的时候不需要加锁也可以保证事务的隔离效果。

    通过 MVCC 我们可以解决以下几个问题:

  • 读写之间阻塞的问题,通过 MVCC 可以让读写互相不阻塞,即读不阻塞写,写不阻塞读,这样就可以提升事务并发处理能力。

  • 降低了死锁的概率。这是因为 MVCC 采用了乐观锁的方式,读取数据时并不需要加锁,对于写操作,也只锁定必要的行。

  • 解决一致性读的问题。一致性读也被称为快照读,当我们查询数据库在某个时间点的快照时,只能看到这个时间点之前事务提交更新的结果,而不能看到这个时间点之后事务提交的更新结果。

  • 使用了如下内容来实现:

    • 事务版本号
    • 行记录的隐藏列
    • Undo Log

    InnoDB 中,MVCC 是通过 Undo Log + Read View 进行数据读取,Undo Log 保存了历史快照,而 Read View 规则帮我们判断当前版本的数据是否可见。需要说明的是,在隔离级别为读已提交(Read Commit)时,一个事务中的每一次 SELECT 查询都会获取一次 Read View。

    出现幻读的原因是在读已提交的情况下,InnoDB 只采用记录锁(Record Locking)。这里要介绍下 InnoDB 三种行锁的方式:记录锁:针对单个行记录添加锁。间隙锁(Gap Locking):可以帮我们锁住一个范围(索引之间的空隙),但不包括记录本身。采用间隙锁的方式可以防止幻读情况的产生。Next-Key 锁:帮我们锁住一个范围,同时锁定记录本身,相当于间隙锁 + 记录锁,可以解决幻读的问题。在隔离级别为可重复读时,InnoDB 会采用 Next-Key 锁的机制,帮我们解决幻读问题。

    一天一备 VS 一周一备

    在一天一备的模式里,最坏情况下需要应用一天的 binlog。比如,你每天 0 点做一次全量备份,而要恢复出一个到昨天晚上 23 点的备份。一周一备最坏情况就要应用一周的 binlog 了。

    关于数据库调优

    image

    导图引用自20丨当我们思考数据库调优的时候,都有哪些维度可以选择?

    关于各种范式

    1NF 指的是数据库表中的任何属性都是原子性的,不可再分。

    2NF 指的数据表里的非主属性都要和这个数据表的候选键有完全依赖关系。所谓完全依赖不同于部分依赖,也就是不能仅依赖候选键的一部分属性,而必须依赖全部属性。

    一个没有满足 2NF 的例子,

    一张球员比赛表 player_game,里面包含球员编号、姓名、年龄、比赛编号、比赛时间和比赛场地等属性,
    这里候选键和主键都为:(球员编号,比赛编号),

    我们可以通过候选键来决定如下的关系:

    (球员编号, 比赛编号) → (姓名, 年龄, 比赛时间, 比赛场地,得分)

    上面这个关系说明球员编号和比赛编号的组合决定了球员的姓名、年龄、比赛时间、比赛地点和该比赛的得分数据。
    但是这个数据表不满足第二范式,因为数据表中的字段之间还存在着如下的对应关系:

    (球员编号) → (姓名,年龄)
    (比赛编号) → (比赛时间, 比赛场地)

    也就是说候选键中的某个字段决定了非主属性。
    插入异常:如果我们想要添加一场新的比赛,但是这时还没有确定参加的球员都有谁,那么就没法插入。
    删除异常:如果我要删除某个球员编号,如果没有单独保存比赛表的话,就会同时把比赛信息删除掉。
    更新异常:如果我们调整了某个比赛的时间,那么数据表中所有这个比赛的时间都需要进行调整,否则就会出现一场比赛时间不同的情况。

    3NF 在满足 2NF 的同时,对任何非主属性都不传递依赖于候选键。也就是说不能存在非主属性 A 依赖于非主属性 B,非主属性 B 依赖于候选键的情况。比如:
    image
    你能看到球员编号决定了球队名称,同时球队名称决定了球队主教练,非主属性球队主教练就会传递依赖于球员编号,因此不符合 3NF 的要求。

    关于索引

    索引模型

    Hash索引

    适用于只有等值查询的场景,因为不是有序的,所以做范围查询的速度是很慢的。

    有序数组

    有序数组在等值查询和范围查询场景中的性能就都非常优秀, 有序数组索引只适用于静态存储引擎,因为动态插入数据,会引起插入位置后续的数据移动,成本比较高。

    二叉搜索树

    查询复杂度是:O(log(N)) ,需要保持这棵树是平衡二叉树。为了做这个保证,更新的时间复杂度也是 O(log(N))。树可以有二叉,也可以有多叉。多叉树就是每个节点有多个儿子,儿子之间的大小保证从左到右递增。二叉树是搜索效率最高的,但是实际上大多数的数据库存储却并不使用二叉树。其原因是,索引不止存在内存中,还要写到磁盘上。你可以想象一下一棵 100 万节点的平衡二叉树,树高 20。一次查询可能需要访问 20 个数据块。在机械硬盘时代,从磁盘随机读一个数据块需要 10 ms 左右的寻址时间。也就是说,对于一个 100 万行的表,如果使用二叉树来存储,单独访问一个行可能需要 20 个 10 ms 的时间,这个查询可真够慢的。为了让一个查询尽量少地读磁盘,就必须让查询过程访问尽量少的数据块。那么,我们就不应该使用二叉树,而是要使用“N 叉”树。这里,“N 叉”树中的“N”取决于数据块的大小。

    B树和B+树

    先看单次查询。为了尽可能快的命中数据,我们希望尽可能的将更多的索引数据存储在内存中。b树有一个特点,每一层都会存储真正的数据,这会挤压索引可用的内存空间,从而在整体上增加io次数。另外,如果只看等值查询的话,树型索引是不如hash索引的。 其次,关系数据库中还会大量使用范围查询、有序查询等,比如某时间范围内的用户交易数据。范围查询,这种查询的特点是会大量使用排序,比较,返回结果也往往是多条。 如果使用b树的话,需要使用中序遍历,因为数据节点不在同一层上,会频繁引起io,从而导致整体速度下降。而在b+树中,所有的数据节点都在叶子节点,相近的叶子节点之间也存在着链接,因此会节约io时间。这样,b+树整体上就比b树要快。 其实,b+树主要应用于关系型数据库中。也有使用b树做索引的数据库,比如mangodb。
    MySQL 的 InnoDB 存储引擎还有个“自适应 Hash 索引”的功能,就是当某个索引值使用非常频繁的时候,它会在 B+ 树索引的基础上再创建一个 Hash 索引,这样让 B+ 树也具备了 Hash 索引的优点

    索引的分类

    功能上分:普通索引,唯一索引,主键索引,全文索引

    主键索引的叶子节点存的是整行数据。在 InnoDB 里,主键索引也被称为聚簇索引(clustered index)。非主键索引的叶子节点内容是主键的值。在 InnoDB 里,非主键索引也被称为二级索引(secondary index)。

    什么是回表,什么是覆盖索引?(ID是主键索引,k是普通索引)

    如果语句是 select * from T where ID=500,即主键查询方式,则只需要搜索 ID 这棵 B+ 树;

    如果语句是 select * from T where k=5,即普通索引查询方式,则需要先搜索 k 索引树,得到 ID 的值为 500,再到 ID 索引树搜索一次。这个过程称为回表。

    如果执行的语句是 select ID from T where k between 3 and 5,这时只需要查 ID 的值,而 ID 的值已经在 k 索引树上了,因此可以直接提供查询结果,不需要回表。也就是说,在这个查询里面,索引 k 已经“覆盖了”我们的查询需求,我们称为覆盖索引。

    身份证号是市民的唯一标识。也就是说,如果有根据身份证号查询市民信息的需求,我们只要在身份证号字段上建立索引就够了。而再建立一个(身份证号、姓名)的联合索引,是不是浪费空间?如果现在有一个高频请求,要根据市民的身份证号查询他的姓名,这个联合索引就有意义了。它可以在这个高频请求上用到覆盖索引,不再需要回表查整行记录,减少语句的执行时间。

    物理结构上:聚集索引(顺序)和非聚集索引(非顺序),可以类比链表和数组的区别。

    字段上分:单一索引和联合索引(最左匹配原则)

    • 聚集索引的叶子节点存储的就是我们的数据记录,非聚集索引的叶子节点存储的是数据位置。非聚集索引不会影响数据表的物理存储顺序。

    • 一个表只能有一个聚集索引,因为只能有一种排序存储的方式,但可以有多个非聚集索引,也就是多个索引目录提供数据检索。

    • 使用聚集索引的时候,数据的查询效率高,但如果对数据进行插入,删除,更新等操作,效率会比非聚集索引低。

    什么时候创建索引,什么时候不应该创建索引?

    创建索引

  • 字段唯一
  • WHERE频繁查询
  • 经常GROUP BY或者ORDER BY的列
  • DISTINCT字段
  • 不适合的情况

  • 频繁更新的字段

  • 重复数据比较多的字段

  • WHERE用不到的字段

  • InnoDB 表 T,如果你要重建索引 k,你的两个 SQL 语句可以这么写:

    alter table T drop index k;

    alter table T add index(k);

    如果你要重建主键索引,也可以这么写:

    alter table T drop primary key;

    alter table T add primary key(id);

    其中,重建索引 k 的做法是合理的,可以达到省空间的目的。但是,重建主键的过程不合理。不论是删除主键还是创建主键,都会将整个表重建。所以连着执行这两个语句的话,第一个语句就白做了。这两个语句,你可以用这个语句代替 : alter table T engine=InnoDB。

    分析一下哪些场景下应该使用自增主键,而哪些场景下不应该?

    自增主键每次插入一条新记录,都是追加操作,都不涉及到挪动其他记录,也不会触发叶子节点的分裂。

    而有业务逻辑的字段做主键,则往往不容易保证有序插入,这样写数据成本相对较高。

    除了考虑性能外,还可以从存储空间的角度来看。

    假设你的表中确实有一个唯一字段,比如字符串类型的身份证号,那应该用身份证号做主键,还是用自增字段做主键呢?

    由于每个非主键索引的叶子节点上都是主键的值。如果用身份证号做主键,那么每个二级索引的叶子节点占用约 20 个字节,而如果用整型做主键,则只要 4 个字节,如果是长整型(bigint)则是 8 个字节。显然,主键长度越小,普通索引的叶子节点就越小,普通索引占用的空间也就越小。

    所以,从性能和存储空间方面考量,自增主键往往是更合理的选择。

    有没有什么场景适合用业务字段直接做主键的呢?

    比如典型的 KV 场景。由于没有其他索引,所以也就不用考虑其他索引的叶子节点大小的问题。这时候我们就要优先考虑上一段提到的“尽量使用主键查询”原则,直接将这个索引设置为主键,可以避免每次查询需要搜索两棵树。

    最左前缀原则。

    基于以上原则,在建立联合索引的时候,如何安排索引内的字段顺序?

    因为可以支持最左前缀,所以当已经有了 (a,b) 这个联合索引后,一般就不需要单独在 a 上建立索引了。因此,第一原则是,如果通过调整顺序,可以少维护一个索引,那么这个顺序往往就是需要优先考虑采用的。那么,如果既有联合查询,又有基于 a、b 各自的查询呢?查询条件里面只有 b 的语句,是无法使用 (a,b) 这个联合索引的,这时候你不得不维护另外一个索引,也就是说你需要同时维护 (a,b)、(b) 这两个索引。这时候,我们要考虑的原则就是空间了。比如上面这个市民表的情况,name 字段是比 age 字段大的 ,那我就建议你创建一个(name,age) 的联合索引和一个 (age) 的单字段索引。

    索引下推原则

    以市民表的联合索引(name, age)为例。如果现在有一个需求:检索出表中“名字第一个字是张,而且年龄是 10 岁的所有男孩”。那么,SQL 语句是这么写的:

    select * from tuser where name like \'张%\' and age=10 and ismale=1;

    在 MySQL 5.6 之前,只能从 ID3 开始一个个回表。到主键索引上找出数据行,再对比字段值。

    而 MySQL 5.6 引入的索引下推优化(index condition pushdown), 可以在索引遍历过程中,对索引中包含的字段先做判断,直接过滤掉不满足条件的记录,减少回表次数。

    image

    在图 3 和 4 这两个图里面,每一个虚线箭头表示回表一次。图 3 中,在 (name,age) 索引里面我特意去掉了 age 的值,这个过程 InnoDB 并不会去看 age 的值,只是按顺序把“name 第一个字是’张’”的记录一条条取出来回表。因此,需要回表 4 次。图 4 跟图 3 的区别是,InnoDB 在 (name,age) 索引内部就判断了 age 是否等于 10,对于不等于 10 的记录,直接判断并跳过。在我们的这个例子中,只需要对 ID4、ID5 这两条记录回表取数据判断,就只需要回表 2 次。

    什么时候索引失效

  • 索引字段使用了表达式
  • 使用函数
  • 在 WHERE 子句中,如果在 OR 前的条件列进行了索引,而在 OR 后的条件列没有进行索引,那么索引会失效。
  • 当我们使用 LIKE 进行模糊查询的时候,前面不能是 %
  • 最左原则
  • 示例题:

    CREATE TABLE `geek` (
    `a` int(11) NOT NULL,
    `b` int(11) NOT NULL,
    `c` int(11) NOT NULL,
    `d` int(11) NOT NULL,
    PRIMARY KEY (`a`,`b`),
    KEY `c` (`c`),
    KEY `ca` (`c`,`a`),
    KEY `cb` (`c`,`b`)
    ) ENGINE=InnoDB;

    假设原表如上,索引(\'c\',\'a\')和索引(\'c\',\'b\')是否都需要?

    假设表数据如下:

    image

    按(a,b)排序

    image

    按(c)排序

    image

    按(c,a)排序

    image

    按(c,b)排序

    image

    按c排序和按ca排序是一致的,所以(c,a)索引可以省略。

    索引的选择

    涉及change buffer

    参考如下:https://time.geekbang.org/column/article/70848

    使用前缀索引,定义好长度,就可以做到既节省空间,又不用额外增加太多的查询成本。比如:email字段中可以使用前面若干个字符作为前缀索引。

    实际上,我们在建立索引时关注的是区分度,区分度越高越好。因为区分度越高,意味着重复的键值越少。因此,我们可以通过统计索引上有多少个不同的值来判断要使用多长的前缀。首先,你可以使用下面这个语句,算出这个列上有多少个不同的值:

    mysql> select count(distinct email) as L from SUser;

    然后,依次选取不同长度的前缀来看这个值,比如我们要看一下 4~7 个字节的前缀索引,可以用这个语句:

    mysql> select count(distinct left(email,4))as L4,
    count(distinct left(email,5))as L5,
    count(distinct left(email,6))as L6,
    count(distinct left(email,7))as L7,
    from SUser;

    当然,使用前缀索引很可能会损失区分度,所以你需要预先设定一个可以接受的损失比例,比如 5%。然后,在返回的 L4~L7 中,找出不小于 L * 95% 的值,假设这里 L6、L7 都满足,你就可以选择前缀长度为 6。

    使用前缀索引就用不上覆盖索引对查询性能的优化了,这也是你在选择是否使用前缀索引时需要考虑的一个因素。比如:

    select id,email from SUser where email=\'zhangssxyz@xxx.com\';

    如果使用email完整字符串作为索引,就不需要回表,如果使用前缀索引,需要回表确认id然后再匹配email

    其他方式:

    hash方式

    alter table t add id_card_crc int unsigned, add index(id_card_crc);

    倒序方式

    select field_list from t where id_card = reverse(\'input_id_card_string\');

    索引的“破坏”

    对索引字段做函数操作,可能会破坏索引值的有序性,因此优化器就决定放弃走树搜索功能。

    例1,注:其中的t_modified是datetime类型,在t_modified中加上了索引,但是如下SQL

    select count(*) from tradelog where month(t_modified)=7;

    还是会走全表扫描。

    正确方式应该为:

    select count(*) from tradelog where
    (t_modified >= \'2016-7-1\' and t_modified<\'2016-8-1\') or
    (t_modified >= \'2017-7-1\' and t_modified<\'2017-8-1\') or
    (t_modified >= \'2018-7-1\' and t_modified<\'2018-8-1\');

    例2,注:其中的tradeid设置了索引,且类型为varchar(32)

    select * from tradelog where tradeid=110717;

    其中tradeid设置了索引,但是如上语句还是走了全表扫描,因为tradeid是varchar类型,但是输入参数却是整数(字符串和数字做比较的话,是将字符串转换成数字),MySQL会做类型转换,并放弃走索引。

    例3,注:其中trade_detail表是utf8字符集,而trade_detail是utf8mb4

    select d.* from tradelog l, trade_detail d where d.tradeid=l.tradeid and l.id=2;

    在tradelog中找到id等于2的字段后,再去trade_detail中匹配的行时候,走了全表扫描,因为MySQL做了如下执行:

    select * from trade_detail where CONVERT(traideid USING utf8mb4)=$L2.tradeid.value;

    即:将trade_detail字段中的traideid做了编码转换。

    如果要使用索引,可以参考如下做法:

    select l.operator from tradelog l , trade_detail d where d.tradeid=l.tradeid and d.id=4;

    在这个例子中,MySQL会执行如下操作

    select operator from tradelog where traideid =CONVERT($R4.tradeid.value USING utf8mb4);

    这里的 CONVERT 函数是加在输入参数上的,这样就可以用上被驱动表的 traideid 索引。

    所以,例3中的SQL语句,可以有如下两种优化方式:

  • 将两个表的编码集统一,utf8->utf8mb4

  • 将语句改成:

  • select d.* from tradelog l , trade_detail d where d.tradeid=CONVERT(l.tradeid USING utf8) and l.id=2;

    数据库中的存储结构

    数据库管理存储空间的基本单位是页(Page),一页中可以存储多行记录, InnoDB中页大小查看

    show variables like \'%innodb_page_size%\';

    我们在分配空间的时候会按照页为单位来进行分配,同一棵树上同一层的页与页之间采用双向链表,而在页里面,记录之间采用的单向链表的方式。

    区(Extent)是比页大一级的存储结构,InnoDB 中,页大小默认是 16KB, 一个区会分配 64 个连续的页。所以一个区的大小是:

    64*16KB=1MB。

    段(Segment)由一个或多个区组成,不过在段中不要求区与区之间是相邻的。段是数据库中的分配单位,不同类型的数据库对象以不同的段形式存在。当我们创建数据表、索引的时候,就会相应创建对应的段,比如创建一张表时会创建一个表段,创建一个索引时会创建一个索引段。

    表空间(Tablespace)是一个逻辑容器,表空间存储的对象是段,在一个表空间中可以有一个或多个段,但是一个段只能属于一个表空间。数据库由一个或多个表空间组成,表空间从管理上可以划分为系统表空间、用户表空间、撤销表空间、临时表空间等。在 InnoDB 中存在两种表空间的类型:

    共享表空间和独立表空间。

    如果是共享表空间就意味着多张表共用一个表空间。
    如果是独立表空间,就意味着每张表有一个独立的表空间,也就是数据和索引信息都会保存在自己的表空间中。独立的表空间可以在不同的数据库之间进行迁移。

    show variables like \'innodb_file_per_table\';

    关于数据库缓冲池

    -- 每个缓冲池多大
    show variables like \'innodb_buffer_pool_size\'

    -- 可以开启多个缓冲池
    show variables like \'innodb_buffer_pool_instances\'

    -- 获取查询页的数量
    SHOW STATUS LIKE \'last_query_cost\';

    三星索引

  • 在 WHERE 条件语句中,找到所有等值谓词中的条件列,将它们作为索引片中的开始列;
  • 将 GROUP BY 和 ORDER BY 中的列加入到索引中;
  • 将 SELECT 字段中剩余的列加入到索引片中。
  • 关于数据库中的锁

    按锁粒度划分

  • 行锁
  • 表锁(表锁,MySQL 5.5引入了元数据锁)
  • 全局锁
  • 不同的数据库和存储引擎支持的锁粒度不同,InnoDB 和 Oracle 支持行锁和表锁。而 MyISAM 只支持表锁,MySQL 中的 BDB 存储引擎支持页锁和表锁。SQL Server 可以同时支持行锁、页锁和表锁。

    全局锁的典型使用场景是,做全库的逻辑备份。官方自带的逻辑备份工具是 mysqldump。当 mysqldump 使用参数–single-transaction 的时候,导数据之前就会启动一个事务,来确保拿到一致性视图。而由于 MVCC 的支持,这个过程中数据是可以正常更新的。single-transaction 方法只适用于所有的表使用事务引擎的库。如果有的表使用了不支持事务的引擎,那么备份就只能通过 FTWRL 方法。这往往是 DBA 要求业务开发人员使用 InnoDB 替代 MyISAM 的原因之一。

    为什么不使用 set global readonly=true 的方式呢?主要有两个原因:

    一是,在有些系统中,readonly 的值会被用来做其他逻辑,比如用来判断一个库是主库还是备库。因此,修改 global 变量的方式影响面更大,不建议使用。

    二是,在异常处理机制上有差异。如果执行 FTWRL 命令之后由于客户端发生异常断开,那么 MySQL 会自动释放这个全局锁,整个库回到可以正常更新的状态。而将整个库设置为 readonly 之后,如果客户端发生异常,则数据库就会一直保持 readonly 状态,这样会导致整个库长时间处于不可写状态,风险较高。

    事务中的 MDL 锁,在语句执行开始时申请,但是语句结束后并不会马上释放,而会等到整个事务提交后再释放。

    那么如何安全地给小表加字段?

    首先我们要解决长事务,事务不提交,就会一直占着 MDL 锁。在 MySQL 的 information_schema 库的 innodb_trx 表中,你可以查到当前执行中的事务。如果你要做 DDL 变更的表刚好有长事务在执行,要考虑先暂停 DDL,或者 kill 掉这个长事务。但考虑一下这个场景。如果你要变更的表是一个热点表,虽然数据量不大,但是上面的请求很频繁,而你不得不加个字段,你该怎么做呢?这时候 kill 可能未必管用,因为新的请求马上就来了。比较理想的机制是,在 alter table 语句里面设定等待时间,如果在这个指定的等待时间里面能够拿到 MDL 写锁最好,拿不到也不要阻塞后面的业务语句,先放弃。之后开发人员或者 DBA 再通过重试命令重复这个过程。MariaDB 已经合并了 AliSQL 的这个功能,所以这两个开源分支目前都支持 DDL NOWAIT/WAIT n 这个语法。

    ALTER TABLE tbl_name NOWAIT add column ...
    ALTER TABLE tbl_name WAIT N add column ...

    我们还可以从数据库管理的角度对锁进行划分。共享锁和排它锁

    加共享锁:

    LOCK TABLE product_comment READ;

    解锁:

    UNLOCK TABLE;

    加排他锁

    LOCK TABLE product_comment WRITE;

    解锁

    UNLOCK TABLE;

    意向锁(Intent Lock),简单来说就是给更大一级别的空间示意里面是否已经上过锁。
    如果事务想要获得数据表中某些记录的共享锁,就需要在数据表上添加意向共享锁。同理,事务想要获得数据表中某些记录的排他锁,就需要在数据表上添加意向排他锁。这时,意向锁会告诉其他事务已经有人锁定了表中的某些记录,不能对整个表进行全表扫描。

    从程序员角度划分

    乐观锁:通过版本号或者时间戳来控制

    悲观锁:对数据被其他事务的修改持保守态度,会通过数据库自身的锁机制来实现,从而保证数据操作的排它性。

  • 如果事务涉及多个表,操作比较复杂,那么可以尽量一次锁定所有的资源,而不是逐步来获取,这样可以减少死锁发生的概率;

  • 如果事务需要更新数据表中的大部分数据,数据表又比较大,这时可以采用锁升级的方式,比如将行级锁升级为表级锁,从而减少死锁产生的概率;

  • 不同事务并发读写多张数据表,可以约定访问表的顺序,采用相同的顺序降低死锁发生的概率。

  • 当然在数据库中,也有一些情况是不会发生死锁的,比如采用乐观锁的方式。另外在 MySQL MyISAM 存储引擎中也不会出现死锁,这是因为 MyISAM 总是一次性获得全部的锁,这样的话要么全部满足可以执行,要么就需要全部等待。

    使用 MySQL InnoDB 存储引擎时,为什么对某行数据添加排它锁之前,会在数据表上添加意向排他锁呢?

    因为要告诉其他人这个数据页或数据表已经有人上过排它锁了,这样当其他人想要获取数据表排它锁的时候,只需要了解是否有人已经获取了这个数据表的意向排他锁即可。而不需要进行全表的扫描,节省时间,提高效率!

    在 InnoDB 事务中,行锁是在需要的时候才加上的,但并不是不需要了就立刻释放,而是要等到事务结束时才释放。这个就是两阶段锁协议。知道了这个设定,对我们使用事务有什么帮助呢?那就是,如果你的事务中需要锁多个行,要把最可能造成锁冲突、最可能影响并发度的锁尽量往后放。我给你举个例子。假设你负责实现一个电影票在线交易业务,顾客 A 要在影院 B 购买电影票。我们简化一点,这个业务需要涉及到以下操作:

  • 从顾客 A 账户余额中扣除电影票价;

  • 给影院 B 的账户余额增加这张电影票价;

  • 记录一条交易日志。

  • 也就是说,要完成这个交易,我们需要 update 两条记录,并 insert 一条记录。当然,为了保证交易的原子性,我们要把这三个操作放在一个事务中。那么,你会怎样安排这三个语句在事务中的顺序呢?试想如果同时有另外一个顾客 C 要在影院 B 买票,那么这两个事务冲突的部分就是语句 2 了。因为它们要更新同一个影院账户的余额,需要修改同一行数据。根据两阶段锁协议,不论你怎样安排语句顺序,所有的操作需要的行锁都是在事务提交的时候才释放的。所以,如果你把语句 2 安排在最后,比如按照 3、1、2 这样的顺序,那么影院账户余额这一行的锁时间就最少。这就最大程度地减少了事务之间的锁等待,提升了并发度。好了,现在由于你的正确设计,影院余额这一行的行锁在一个事务中不会停留很长时间。但是,这并没有完全解决你的困扰。如果这个影院做活动,可以低价预售一年内所有的电影票,而且这个活动只做一天。于是在活动时间开始的时候,你的 MySQL 就挂了。你登上服务器一看,CPU 消耗接近 100%,但整个数据库每秒就执行不到 100 个事务。这是什么原因呢?这里,我就要说到死锁和死锁检测了。

    死锁和死锁检测

    当并发系统中不同线程出现循环资源依赖,涉及的线程都在等待别的线程释放资源时,就会导致这几个线程都进入无限等待的状态,称为死锁。

    这里我用数据库中的行锁举个例子。

    image

    这时候,事务 A 在等待事务 B 释放 id=2 的行锁,而事务 B 在等待事务 A 释放 id=1 的行锁。

    事务 A 和事务 B 在互相等待对方的资源释放,就是进入了死锁状态。

    当出现死锁以后,有两种策略:

  • 一种策略是,直接进入等待,直到超时。这个超时时间可以通过参数 innodb_lock_wait_timeout 来设置。
  • 另一种策略是,发起死锁检测,发现死锁后,主动回滚死锁链条中的某一个事务,让其他事务得以继续执行。将参数 innodb_deadlock_detect 设置为 on,表示开启这个逻辑。在 InnoDB 中,innodb_lock_wait_timeout 的默认值是 50s,意味着如果采用第一个策略,当出现死锁以后,第一个被锁住的线程要过 50s 才会超时退出,然后其他线程才有可能继续执行。
  • 对于在线服务来说,这个等待时间往往是无法接受的。但是,我们又不可能直接把这个时间设置成一个很小的值,比如 1s。这样当出现死锁的时候,确实很快就可以解开,但如果不是死锁,而是简单的锁等待呢?所以,超时时间设置太短的话,会出现很多误伤。

    所以,正常情况下我们还是要采用第二种策略,即:主动死锁检测,而且 innodb_deadlock_detect 的默认值本身就是 on。主动死锁检测在发生死锁的时候,是能够快速发现并进行处理的,但是它也是有额外负担的。你可以想象一下这个过程:每当一个事务被锁的时候,就要看看它所依赖的线程有没有被别人锁住,如此循环,最后判断是否出现了循环等待,也就是死锁。那如果是我们上面说到的所有事务都要更新同一行的场景呢?每个新来的被堵住的线程,都要判断会不会由于自己的加入导致了死锁,这是一个时间复杂度是 O(n) 的操作。假设有 1000 个并发线程要同时更新同一行,那么死锁检测操作就是 100 万这个量级的。虽然最终检测的结果是没有死锁,但是这期间要消耗大量的 CPU 资源。因此,你就会看到 CPU 利用率很高,但是每秒却执行不了几个事务。根据上面的分析,我们来讨论一下,怎么解决由这种热点行更新导致的性能问题呢?问题的症结在于,死锁检测要耗费大量的 CPU 资源。

    一种方案是:
    如果你能确保这个业务一定不会出现死锁,可以临时把死锁检测关掉。但是这种操作本身带有一定的风险,因为业务设计的时候一般不会把死锁当做一个严重错误,毕竟出现死锁了,就回滚,然后通过业务重试一般就没问题了,这是业务无损的。而关掉死锁检测意味着可能会出现大量的超时,这是业务有损的。另一个思路是控制并发度。根据上面的分析,你会发现如果并发能够控制住,比如同一行同时最多只有 10 个线程在更新,那么死锁检测的成本很低,就不会出现这个问题。一个直接的想法就是,在客户端做并发控制。但是,你会很快发现这个方法不太可行,因为客户端很多。我见过一个应用,有 600 个客户端,这样即使每个客户端控制到只有 5 个并发线程,汇总到数据库服务端以后,峰值并发数也可能要达到 3000。因此,这个并发控制要做在数据库服务端。如果你有中间件,可以考虑在中间件实现;如果你的团队有能修改 MySQL 源码的人,也可以做在 MySQL 里面。基本思路就是,对于相同行的更新,在进入引擎之前排队。这样在 InnoDB 内部就不会有大量的死锁检测工作了。

    第一种方案是:
    你可以考虑通过将一行改成逻辑上的多行来减少锁冲突。还是以影院账户为例,可以考虑放在多条记录上,比如 10 个记录,影院的账户总额等于这 10 个记录的值的总和。这样每次要给影院账户加金额的时候,随机选其中一条记录来加。这样每次冲突概率变成原来的 1/10,可以减少锁等待个数,也就减少了死锁检测的 CPU 消耗。这个方案看上去是无损的,但其实这类方案需要根据业务逻辑做详细设计。如果账户余额可能会减少,比如退票逻辑,那么这时候就需要考虑当一部分行记录变成 0 的时候,代码要有特殊处理。

    关于排序

    MySQL 5.6 版本引入的一个新的排序算法,即:优先队列排序算法。用来替换临时文件的算法。详见:17 | 如何正确地显示随机消息?

    如下SQL 查询语句:

    select city,name,age from t where city=\'杭州\' order by name limit 1000 ;

    也用到了 limit,为什么没用优先队列排序算法呢?
    原因是,这条 SQL 语句是 limit 1000,如果使用优先队列算法的话,需要维护的堆的大小就是 1000 行的 (name,rowid),超过了我设置的 sort_buffer_size 大小,所以只能使用归并排序算法。

    随机取前三条数据

    方法1

    select word from words order by rand() limit 3;

    方法2

    select count(*) into @C from t;
    set @Y1 = floor(@C * rand());
    set @Y2 = floor(@C * rand());
    set @Y3 = floor(@C * rand());
    select * from t limit @Y1,1;
    select * from t limit @Y2,1;
    select * from t limit @Y3,1;

    安全删除前10000行数据

    如果你要删除一个表里面的前 10000 行数据,有以下三种方法可以做到:

    第一种,直接执行 delete from T limit 10000;

    事务相对较长,则占用锁的时间较长,会导致其他客户端等待资源时间较长。

    第二种,在一个连接中循环执行 20 次 delete from T limit 500;

    串行化执行,将相对长的事务分成多次相对短的事务,则每次事务占用锁的时间相对较短,其他客户端在等待相应资源的时间也较短。这样的操作,同时也意味着将资源分片使用(每次执行使用不同片段的资源),可以提高并发性。

    第三种,在 20 个连接中同时执行 delete from T limit 500。

    人为自己制造锁竞争,加剧并发量。

    CBO VS RBO

    第一种是基于规则的优化器(RBO,Rule-Based Optimizer),规则就是人们以往的经验,或者是采用已经被证明是有效的方式。通过在优化器里面嵌入规则,来判断 SQL 查询符合哪种规则,就按照相应的规则来制定执行计划,同时采用启发式规则去掉明显不好的存取路径。

    第二种是基于代价的优化器(CBO,Cost-Based Optimizer),这里会根据代价评估模型,计算每条可能的执行计划的代价,也就是 COST,从中选择代价最小的作为执行计划。相比于 RBO 来说,CBO 对数据更敏感,因为它会利用数据表中的统计信息来做判断,针对不同的数据表,查询得到的执行计划可能是不同的,因此制定出来的执行计划也更符合数据表的实际情况。

    但我们需要记住,SQL 是面向集合的语言,并没有指定执行的方式,因此在优化器中会存在各种组合的可能。我们需要通过优化器来制定数据表的扫描方式、连接方式以及连接顺序,从而得到最佳的 SQL 执行计划。

    你能看出来,RBO 的方式更像是一个出租车老司机,凭借自己的经验来选择从 A 到 B 的路径。而 CBO 更像是手机导航,通过数据驱动,来选择最佳的执行路径。

    5.7.10 版本之后,MySQL 会引入两张数据表,里面规定了各种步骤预估的代价(Cost Value) ,我们可以从mysql.server_cost和mysql.engine_cost这两张表中获得这些步骤的代价

    定位慢SQL方法

    • mysqldumpslow
    • EXPLAIN 查看执行计划

    image

    • SHOW PROFILE 查看开销

    如何查看执行计划

    image

    主从同步原理

    提到主从同步的原理,我们就需要了解在数据库中的一个重要日志文件,那就是 Binlog 二进制日志,它记录了对数据库进行更新的事件。实际上主从同步的原理就是基于 Binlog 进行数据同步的。

    在主从复制过程中,会基于 3 个线程来操作,一个主库线程,两个从库线程。二进制日志转储线程(Binlog dump thread)是一个主库线程。当从库线程连接的时候,主库可以将二进制日志发送给从库,当主库读取事件的时候,会在 Binlog 上加锁,读取完成之后,再将锁释放掉。从库 I/O 线程会连接到主库,向主库发送请求更新 Binlog。这时从库的 I/O 线程就可以读取到主库的二进制日志转储线程发送的 Binlog 更新部分,并且拷贝到本地形成中继日志(Relay log)。从库 SQL 线程会读取从库中的中继日志,并且执行日志中的事件,从而将从库中的数据与主库保持同步。

    如何解决主从不一致问题

    • 异步复制
    • 半同步复制

    MySQL5.5 版本之后开始支持半同步复制的方式。原理是在客户端提交 COMMIT 之后不直接将结果返回给客户端,而是等待至少有一个从库接收到了 Binlog,并且写入到中继日志中,再返回给客户端。这样做的好处就是提高了数据的一致性,当然相比于异步复制来说,至少多增加了一个网络连接的延迟,降低了主库写的效率。在 MySQL5.7 版本中还增加了一个rpl_semi_sync_master_wait_for_slave_count参数,我们可以对应答的从库数量进行设置,默认为 1,也就是说只要有 1 个从库进行了响应,就可以返回给客户端。如果将这个参数调大,可以提升数据一致性的强度,但也会增加主库等待从库响应的时间。

    • 组复制(MySQL 5.7.17 以后 ,基于Paxos)

    MySQL的备份与恢复

    方式1:

    innodb_force_recovery

    方式2:

    Linux下MySQL数据库的备份与恢复

    关于脏页的刷新设置

    为什么我的MySQL会“抖”一下

    数据库表的空间回收

    参数 innodb_file_per_table

    这个参数设置为 OFF 表示的是,表的数据放在系统共享表空间,也就是跟数据字典放在一起;

    这个参数设置为 ON 表示的是,每个 InnoDB 表数据存储在一个以 .ibd 为后缀的文件中。

    建议配置为ON。

    删除数据和插入数据都会造成数据空洞(空洞被标识为可复用,但是空间不变)

    你可以使用 alter table A engine=InnoDB 命令来重建表。在 MySQL 5.5 版本之前,如果在这个过程中,有新的数据要写入到表 A 的话,就会造成数据丢失。因此,在整个 DDL 过程中,表 A 中不能有更新。也就是说,这个 DDL 不是 Online 的。

    而在 MySQL 5.6 版本开始引入的 Online DDL,对这个操作流程做了优化。

  • 建立一个临时文件,扫描表 A 主键的所有数据页;

  • 用数据页中表 A 的记录生成 B+ 树,存储到临时文件中;生成临时文件的过程中,将所有对 A 的操作记录在一个日志文件(row log)中;

  • 临时文件生成后,将日志文件中的操作应用到临时文件,得到一个逻辑数据上与表 A 相同的数据文件;用临时文件替换表 A 的数据文件。

  • 更多

    13 | 为什么表数据删掉一半,表文件大小不变?

    工具:Github-gh-ost

    关于并发连接和并发查询

    通常情况下,我们建议把 innodb_thread_concurrency 设置为 64~128 之间的值。这时,你一定会有疑问,并发线程上限数设置为 128 够干啥,线上的并发连接数动不动就上千了。产生这个疑问的原因,是搞混了并发连接和并发查询。并发连接和并发查询,并不是同一个概念。你在 show processlist 的结果里,看到的几千个连接,指的就是并发连接。而“当前正在执行”的语句,才是我们所说的并发查询。并发连接数达到几千个影响并不大,就是多占一些内存而已。我们应该关注的是并发查询,因为并发查询太高才是 CPU 杀手。这也是为什么我们需要设置 innodb_thread_concurrency 参数的原因。

    如果把 innodb_thread_concurrency 设置为 128 的话,那么出现同一行热点更新的问题时,是不是很快就把 128 消耗完了,这样整个系统是不是就挂了呢?实际上,在线程进入锁等待以后,并发线程的计数会减一,也就是说等行锁(也包括间隙锁)的线程是不算在 128 里面的。MySQL 这样设计是非常有意义的。因为,进入锁等待的线程已经不吃 CPU 了;更重要的是,必须这么设计,才能避免整个系统锁死。为什么呢?假设处于锁等待的线程也占并发线程的计数,你可以设想一下这个场景:线程 1 执行 begin; update t set c=c+1 where id=1, 启动了事务 trx1, 然后保持这个状态。这时候,线程处于空闲状态,不算在并发线程里面。线程 2 到线程 129 都执行 update t set c=c+1 where id=1; 由于等行锁,进入等待状态。这样就有 128 个线程处于等待状态;如果处于锁等待状态的线程计数不减一,InnoDB 就会认为线程数用满了,会阻止其他语句进入引擎执行,这样线程 1 不能提交事务。而另外的 128 个线程又处于锁等待状态,整个系统就堵住了。

    更多

    参考文档

    MySQL实战45讲

    SQL必知必会

    MySQL 面试题阅读指南

    来源:https://www.cnblogs.com/greyzeng/p/15161249.html
    图文来源于网络,如有侵权请联系删除。

    未经允许不得转载:百木园 » MySQL学习笔记

    相关推荐

    • 暂无文章