1. 程式人生 > >資料庫中介軟體 Sharding-JDBC 原始碼分析 —— SQL 解析(六)之刪除SQL

資料庫中介軟體 Sharding-JDBC 原始碼分析 —— SQL 解析(六)之刪除SQL

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

������關注微信公眾號:【芋道原始碼】有福利:
1. RocketMQ / MyCAT / Sharding-JDBC 所有原始碼分析文章列表
2. RocketMQ / MyCAT / Sharding-JDBC 中文註釋原始碼 GitHub 地址
3. 您對於原始碼的疑問每條留言將得到認真回覆。甚至不知道如何讀原始碼也可以請教噢
4. 新的原始碼解析文章實時收到通知。每週更新一篇左右

> 5. 認真的原始碼交流微信群。

1. 概述

本文前置閱讀:

本文分享刪除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_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
@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()

3.3 #parseWhere()

666. 彩蛋

知識星球

道友,幫我分享一波怎麼樣?

後面 SQL 路由和改寫會更加有趣喲!

������關注微信公眾號:【芋道原始碼】有福利:
1. RocketMQ / MyCAT / Sharding-JDBC 所有原始碼分析文章列表
2. RocketMQ / MyCAT / Sharding-JDBC 中文註釋原始碼 GitHub 地址
3. 您對於原始碼的疑問每條留言將得到認真回覆。甚至不知道如何讀原始碼也可以請教噢
4. 新的原始碼解析文章實時收到通知。每週更新一篇左右
5. 認真的原始碼交流微信群。