本文主要基于 Sharding-JDBC 1.5.0 正式版
  • 1. 概述
  • 2. DeleteStatement
  • 3. #parse()
    • 3.1 #skipBetweenDeleteAndTable()
    • 3.2 #parseSingleTable()
    • 3.3 #parseWhere()
  • 666. 彩蛋
🙂🙂🙂关注微信公众号：【芋道源码】有福利：
  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解析主流程如下：
  1. // AbstractDeleteParser.java
  2. @Override
  3. publicDeleteStatement 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. publicfinalclassUpdateStatementextendsAbstractSQLStatement{
  2. }
😈 对，没有其他属性。
我们来看下 DELETE IGNORE FROM t_user WHERE user_id=? 的解析结果：

3. #parse()

3.1 #skipBetweenDeleteAndTable()

在 DELETE 和 表名 之间有些词法，对 SQL 路由和改写无影响，进行跳过。
  1. // MySQLDeleteParser.java
  2. @Override
  3. protectedvoid skipBetweenDeleteAndTable(){
  4.   getSqlParser().skipAll(MySQLKeyword.LOW_PRIORITY,MySQLKeyword.QUICK,MySQLKeyword.IGNORE);
  5.   getSqlParser().skipIfEqual(DefaultKeyword.FROM);
  6. }
  7. // OracleDeleteParser.java
  8. @Override
  9. protectedvoid 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 路由和改写会更加有趣哟.
继续阅读
阅读原文