数据库分库分表中间件 Sharding-JDBC 源码分析 —— SQL 解析(六)之删除SQL

数据库分库分表中间件 Sharding-JDBC 源码分析 —— SQL 解析(六)之删除SQL

本文主要基于 Sharding-JDBC 1.5.0 正式版

  • 1. 概述

  • 2. DeleteStatement

  • 3. #parse()

    • 3.1 #skipBetweenDeleteAndTable()

    • 3.2 #parseSingleTable()

    • 3.3 #parseWhere()

  • 666. 彩蛋


数据库分库分表中间件 Sharding-JDBC 源码分析 —— SQL 解析(六)之删除SQL

🙂🙂🙂关注微信公众号:【芋道源码】有福利:

  1. RocketMQ / MyCAT / Sharding-JDBC 所有源码分析文章列表

  2. RocketMQ / MyCAT / Sharding-JDBC 中文注释源码 GitHub 地址

  3. 您对于源码的疑问每条留言将得到认真回复。甚至不知道如何读源码也可以请教噢

  4. 新的源码解析文章实时收到通知。每周更新一篇左右

  5. 认真的源码交流微信群


1. 概述

本文前置阅读:

  • 《SQL 解析(一)之词法解析》

  • 《SQL 解析(二)之SQL解析》

本文分享删除SQL解析的源码实现。

🙂 如果你已经理解《SQL 解析(三)之查询SQL》,那本文会是一篇水文,当成一种放松吧。还是跟前文一样,以 MySQL 举例子。我们来一起看看 MySQLDeleteParser。

MySQL DELETE 语法一共有 2 种 :

  • 第一种:Single-table syntax

  1. DELETE [LOW_PRIORITY] [QUICK] [IGNORE] FROM tbl_name

  2.    [PARTITION (partition_name,...)]

  3.    [WHERE where_condition]

  4.    [ORDER BY ...]

  5.    [LIMIT row_count]

  • 第二种:Multiple-table syntax

  1. DELETE [LOW_PRIORITY] [QUICK] [IGNORE]

  2.    tbl_name[.*] [, tbl_name[.*]] ...

  3.    FROM table_references

  4.    [WHERE where_condition]

  5. OR

  6. DELETE [LOW_PRIORITY] [QUICK] [IGNORE]

  7.    FROM tbl_name[.*] [, tbl_name[.*]] ...

  8.    USING table_references

  9.    [WHERE where_condition]    

Sharding-JDBC 目前仅支持第一种。业务场景上使用第二种的很少很少。

Sharding-JDBC 更新SQL解析主流程如下:

数据库分库分表中间件 Sharding-JDBC 源码分析 —— SQL 解析(六)之删除SQL

  1. // AbstractDeleteParser.java

  2. @Override

  3. public DeleteStatement parse() {

  4.   sqlParser.getLexer().nextToken(); // 跳过 DELETE

  5.   skipBetweenDeleteAndTable(); // // 跳过关键字,例如:MYSQL 里的 LOW_PRIORITY、IGNORE 和 FROM

  6.   sqlParser.parseSingleTable(deleteStatement); // 解析表

  7.   sqlParser.skipUntil(DefaultKeyword.WHERE); // 跳到 WHERE

  8.   sqlParser.parseWhere(deleteStatement); // 解析 WHERE

  9.   return deleteStatement;

  10. }

Sharding-JDBC 正在收集使用公司名单:传送门。
🙂 你的登记,会让更多人参与和使用 Sharding-JDBC。传送门
Sharding-JDBC 也会因此,能够覆盖更多的业务场景。传送门
登记吧,骚年!传送门

2. DeleteStatement

删除SQL 解析结果。

  1. public final class UpdateStatement extends AbstractSQLStatement {

  2. }

😈 对,没有其他属性。

我们来看下 DELETE IGNORE FROM t_user WHERE user_id=?解析结果

数据库分库分表中间件 Sharding-JDBC 源码分析 —— SQL 解析(六)之删除SQL

3. #parse()

3.1 #skipBetweenDeleteAndTable()

DELETE 和 表名 之间有些词法,对 SQL 路由和改写无影响,进行跳过。

  1. // MySQLDeleteParser.java

  2. @Override

  3. protected void skipBetweenDeleteAndTable() {

  4.   getSqlParser().skipAll(MySQLKeyword.LOW_PRIORITY, MySQLKeyword.QUICK, MySQLKeyword.IGNORE);

  5.   getSqlParser().skipIfEqual(DefaultKeyword.FROM);

  6. }

  7. // OracleDeleteParser.java

  8. @Override

  9. protected void skipBetweenDeleteAndTable() {

  10.   getSqlParser().skipIfEqual(DefaultKeyword.FROM);

  11.   getSqlParser().skipIfEqual(OracleKeyword.ONLY);

  12. }

3.2 #parseSingleTable()

解析,请看《SQL 解析(二)之SQL解析》的 #parseSingleTable() 小节。

3.3 #parseWhere()

解析 WHERE 条件。解析代码:《SQL 解析(二)之SQL解析》的#parseWhere()小节。

666. 彩蛋

道友,帮我分享一波怎么样?

后面 SQL 路由和改写会更加有趣哟.

发表评论