带你读 MySQL 源码:Select *( 二 )


这种场景的示例 SQL 如下:
select st1, i1 from t1 where exists(select * from t2 where t1.i1 = t2.i1)子查询只需要判断 t2 表中是否存在满足 t1.i1 = t2.i1 的记录,而不需要读取 t2 表的所有字段,因为读取了所有字段,也用不上,纯属浪费,所以,星号也就可以被替换成常量了 。替换之后的 SQL 相当于这样:
select st1, i1 from t1 where exists(select 1 from t2 where t1.i1 = t2.i1)

实际上,子查询执行过程中,server 层会要求存储引擎返回 t2 表的 i1 字段内容,用于判断 t2 表中是否存在满足 t1.i1 = t2.i1? 的记录 。这个逻辑是 server 层自主实现的,和 ?select * 中的星号展开为表中所有字段的逻辑不相关,我们知道有这个逻辑就可以,不展开介绍了 。
第 2 种:不满足 if (subsel && ...)? 条件,就需要调用 insert_fields(),把 select 字段列表中的星号展开为表的所有字段 。
(4)insert_fields() // sql/sql_base.ccbool insert_fields(THD *thd, Query_block *query_block, const char *db_name,const char *table_name, mem_root_deque<Item *> *fields,mem_root_deque<Item *>::iterator *it, bool any_privileges) {...bool found = false;Table_ref *tables;// 按照 select 语句中表的出现顺序// 初始化表的迭代器Tables_in_user_order_iterator user_it;user_it.init(query_block, table_name != nullptr);while (true) {// 从迭代器中获取下一个需要处理的表tables = user_it.get_next();// tables == nullptr 说明迭代结束,结束循环if (tables == nullptr) break;// 表中的字段迭代器Field_iterator_table_ref field_iterator;TABLE *const table = tables->table;assert(tables->is_leaf_for_name_resolution());// if 进行 2 个条件判断,任何一个不满足则跳过当前表:// 1. table_name 不为 NULL 说明星号前面指定了表名//比较星号前面的表名和当前迭代的表名是否相同// 2. db_name 不为 NULL 说明星号前面指定了数据库名//比较星号前面的数据库名和当前迭代的表所属的数据库名是否相同if ((table_name &&my_strcasecmp(table_alias_charset, table_name, tables->alias)) ||(db_name && strcmp(tables->db, db_name)))continue;// 以下 2 种情况都满足,需要检查// 当前连接用户是否有表中所有字段的 select 权限:// 1. !any_privileges 为 true//说明当前 select 语句//不是 create view as ... 中的 select 语句// 2. 当前连接用户没有表的 select 权限,if (!any_privileges && !(tables->grant.privilege & SELECT_ACL)) {field_iterator.set(tables);if (check_grant_all_columns(thd, SELECT_ACL, &field_iterator))return true;}...// 初始化字段迭代器field_iterator.set(tables);// 迭代当前表的每一个字段for (; !field_iterator.end_of_fields(); field_iterator.next()) {// 根据字段对象创建 ItemItem *const item = field_iterator.create_item(thd);if (!item) return true; /* purecov: inspected */assert(item->fixed);...// found 的初始值为 false,// 表示这是表中第 1 个字段// 用该字段的 Item 对象替换星号的 Item 对象if (!found) {found = true;**it = item; /* Replace '*' with the first found item. */} else {// 表中第 2 个及以后的字段时,// Item 对象赋值给 it + 1 指向的位置// 也就是加入了 select 字段列表/* Add 'item' to the SELECT list, after the current one. */*it = fields->insert(*it + 1, item);}...}}...insert_fields() 的主要逻辑如下:【带你读 MySQL 源码:Select *】按照 select 语句中表的出现顺序迭代每个表,每迭代一个表,都会判断该表名和星号前面的表名(如果有)是否相同,以及该表所属的数据库名和星号前面的数据库名是否相同(如果有) 。
如果当前迭代的表名、表所属的数据库名和星号前面的表名、数据库名都相同,接下来会进行访问权限检查 。
如果当前连接用户有表的 select 权限,说明它对表中的所有列都有查询权限,否则,需要调用 check_grant_all_columns(...),检查它对表中每一个字段是否有 select 权限 。
通过权限检查之后,就开始迭代表中的每个字段,每迭代一个字段,都根据该字段构造一个 Item 对象,并把 Item 对象加入 select 字段列表 。
3、总结select * 中的星号展开为表中所有字段涉及词法 & 语法分析阶段、查询准备阶段,总结如下: