写点什么

SQL 解析在美团的应用

  • 2020-02-27
  • 本文字数:5892 字

    阅读完需:约 19 分钟

SQL解析在美团的应用

数据库作为核心的基础组件,是需要重点保护的对象。任何一个线上的不慎操作,都有可能给数据库带来严重的故障,从而给业务造成巨大的损失。为了避免这种损失,一般会在管理上下功夫。比如为研发人员制定数据库开发规范;新上线的 SQL,需要 DBA 进行审核;维护操作需要经过领导审批等等。而且如果希望能够有效地管理这些措施,需要有效的数据库培训,还需要 DBA 细心的进行 SQL 审核。很多中小型创业公司,可以通过设定规范、进行培训、完善审核流程来管理数据库。


随着美团的业务不断发展和壮大,上述措施的实施成本越来越高。如何更多的依赖技术手段,来提高效率,越来越受到重视。业界已有不少基于 MySQL 源码开发的 SQL 审核、优化建议等工具,极大的减轻了 DBA 的 SQL 审核负担。那么我们能否继续扩展 MySQL 的源码,来辅助 DBA 和研发人员来进一步提高效率呢?比如,更全面的 SQL 优化功能;多维度的慢查询分析;辅助故障分析等。要实现上述功能,其中最核心的技术之一就是 SQL 解析。

现状与场景

SQL 解析是一项复杂的技术,一般都是由数据库厂商来掌握,当然也有公司专门提供SQL解析的API。由于这几年 MySQL 数据库中间件的兴起,需要支持读写分离、分库分表等功能,就必须从 SQL 中抽出表名、库名以及相关字段的值。因此像 Java 语言编写的 Druid,C 语言编写的 MaxScale,Go 语言编写的 Kingshard 等,都会对 SQL 进行部分解析。而真正把 SQL 解析技术用于数据库维护的产品较少,主要有如下几个:


  • 美团开源的SQLAdvisor。它基于 MySQL 原生态词法解析,结合分析 SQL 中的 where 条件、聚合条件、多表 Join 关系给出索引优化建议。

  • 去哪儿开源的Inception。侧重于根据内置的规则,对 SQL 进行审核。

  • 阿里的Cloud DBA。根据官方文档介绍,其也是提供 SQL 优化建议和改写。


上述产品都有非常合适的应用场景,在业界也被广泛使用。但是 SQL 解析的应用场景远远没有被充分发掘,比如:


  • 基于表粒度的慢查询报表。比如,一个 Schema 中包含了属于不同业务线的数据表,那么从业务线的角度来说,其希望提供表粒度的慢查询报表。

  • 生成 SQL 特征。将 SQL 语句中的值替换成问号,方便 SQL 归类。虽然可以使用正则表达式实现相同的功能,但是其 Bug 较多,可以参考 pt-query-digest。比如 pt-query-digest 中,会把遇到的数字都替换成“?”,导致无法区别不同数字后缀的表。

  • 高危操作确认与规避。比如,DBA 不小心 Drop 数据表,而此类操作,目前还无有效的工具进行回滚,尤其是大表,其后果将是灾难性的。

  • SQL 合法性判断。为了安全、审计、控制等方面的原因,美团不会让研发人员直接操作数据库,而是提供 RDS 服务。尤其是对于数据变更,需要研发人员的上级主管进行业务上的审批。如果研发人员,写了一条语法错误的 SQL,而 RDS 无法判断该 SQL 是否合法,就会造成不必要的沟通成本。


因此为了让所有有需要的业务都能方便的使用 SQL 解析功能,我们认为应该具有如下特性。


  • 直接暴露 SQL 解析接口,使用尽量简单。比如,输入 SQL,则输出表名、特征和优化建议。

  • 接口的使用不依赖于特定的语言,否则维护和使用的代价太高。比如,以 HTTP 等方式提供服务。


千里之行,始于足下。下面我先介绍下 SQL 的解析原理。

原理

SQL 解析与优化是属于编译器范畴,和 C 等其他语言的解析没有本质的区别。其中分为,词法分析、语法和语义分析、优化、执行代码生成。对应到 MySQL 的部分,如下图



图 1 SQL 解析原理

词法分析

SQL 解析由词法分析和语法/语义分析两个部分组成。词法分析主要是把输入转化成一个个 Token。其中 Token 中包含 Keyword(也称 symbol)和非 Keyword。例如,SQL 语句 select username from userinfo,在分析之后,会得到 4 个 Token,其中有 2 个 Keyword,分别为 select 和 from:


关键字非关键字关键字非关键字
selectusernamefromuserinfo


通常情况下,词法分析可以使用Flex来生成,但是 MySQL 并未使用该工具,而是手写了词法分析部分(据说是为了效率和灵活性,参考此文)。具体代码在 sql/lex.h 和 sql/sql_lex.cc 文件中。


MySQL 中的 Keyword 定义在 sql/lex.h 中,如下为部分 Keyword:


{ "&&",        SYM(AND_AND_SYM)},{ "<",        SYM(LT)},{ "<=",        SYM(LE)},{ "<>",        SYM(NE)},{ "!=",        SYM(NE)},{ "=",        SYM(EQ)},{ ">",        SYM(GT_SYM)},{ ">=",        SYM(GE)},{ "<<",        SYM(SHIFT_LEFT)},{ ">>",        SYM(SHIFT_RIGHT)},{ "<=>",       SYM(EQUAL_SYM)},{ "ACCESSIBLE",    SYM(ACCESSIBLE_SYM)},{ "ACTION",      SYM(ACTION)},{ "ADD",       SYM(ADD)},{ "AFTER",      SYM(AFTER_SYM)},{ "AGAINST",     SYM(AGAINST)},{ "AGGREGATE",    SYM(AGGREGATE_SYM)},{ "ALL",       SYM(ALL)},
复制代码


词法分析的核心代码在 sql/sql_lex.c 文件中的,MySQLLex→lex_one_Token,有兴趣的同学可以下载源码研究。

语法分析

语法分析就是生成语法树的过程。这是整个解析过程中最精华,最复杂的部分,不过这部分 MySQL 使用了 Bison 来完成。即使如此,如何设计合适的数据结构以及相关算法,去存储和遍历所有的信息,也是值得在这里研究的。


语法分析树


SQL 语句:


select username, ismale from userinfo where age > 20 and level > 5 and 1 = 1
复制代码


会生成如下语法树。



图 2 语法树


对于未接触过编译器实现的同学,肯定会好奇如何才能生成这样的语法树。其背后的原理都是编译器的范畴,可以参考维基百科的一篇文章,以及该链接中的参考书籍。本人也是在学习 MySQL 源码过程中,阅读了部分内容。由于编译器涉及的内容过多,本人精力和时间有限,不做过多探究。从工程的角度来说,学会如何使用 Bison 去构建语法树,来解决实际问题,对我们的工作也许有更大帮助。下面我就以 Bison 为基础,探讨该过程。


MySQL 语法分析树生成过程


全部的源码在 sql/sql_yacc.yy 中,在 MySQL5.6 中有 17K 行左右代码。这里列出涉及到 SQL:


select username, ismale from userinfo where age > 20 and level > 5 and 1 = 1 
复制代码


解析过程的部分代码摘录出来。其实有了 Bison 之后,SQL 解析的难度也没有想象的那么大。特别是这里给出了解析的脉络之后。


select /*select语句入口*/:      select_init      {       LEX *lex= Lex;       lex->sql_command= SQLCOM_SELECT;      }     ; select_init:     SELECT_SYM /*select 关键字*/ select_init2     | '(' select_paren ')' union_opt     ; select_init2:     select_part2     {      LEX *lex= Lex;      SELECT_LEX * sel= lex->current_select;      if (lex->current_select->set_braces(0))      {       my_parse_error(ER(ER_SYNTAX_ERROR));       MYSQL_YYABORT;      }      if (sel->linkage == UNION_TYPE &&        sel->master_unit()->first_select()->braces)      {       my_parse_error(ER(ER_SYNTAX_ERROR));       MYSQL_YYABORT;      }     }     union_clause    ;select_part2:     {      LEX *lex= Lex;      SELECT_LEX *sel= lex->current_select;      if (sel->linkage != UNION_TYPE)       mysql_init_select(lex);      lex->current_select->parsing_place= SELECT_LIST;     }      select_options select_item_list /*解析列名*/     {      Select->parsing_place= NO_MATTER;     }     select_into select_lock_type    ; select_into:     opt_order_clause opt_limit_clause {}    | into    | select_from /*from 字句*/    | into select_from    | select_from into    ;select_from:     FROM join_table_list /*解析表名*/ where_clause /*where字句*/ group_clause having_clause     opt_order_clause opt_limit_clause procedure_analyse_clause     {      Select->context.table_list=       Select->context.first_name_resolution_table=        Select->table_list.first;     }    | FROM DUAL_SYM where_clause opt_limit_clause     /* oracle compatibility: oracle always requires FROM clause,       and DUAL is system table without fields.       Is "SELECT 1 FROM DUAL" any better than "SELECT 1" ?     Hmmm :) */    ; where_clause:     /* empty */ { Select->where= 0; }    | WHERE     {      Select->parsing_place= IN_WHERE;     }     expr /*各种表达式*/     {      SELECT_LEX *select= Select;      select->where= $3;      select->parsing_place= NO_MATTER;      if ($3)       $3->top_level_item();     }    ; /* all possible expressions */expr:      | expr and expr %prec AND_SYM     {      /* See comments in rule expr: expr or expr */      Item_cond_and *item1;      Item_cond_and *item3;      if (is_cond_and($1))      {       item1= (Item_cond_and*) $1;       if (is_cond_and($3))       {        item3= (Item_cond_and*) $3;        /*         (X1 AND X2) AND (Y1 AND Y2) ==> AND (X1, X2, Y1, Y2)        */        item3->add_at_head(item1->argument_list());        $$ = $3;       }       else       {        /*         (X1 AND X2) AND Y ==> AND (X1, X2, Y)        */        item1->add($3);        $$ = $1;       }      }      else if (is_cond_and($3))      {       item3= (Item_cond_and*) $3;       /*        X AND (Y1 AND Y2) ==> AND (X, Y1, Y2)       */       item3->add_at_head($1);       $$ = $3;      }      else      {       /* X AND Y */       $$ = new (YYTHD->mem_root) Item_cond_and($1, $3);       if ($$ == NULL)        MYSQL_YYABORT;      }     }
复制代码


在大家浏览上述代码的过程,会发现 Bison 中嵌入了 C++的代码。通过 C++代码,把解析到的信息存储到相关对象中。例如表信息会存储到 TABLE_LIST 中,order_list 存储 order by 子句里的信息,where 字句存储在 Item 中。有了这些信息,再辅助以相应的算法就可以对 SQL 进行更进一步的处理了。


核心数据结构及其关系


在 SQL 解析中,最核心的结构是 SELECT_LEX,其定义在 sql/sql_lex.h 中。下面仅列出与上述例子相关的部分。



图 3 SQL 解析树结构


上面图示中,列名 username、ismale 存储在 item_list 中,表名存储在 table_list 中,条件存储在 where 中。其中以 where 条件中的 Item 层次结构最深,表达也较为复杂,如下图所示。



图 4 where 条件

SQL 解析的应用

为了更深入的了解 SQL 解析器,这里给出 2 个应用 SQL 解析的例子。

无用条件去除

无用条件去除属于优化器的逻辑优化范畴,可以仅仅根据 SQL 本身以及表结构即可完成,其优化的情况也是较多的,代码在 sql/sql_optimizer.cc 文件中的 remove_eq_conds 函数。为了避免过于繁琐的描述,以及大段代码的粘贴,这里通过图来分析以下四种情况。


  • a)1=1 and (m > 3 and n > 4)

  • b)1=2 and (m > 3 and n > 4)

  • c)1=1 or (m > 3 and n > 4)

  • d)1=2 or (m > 3 and n > 4)



图 5 无用条件去除 a



图 6 无用条件去除 b



图 7 无用条件去除 c



图 8 无用条件去除 d


如果对其代码实现有兴趣的同学,需要对 MySQL 中的一个重要数据结构 Item 类有所了解。因为其比较复杂,所以 MySQL 官方文档,专门介绍了Item类。阿里的 MySQL 小组,也有类似的文章。如需更详细的了解,就需要去查看源码中 sql/item_*等文件。

SQL 特征生成

为了确保数据库,这一系统基础组件稳定、高效运行,业界有很多辅助系统。比如慢查询系统、中间件系统。这些系统采集、收到 SQL 之后,需要对 SQL 进行归类,以便统计信息或者应用相关策略。归类时,通常需要获取 SQL 特征。比如 SQL:


select username, ismale from userinfo where age > 20 and level > 5;```SQL特征为: ```sqlselect username, ismale from userinfo where age > ? and level > ? 
复制代码


业界著名的慢查询分析工具 pt-query-digest,通过正则表达式实现这个功能但是这类处理办法 Bug 较多。接下来就介绍如何使用 SQL 解析,完成 SQL 特征的生成。


SQL 特征生成分两部分组成。


  • a) 生成 Token 数组

  • b) 根据 Token 数组,生成 SQL 特征


首先回顾在词法解析章节,我们介绍了 SQL 中的关键字,并且每个关键字都有一个 16 位的整数对应,而非关键字统一用 ident 表示,其也对应了一个 16 位整数。如下表:


标识selectfromwhere>?andident
整数728448878463893272476


将一个 SQL 转换成特征的过程:


原SQLselectusernamefromuserinfowhereage>20
SQL特征selectident:length:valuefromident:length:valuewhereident:length:value>?


在 SQL 解析过程中,可以很方便的完成 Token 数组的生成。而一旦完成 Token 数组的生成,就可以很简单的完成 SQL 特征的生成。SQL 特征被广泛用于各个系统中,比如 pt-query-digest 需要根据特征对 SQL 归类,然而其基于正则表达式的实现有诸多 bug。下面列举几个已知 Bug:


原始SQLpt-query-digest生成的特征SQL解析器生成的特征
select * from email_template2 where id = 1select * from mail_template? where id = ?select * from email_template2 where id = ?
REPLACE INTO a VALUES(‘INSERT INTO foo VALUES (1),(2)’)replace into a values(\‘insert into foo values(?+)replace into a values (?)


因此可以看出 SQL 解析的优势是很明显的。

学习建议

最近,在对 SQL 解析器和优化器探索的过程中,从一开始的茫然无措到有章可循,也总结了一些心得体会,在这里跟大家分享一下。


  • 首先,阅读相关图书书籍。图书能给我们系统认识解析器和优化器的角度。但是针对 MySQL 的此类图书市面上很少,目前中文作品可以看一看《数据库查询优化器的艺术:原理解析与 SQL 性能优化》。

  • 其次,要阅读源码,但是最好以某个版本为基础,比如 MySQL5.6.23,因为 SQL 解析、优化部分的代码在不断变化。尤其是在跨越大的版本时,改动力度大。

  • 再次,多使用 GDB 调试,验证自己的猜测,检验阅读质量。


最后,需要写相关代码验证,只有写出来了才能算真正的掌握。

作者简介

  • 广友,美团到店综合事业群 MySQL DBA 专家,2012 年毕业于中国科学技术大学,2017 年加入美团,长期致力于 MySQL 及周边工具的研究。

  • 金龙,2014 年加入美团,主要从事相关的数据库运维、高可用和相关的运维平台建设。对运维高可用与架构相关感兴趣的同学可以关注个人微信公众号“自己的设计师”,定期推送运维相关原创内容。

  • 邢帆,美团到店综合事业群 MySQL DBA,2017 年研究生毕业后加入美团,目前已经对 MySQL 运维有一定经验,并编写了一些自动化脚本。


2020-02-27 11:14973

评论

发布
暂无评论
发现更多内容

软件测试 | 测试开发 | Jenkins通过什么方式报警?

测吧(北京)科技有限公司

测试

企业知识分享|如何设计产品手册/产品说明书?

Baklib

软件测试 | 测试开发 | 如何安装Jenkins 插件?

测吧(北京)科技有限公司

测试

9个 方法预防租赁LED显示屏舞台隐患

Dylan

LED显示屏 户外LED显示屏 led显示屏厂家

软件测试 | 测试开发 | 接口抓包分析与Mock实战

测吧(北京)科技有限公司

测试

软件测试 | 测试开发 | 一步一步学测试平台开发-Vue restful请求

测吧(北京)科技有限公司

测试

Qualcomm Atheros wallys QCA9880 Dual Band 2.4GHz 5GHz 2x2 MIMO 802.11ac Mini PCIE WiFi Module//QCA9882 3x3 FCC/CE/IC

wallys-wifi6

QCA9880 QCA9882

新零售SaaS架构:中央库存系统架构设计

架构师汤师爷

SaaS 架构设计 新零售 库存系统

软件测试 | 测试开发 | 搞清楚这六个能力模型,轻松应对互联网裁员潮

测吧(北京)科技有限公司

测试

JVM——内存泄漏与内存溢出

琦彦

JVM 内存泄漏 内存溢出 10月月更

Log4j2远程执行代码漏洞如何攻击? 又如何修复

琦彦

log4j2 Log4j2 漏洞 10月月更

微服务的设计模式,你用了几个

琦彦

微服务架构 设计模式 10月月更

挑选文档协作工具的技巧

Baklib

CUDA入门教程;Transformer太火不是好事?;探求GPU极限性能的利器|AI系统前沿动态

OneFlow

人工智能 前沿动态

持续测试成熟度模型

陈磊@Criss

从启动到关闭 | SeaTunnel2.1.1源码解析

Apache SeaTunnel

软件测试 | 测试开发 | 测试平台开发-前端开发之数据展示与分析

测吧(北京)科技有限公司

测试

软件测试 | 测试开发 | 做到这几点,你也能成为 BAT 的抢手人!

测吧(北京)科技有限公司

测试

易宝正式加入openGauss社区

openGauss

秋招收到10几个offer 说说我的想法吧

Geek_0c76c3

Java 数据库 开源 程序员 开发

Java 8的新特性

琦彦

java8 10月月更

ElasticSearch 不停服升级实践

移动云大数据

elasticsearch

技术分享 | 实战演练

测吧(北京)科技有限公司

测试

喜报!霍格沃兹第二届火焰杯软件测试高校选拔赛荣获大奖

测吧(北京)科技有限公司

测试

软件测试 | 测试开发 | Frida 实现 Hook 功能的强大能力

测吧(北京)科技有限公司

测试

火山引擎在行为分析场景下的ClickHouse JOIN优化

字节跳动数据平台

数据库 数据分析 OLAP Clickhouse 数据研发

openGauss企业级开源数据库获第十届中国电子信息博览会金奖

openGauss

图尔兹正式加入openGauss社区

openGauss

软件测试 | 测试开发 | 静态扫描体系集成

测吧(北京)科技有限公司

测试

毕业后什么都不会,找了个培训班学软件测试学了4个月,拿到offer,坐等入职

测吧(北京)科技有限公司

测试

实现企业内部知识流通?搭建企业内部Wiki

Baklib

SQL解析在美团的应用_文化 & 方法_美团技术团队_InfoQ精选文章