MySQL子查询原理的深入分析
01前言
子查询，通俗解释就是查询语句中嵌套着另一个查询语句。相信日常工作中接触到 mysql 的同学都了解或使用过子查询，但是具体它是怎样实现的呢? 查询效率如何? 这些恐怕好多人就不太清楚了，下面咱们就围绕这两个问题共同探索一下。
02准备内容
这里我们需要用到3个表，这3个表都有一个主键索引 id 和一个索引 a，字段 b 上无索引。存储过程 idata() 往表 t1 里插入的是 100 行数据，表 t2、t3 里插入了 1000 行数据。建表语句如下：
create table `t1` (
`id` int ( 11 ) not null,
`t1_a` int ( 11 ) default null,
`t1_b` int ( 11 ) default null,
primary key ( `id` ),
key `idx_a` ( `t1_a` )) engine = innodb;
create table `t2` (
`id` int ( 11 ) not null,
`t2_a` int ( 11 ) default null,
`t2_b` int ( 11 ) default null,
primary key ( `id` ),
key `idx_a` ( `t2_a` )) engine = innodb;
create table `t3` (
`id` int ( 11 ) not null,
`t3_a` int ( 11 ) default null,
`t3_b` int ( 11 ) default null,
primary key ( `id` ),
key `idx_a` ( `t3_a` )) engine = innodb;
-- 向t1添加100条数据
-- drop procedure idata;
delimiter ;;
create procedure idata()
begin
declare i int;
set i=1;
while(i<=100)do
insert into t1 values(i, i, i);
set i=i+1;
end while;
end;;
delimiter ;
call idata();
-- 向t2添加1000条数据
drop procedure idata;
delimiter ;;
create procedure idata()
begin
declare i int;
set i=101;
while(i<=1100)do
insert into t2 values(i, i, i);
set i=i+1;
end while;
end;;
delimiter ;
call idata();
-- 向t2添加1000条数据，且t3_a列的值为倒叙
drop procedure idata;
delimiter ;;
create procedure idata()
begin
declare i int;
set i=101;
while(i<=1100)do
insert into t3 values(i, 1101-i, i);
set i=i+1;
end while;
end;;
delimiter ;
call idata();03子查询的语法形式和分类
3.1 语法形式
子查询的语法规定，子查询可以在一个外层查询的各种位置出现，这里我们只介绍常用的几个：
3.1.1 from子句中
如 select m, n from (select m2 + 1 as m, n2 as n from t2 where m2 > 2) as t;
这个例子中的子查询是：(select m2 + 1 as m, n2 as n from t2 where m2 > 2)，这个放在from子句中的子查询相当于一个表，但又和我们平常使用的表有点儿不一样，这种由子查询结果集组成的表称之为派生表。
3.1.2 where或in子句中
如：select * from t1 where m1 = (select min(m2) from t2);
select * from t1 where m1 in (select m2 from t2);
其他的还有 select 子句中，order by 子句中，group by 子句中，虽然语法支持，但没啥意义，就不唠叨这些情况了。
3.2 分类
3.2.1 按返回的结果集区分
标量子查询，只返回一个单一值的子查询称之为标量子查询，比如：
select * from t1 where m1 = (select m1 from t1 limit 1);
行子查询，就是只返回一条记录的子查询，不过这条记录需要包含多个列（只包含一个列就成了标量子查询了）。比如：select * from t1 where (m1, n1) = (select m2, n2 from t2 limit 1);
列子查询，就是只返回一个列的数据，不过这个列的数据需要包含多条记录（只包含一条记录就成了标量子查询了）。比如：select * from t1 where m1 in (select m2 from t2);
表子查询，就是子查询的结果既包含很多条记录，又包含很多个列，比如：
select * from t1 where (m1, n1) in (select m2, n2 from t2);
其中的 (select m2, n2 from t2) 就是一个表子查询，这里需要和行子查询对比一下，行子查询中我们用了 limit 1 来保证子查询的结果只有一条记录。
3.2.2 按与外层查询关系来区分
不相关子查询，就是子查询可以单独运行出结果，而不依赖于外层查询的值，我们就可以把这个子查询称之为不相关子查询。
相关子查询，就是需要依赖于外层查询的值的子查询称之为相关子查询。比如：select * from t1 where m1 in (select m2 from t2 where n1 = n2);
04子查询在mysql中是怎么执行的
4.1 标量子查询、行子查询的执行方式
4.1.1 不相关子查询
如下边这个查询语句：
mysql root@localhost:test> explain select * from t1 where t1_a = (select t2_a from t2 limit 1); +----+-------------+-------+-------+---------------+-------+---------+--------+------+-------------+ | id | select_type | table | type | possible_keys | key | key_len | ref | rows | extra | +----+-------------+-------+-------+---------------+-------+---------+--------+------+-------------+ | 1 | primary | t1 | ref | idx_a | idx_a | 5 | const | 1 | using where | | 2 | subquery | t2 | index | <null> | idx_a | 5 | <null> | 1000 | using index | +----+-------------+-------+-------+---------------+-------+---------+--------+------+-------------+
它的执行方式：
先单独执行 (select t2_a from t2 limit 1) 这个子查询。
然后在将上一步子查询得到的结果当作外层查询的参数再执行外层查询 select * from t1 where t1_a = ...。
也就是说，对于包含不相关的标量子查询或者行子查询的查询语句来说，mysql 会分别独立的执行外层查询和子查询，就当作两个单表查询就好了。
4.1.2 相关的子查询
比如下边这个查询：
mysql root@localhost:test> explain select * from t1 where t1_a = (select t2_a from t2 where t1.t1_b=t2.t2_b limit 1); +----+--------------------+-------+------+---------------+--------+---------+--------+------+-------------+ | id | select_type | table | type | possible_keys | key | key_len | ref | rows | extra | +----+--------------------+-------+------+---------------+--------+---------+--------+------+-------------+ | 1 | primary | t1 | all | <null> | <null> | <null> | <null> | 100 | using where | | 2 | dependent subquery | t2 | all | <null> | <null> | <null> | <null> | 1000 | using where | +----+--------------------+-------+------+---------------+--------+---------+--------+------+-------------+
它的执行方式就是这样的：
先从外层查询中获取一条记录，本例中也就是先从 t1 表中获取一条记录。
然后从上一步骤中获取的那条记录中找出子查询中涉及到的值，就是 t1 表中找出 t1.t1_b 列的值，然后执行子查询。
最后根据子查询的查询结果来检测外层查询 where 子句的条件是否成立，如果成立，就把外层查询的那条记录加入到结果集，否则就丢弃。
然后重复以上步骤，直到 t1 中的记录全部匹配完。
4.2 in子查询
4.2.1 物化
如果子查询的结果集中的记录条数很少，那么把子查询和外层查询分别看成两个单独的单表查询效率还是蛮高的，但是如果单独执行子查询后的结果集太多的话，就会导致这些问题：
结果集太多，可能内存中都放不下～
对于外层查询来说，如果子查询的结果集太多，那就意味着 in 子句中的参数特别多，这就导致：
1）无法有效的使用索引，只能对外层查询进行全表扫描。
2）在对外层查询执行全表扫描时，由于 in 子句中的参数太多，这会导致检测一条记录是否符合和 in 子句中的参数匹配花费的时间太长。
于是就有：不直接将不相关子查询的结果集当作外层查询的参数，而是将该结果集写入一个临时表里。写入临时表的过程是这样的：
该临时表的列就是子查询结果集中的列。
写入临时表的记录会被去重，让临时表变得更小，更省地方。
一般情况下子查询结果集不大时，就会为它建立基于内存的使用 memory 存储引擎的临时表，而且会为该表建立哈希索引。
如果子查询的结果集非常大，超过了系统变量 tmp_table_size或者 max_heap_table_size，临时表会转而使用基于磁盘的存储引擎来保存结果集中的记录，索引类型也对应转变为 b+ 树索引。
这个将子查询结果集中的记录保存到临时表的过程称之为物化（materialize）。为了方便起见，我们就把那个存储子查询结果集的临时表称之为物化表。正因为物化表中的记录都建立了索引（基于内存的物化表有哈希索引，基于磁盘的有 b+ 树索引），通过索引执行in语句判断某个操作数在不在子查询结果集中变得非常快，从而提升了子查询语句的性能。
mysql root@localhost:test> explain select * from t3 where t3_a in (select t2_a from t2); +----+--------------+-------------+--------+---------------+------------+---------+--------------+------+-------------+ | id | select_type | table | type | possible_keys | key | key_len | ref | rows | extra | +----+--------------+-------------+--------+---------------+------------+---------+--------------+------+-------------+ | 1 | simple | t3 | all | idx_a | <null> | <null> | <null> | 1000 | using where | | 1 | simple | <subquery2> | eq_ref | <auto_key> | <auto_key> | 5 | test.t3.t3_a | 1 | <null> | | 2 | materialized | t2 | index | idx_a | idx_a | 5 | <null> | 1000 | using index | +----+--------------+-------------+--------+---------------+------------+---------+--------------+------+-------------+
其实上边的查询就相当于表 t3 和子查询物化表进行内连接：
mysql root@localhost:test> explain select * from t3 left join t2 on t3.t3_a=t2.t2_a; +----+-------------+-------+------+---------------+--------+---------+--------------+------+--------+ | id | select_type | table | type | possible_keys | key | key_len | ref | rows | extra | +----+-------------+-------+------+---------------+--------+---------+--------------+------+--------+ | 1 | simple | t3 | all | <null> | <null> | <null> | <null> | 1000 | <null> | | 1 | simple | t2 | ref | idx_a | idx_a | 5 | test.t3.t3_a | 1 | <null> | +----+-------------+-------+------+---------------+--------+---------+--------------+------+--------+
此时 mysql 查询优化器会通过运算来选择成本更低的方案来执行查询。
虽然，上面通过物化表的方式，将in子查询转换成了联接查询，但还是会有建立临时表的成本，能不能不进行物化操作直接把子查询转换为连接呢？直接转换肯定不行。
-- 这里我们先构造了3条记录，其实也是构造不唯一的普通索引
+------+------+------+ | id | t2_a | t2_b | +------+------+------+ | 1100 | 1000 | 1000 | | 1101 | 1000 | 1000 | | 1102 | 1000 | 1000 | +------+------+------+ -- 加限制条件where t2.id>=1100是为了减少要显示的数据 mysql root@localhost:test> select * from t3 where t3_a in (select t2_a from t2 where t2.id>=1100); +-----+------+------+ | id | t3_a | t3_b | +-----+------+------+ | 101 | 1000 | 101 | +-----+------+------+ 1 row in set time: 0.016s mysql root@localhost:test> select * from t3 left join t2 on t3.t3_a=t2.t2_a where t2.id>=1100; +-----+------+------+------+------+------+ | id | t3_a | t3_b | id | t2_a | t2_b | +-----+------+------+------+------+------+ | 101 | 1000 | 101 | 1100 | 1000 | 1000 | | 101 | 1000 | 101 | 1101 | 1000 | 1000 | | 101 | 1000 | 101 | 1102 | 1000 | 1000 | +-----+------+------+------+------+------+ 3 rows in set time: 0.018s
所以说 in 子查询和表联接之间并不完全等价。而我们需要的是另一种叫做半联接 (semi-join) 的联接方式 ：对于 t3 表的某条记录来说，我们只关心在 t2 表中是否存在与之匹配的记录，而不关心具体有多少条记录与之匹配，最终的结果集中也只保留 t3 表的记录。
注意：semi-join 只是在 mysql 内部采用的一种执行子查询的方式，mysql 并没有提供面向用户的 semi-join 语法。
4.2.2 半联接的实现：
- table pullout （子查询中的表上拉）
当子查询的查询列表处只有主键或者唯一索引列时，可以直接把子查询中的表上拉到外层查询的 from 子句中，并把子查询中的搜索条件合并到外层查询的搜索条件中，比如这个：
mysql root@localhost:test> select * from t3 where t3_a in (select t2_a from t2 where t2.id=999) +-----+------+------+ | id | t3_a | t3_b | +-----+------+------+ | 102 | 999 | 102 | +-----+------+------+ 1 row in set time: 0.024s mysql root@localhost:test> select * from t3 join t2 on t3.t3_a=t2.t2_a where t2.id=999; +-----+------+------+-----+------+------+ | id | t3_a | t3_b | id | t2_a | t2_b | +-----+------+------+-----+------+------+ | 102 | 999 | 102 | 999 | 999 | 999 | +-----+------+------+-----+------+------+ 1 row in set time: 0.028s mysql root@localhost:test> explain select * from t3 where t3_a in (select t2_a from t2 where t2.id=999) +----+-------------+-------+-------+---------------+---------+---------+-------+------+--------+ | id | select_type | table | type | possible_keys | key | key_len | ref | rows | extra | +----+-------------+-------+-------+---------------+---------+---------+-------+------+--------+ | 1 | simple | t2 | const | primary,idx_a | primary | 4 | const | 1 | <null> | | 1 | simple | t3 | ref | idx_a | idx_a | 5 | const | 1 | <null> | +----+-------------+-------+-------+---------------+---------+---------+-------+------+--------+
- firstmatch execution strategy （首次匹配）
firstmatch 是一种最原始的半连接执行方式，跟相关子查询的执行方式是一样的，就是说先取一条外层查询的中的记录，然后到子查询的表中寻找符合匹配条件的记录，如果能找到一条，则将该外层查询的记录放入最终的结果集并且停止查找更多匹配的记录，如果找不到则把该外层查询的记录丢弃掉。然后再开始取下一条外层查询中的记录，重复上边这个过程。
mysql root@localhost:test> explain select * from t3 where t3_a in (select t2_a from t2 where t2.t2_a=1000) +----+-------------+-------+------+---------------+-------+---------+-------+------+-----------------------------+ | id | select_type | table | type | possible_keys | key | key_len | ref | rows | extra | +----+-------------+-------+------+---------------+-------+---------+-------+------+-----------------------------+ | 1 | simple | t3 | ref | idx_a | idx_a | 5 | const | 1 | <null> | | 1 | simple | t2 | ref | idx_a | idx_a | 5 | const | 4 | using index; firstmatch(t3) | +----+-------------+-------+------+---------------+-------+---------+-------+------+-----------------------------+
- duplicateweedout execution strategy （重复值消除）
转换为半连接查询后，t3 表中的某条记录可能在 t2 表中有多条匹配的记录，所以该条记录可能多次被添加到最后的结果集中，为了消除重复，我们可以建立一个临时表，并设置主键id，每当某条 t3 表中的记录要加入结果集时，就首先把这条记录的id值加入到这个临时表里，如果添加成功，说明之前这条 t2 表中的记录并没有加入最终的结果集，是一条需要的结果；如果添加失败，说明之前这条 s1 表中的记录已经加入过最终的结果集，直接把它丢弃。
- loosescan execution strategy （松散扫描）
这种虽然是扫描索引，但只取值相同的记录的第一条去做匹配操作的方式称之为松散扫描。
4.2.3 半联接的适用条件
当然，并不是所有包含in子查询的查询语句都可以转换为 semi-join，只有形如这样的查询才可以被转换为 semi-join：
select ... from outer_tables where expr in (select ... from inner_tables ...) and ... -- 或者这样的形式也可以： select ... from outer_tables where (oe1, oe2, ...) in (select ie1, ie2, ... from inner_tables ...) and ...
用文字总结一下，只有符合下边这些条件的子查询才可以被转换为 semi-join：
- 该子查询必须是和in语句组成的布尔表达式，并且在外层查询的 where 或者 on 子句中出现
- 外层查询也可以有其他的搜索条件，只不过和 in 子查询的搜索条件必须使用and 连接起来
- 该子查询必须是一个单一的查询，不能是由若干查询由 union 连接起来的形式
- 该子查询不能包含 group by 或者 having 语句或者聚集函数
4.2.4 转为 exists 子查询
不管子查询是相关的还是不相关的，都可以把 in 子查询尝试转为 exists子查询。其实对于任意一个 in 子查询来说，都可以被转为 exists 子查询，通用的例子如下：
outer_expr in (select inner_expr from ... where subquery_where) -- 可以被转换为： exists (select inner_expr from ... where subquery_where and outer_expr=inner_expr)
当然这个过程中有一些特殊情况，比如在 outer_expr 或者 inner_expr 值为 null 的情况下就比较特殊。因为有 null 值作为操作数的表达式结果往往是 null，比方说：
mysql root@localhost:test> select null in (1, 2, 3); +-------------------+ | null in (1, 2, 3) | +-------------------+ | <null> | +-------------------+ 1 row in set
而 exists 子查询的结果肯定是 true 或者 fasle 。但是现实中我们大部分使用 in 子查询的场景是把它放在 where 或者 on 子句中，而 where 或者 on 子句是不区分 null 和 false 的，比方说：
mysql root@localhost:test> select 1 from s1 where null; +---+ | 1 | +---+ 0 rows in set time: 0.016s mysql root@localhost:test> select 1 from s1 where false; +---+ | 1 | +---+ 0 rows in set time: 0.033s
所以只要我们的in子查询是放在 where 或者 on 子句中的，那么 in -> exists 的转换就是没问题的。说了这么多，为啥要转换呢？这是因为不转换的话可能用不到索引，比方说下边这个查询：
mysql root@localhost:test> explain select * from t3 where t3_a in (select t2_a from t2 where t2.t2_a>=999) or t3_b > 1000; +----+-------------+-------+-------+---------------+--------+---------+--------+------+--------------------------+ | id | select_type | table | type | possible_keys | key | key_len | ref | rows | extra | +----+-------------+-------+-------+---------------+--------+---------+--------+------+--------------------------+ | 1 | primary | t3 | all | <null> | <null> | <null> | <null> | 1000 | using where | | 2 | subquery | t2 | range | idx_a | idx_a | 5 | <null> | 107 | using where; using index | +----+-------------+-------+-------+---------------+--------+---------+--------+------+--------------------------+
但是将它转为 exists 子查询后却可以使用到索引：
mysql root@localhost:test> explain select * from t3 where exists (select 1 from t2 where t2.t2_a>=999 and t2.t2_a=t3.t3_a) or t3_b > 1000; +----+--------------------+-------+------+---------------+--------+---------+--------------+------+--------------------------+ | id | select_type | table | type | possible_keys | key | key_len | ref | rows | extra | +----+--------------------+-------+------+---------------+--------+---------+--------------+------+--------------------------+ | 1 | primary | t3 | all | <null> | <null> | <null> | <null> | 1000 | using where | | 2 | dependent subquery | t2 | ref | idx_a | idx_a | 5 | test.t3.t3_a | 1 | using where; using index | +----+--------------------+-------+------+---------------+--------+---------+--------------+------+--------------------------+
需要注意的是，如果 in 子查询不满足转换为 semi-join 的条件，又不能转换为物化表或者转换为物化表的成本太大，那么它就会被转换为 exists 查询。或者转换为物化表的成本太大，那么它就会被转换为 exists 查询。
05总结
1. 如果in子查询符合转换为 semi-join 的条件，查询优化器会优先把该子查询转换为 semi-join，然后再考虑下边执行半连接的策略中哪个成本最低，
1）table pullout
2）duplicateweedout
3）loosescan
4）firstmatch
选择成本最低的那种执行策略来执行子查询。
2. 如果in子查询不符合转换为 semi-join 的条件，那么查询优化器会从下边两种策略中找出一种成本更低的方式执行子查询：
1）先将子查询物化之后再执行查询
2）执行 in to exists 转换
到此这篇关于mysql子查询原理的文章就介绍到这了,更多相关mysql子查询原理内容请搜索以前的文章或继续浏览下面的相关文章希望大家以后多多支持！
下一篇： Java中操作数组的Arrays类