您的位置：首页 > 数据库

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

2017-09-24 20:11 1196 查看

关注微信公众号：【芋道源码】有福利：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@Overridepublic DeleteStatement parse() {   sqlParser.getLexer().nextToken(); // 跳过 DELETE   skipBetweenDeleteAndTable(); // // 跳过关键字，例如：MYSQL 里的 LOW_PRIORITY、IGNORE 和 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@Overrideprotected void skipBetweenDeleteAndTable() {   getSqlParser().skipAll(MySQLKeyword.LOW_PRIORITY, MySQLKeyword.QUICK, MySQLKeyword.IGNORE);   getSqlParser().skipIfEqual(DefaultKeyword.FROM);}// OracleDeleteParser.java@Overrideprotected void skipBetweenDeleteAndTable() {   getSqlParser().skipIfEqual(DefaultKeyword.FROM);   getSqlParser().skipIfEqual(OracleKeyword.ONLY);}

3.2 #parseSingleTable()

解析表，请看《SQL 解析（二）之SQL解析》的

#parseSingleTable()

小节。

3.3 #parseWhere()

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

666. 彩蛋

道友，帮我分享一波怎么样？后面 SQL 路由和改写会更加有趣哟！

内容来自用户分享和网络整理，不保证内容的准确性，如有侵权内容，可联系管理员处理

标签： java 架构后端

相关文章推荐

新的分享

章节导航