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