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

时间:2022-04-29
本文章向大家介绍数据库分库分表中间件 Sharding-JDBC 源码分析 —— SQL 解析(六)之删除SQL,主要内容包括1. 概述、2. DeleteStatement、3. #parse()、3.2 #parseSingleTable()、3.3 #parseWhere()、基本概念、基础应用、原理机制和需要注意的事项等,并结合实例形式分析了其使用技巧,希望通过本文能帮助到大家理解应用这部分内容。

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

  • 1. 概述
  • 2. DeleteStatement
  • 3. #parse()
    • 3.1 #skipBetweenDeleteAndTable()
    • 3.2 #parseSingleTable()
    • 3.3 #parseWhere()

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_PRIORITY、IGNORE 和 FROM
   sqlParser.parseSingleTable(deleteStatement); // 解析表
   sqlParser.skipUntil(DefaultKeyword.WHERE); // 跳到 WHERE
   sqlParser.parseWhere(deleteStatement); // 解析 WHERE
   return deleteStatement;
}

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()小节。