RocketMQ / MyCAT / Sharding-JDBC 所有源码分析文章列表
RocketMQ / MyCAT / Sharding-JDBC 中文注释源码 GitHub 地址
您对于源码的疑问每条留言都将得到认真回复甚至不知道如何读源码也可以请教噢
新的源码解析文章实时收到通知每周更新一篇左右
认真的源码交流微信群
本文主要基于 Sharding-JDBC 1.5.0 正式版
1. 概述
- 2. DeleteStatement
- 3. #parse()
- 3.1 #skipBetweenDeleteAndTable()
- 3.2 #parseSingleTable()
- 3.3 #parseWhere()
666. 彩蛋
1. 概述
本文前置阅读:
SQL 解析 (一) 之词法解析
SQL 解析 (二) 之 SQL 解析
本文分享删除 SQL 解析的源码实现
如果你已经理解 SQL 解析 (三) 之查询 SQL, 那本文会是一篇水文, 当成一种放松吧还是跟前文一样, 以 MySQL 举例子我们来一起看看 MySQLDeleteParser
MySQL DELETE 语法一共有 2 种 :
第一种: Single-table syntax
- DELETE [LOW_PRIORITY] [QUICK] [IGNORE] FROM tbl_name
- [PARTITION (partition_name,...)]
- [WHERE where_condition]
- [ORDER BY ...]
- [LIMIT row_count]
第二种: Multiple-table syntax
- DELETE [LOW_PRIORITY] [QUICK] [IGNORE]
- tbl_name[.*] [, tbl_name[.*]] ...
- FROM table_references
- [WHERE where_condition]
- OR
- DELETE [LOW_PRIORITY] [QUICK] [IGNORE]
- FROM tbl_name[.*] [, tbl_name[.*]] ...
- USING table_references
- [WHERE where_condition]
Sharding-JDBC 目前仅支持第一种业务场景上使用第二种的很少很少
Sharding-JDBC 更新 SQL 解析主流程如下:
- // AbstractDeleteParser.java
- @Override
- public DeleteStatement parse() {
- sqlParser.getLexer().nextToken(); // 跳过 DELETE
- skipBetweenDeleteAndTable(); // // 跳过关键字, 例如: MYSQL 里的 LOW_PRIORITYIGNORE 和 FROM
- sqlParser.parseSingleTable(deleteStatement); // 解析表
- sqlParser.skipUntil(DefaultKeyword.WHERE); // 跳到 WHERE
- sqlParser.parseWhere(deleteStatement); // 解析 WHERE
- return deleteStatement;
- }
Sharding-JDBC 正在收集使用公司名单: 传送门
你的登记, 会让更多人参与和使用 Sharding-JDBC 传送门
Sharding-JDBC 也会因此, 能够覆盖更多的业务场景 传送门
登记吧, 骚年! 传送门
2. DeleteStatement
删除 SQL 解析结果
- public final class UpdateStatement extends AbstractSQLStatement {
- }
对, 没有其他属性
我们来看下
DELETE IGNORE FROM t_user WHERE user_id = ?
的解析结果:
- 3. #parse()
- 3.1 #skipBetweenDeleteAndTable()
在 DELETE 和 表名 之间有些词法, 对 SQL 路由和改写无影响, 进行跳过
- // MySQLDeleteParser.java
- @Override
- protected void skipBetweenDeleteAndTable() {
- getSqlParser().skipAll(MySQLKeyword.LOW_PRIORITY, MySQLKeyword.QUICK, MySQLKeyword.IGNORE);
- getSqlParser().skipIfEqual(DefaultKeyword.FROM);
- }
- // OracleDeleteParser.java
- @Override
- protected void skipBetweenDeleteAndTable() {
- getSqlParser().skipIfEqual(DefaultKeyword.FROM);
- getSqlParser().skipIfEqual(OracleKeyword.ONLY);
- }
- 3.2 #parseSingleTable()
解析表, 请看 SQL 解析 (二) 之 SQL 解析的
#parseSingleTable()
小节
3.3 #parseWhere()
解析 WHERE 条件解析代码: SQL 解析 (二) 之 SQL 解析的 #parseWhere()小节
来源: https://juejin.im/entry/5a97276c6fb9a063331557b8