数据库[分库分表]中间件 Sharding-JDBC 源码分析 —— SQL 解析(五)之更新SQL解析

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

  • 1. 概述
  • 2. UpdateStatement
  • 3. #parse()
    • 3.1 #skipBetweenUpdateAndTable()
    • 3.2 #parseSingleTable()
    • 3.3 #parseSetItems()
    • 3.4 #parseWhere()

1. 概述

本文前置阅读:

  • 《SQL 解析(一)之词法解析》
  • 《SQL 解析(二)之SQL解析》

本文分享更新SQL解析的源码实现。

更新SQL解析比查询SQL解析复杂度低的多的多。不同数据库在插入SQL语法上也统一的多。本文分享 MySQL 更新SQL解析器 MySQLUpdateParser

MySQL UPDATE 语法一共有 2 种 :

  • 第一种:Single-table syntax
UPDATE [LOW_PRIORITY] [IGNORE] table_reference
    SET col_name1={expr1|DEFAULT} [, col_name2={expr2|DEFAULT}] ...
    [WHERE where_condition]
    [ORDER BY ...]
    [LIMIT row_count]
  • 第二种:Multiple-table syntax
UPDATE [LOW_PRIORITY] [IGNORE] table_references
    SET col_name1={expr1|DEFAULT} [, col_name2={expr2|DEFAULT}] ...
    [WHERE where_condition]

Sharding-JDBC 目前仅支持第一种。业务场景上使用第二种的很少很少。

Sharding-JDBC 更新SQL解析主流程如下:

// AbstractUpdateParser.java
@Override
public UpdateStatement parse() {
   sqlParser.getLexer().nextToken(); // 跳过 UPDATE
   skipBetweenUpdateAndTable(); // 跳过关键字,例如:MYSQL 里的 LOW_PRIORITY、IGNORE
   sqlParser.parseSingleTable(updateStatement); // 解析表
   parseSetItems(); // 解析 SET
   sqlParser.skipUntil(DefaultKeyword.WHERE);
   sqlParser.setParametersIndex(parametersIndex);
   sqlParser.parseWhere(updateStatement);
   return updateStatement; // 解析 WHERE
}

2. UpdateStatement

更新SQL 解析结果。

public final class UpdateStatement extends AbstractSQLStatement {
}

? 对,没有其他属性。

我们来看下 UPDATE t_user SET nickname=?,age=?WHERE user_id=?解析结果

3. #parse()

3.1 #skipBetweenUpdateAndTable()

UPDATE 和 表名 之间有些词法,对 SQL 路由和改写无影响,进行跳过。

// MySQLUpdateParser.java
@Override
protected void skipBetweenUpdateAndTable() {
   getSqlParser().skipAll(MySQLKeyword.LOW_PRIORITY, MySQLKeyword.IGNORE);
}

// OracleUpdateParser.java
@Override
protected void skipBetweenUpdateAndTable() {
   getSqlParser().skipIfEqual(OracleKeyword.ONLY);
}

3.2 #parseSingleTable()

解析,请看《SQL 解析(二)之SQL解析》的 #parseSingleTable() 小节。

3.3 #parseSetItems()

解析 SET后语句。

// AbstractUpdateParser.java
/**
* 解析多个 SET 项
*/
private void parseSetItems() {
   sqlParser.accept(DefaultKeyword.SET);
   do {
       parseSetItem();
   } while (sqlParser.skipIfEqual(Symbol.COMMA)); // 以 "," 分隔
}
/**
* 解析单个 SET 项
*/
private void parseSetItem() {
   parseSetColumn();
   sqlParser.skipIfEqual(Symbol.EQ, Symbol.COLON_EQ);
   parseSetValue();
}
/**
* 解析单个 SET 项
*/
private void parseSetColumn() {
   if (sqlParser.equalAny(Symbol.LEFT_PAREN)) {
       sqlParser.skipParentheses();
       return;
   }
   int beginPosition = sqlParser.getLexer().getCurrentToken().getEndPosition();
   String literals = sqlParser.getLexer().getCurrentToken().getLiterals();
   sqlParser.getLexer().nextToken();
   if (sqlParser.skipIfEqual(Symbol.DOT)) { // 字段有别名
       // TableToken
       if (updateStatement.getTables().getSingleTableName().equalsIgnoreCase(SQLUtil.getExactlyValue(literals))) {
           updateStatement.getSqlTokens().add(new TableToken(beginPosition - literals.length(), literals));
       }
       sqlParser.getLexer().nextToken();
   }
}
/**
* 解析单个 SET 值
*/
private void parseSetValue() {
   sqlParser.parseExpression(updateStatement);
   parametersIndex = sqlParser.getParametersIndex();
}

3.4 #parseWhere()

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

原文发布于微信公众号 - 芋道源码(YunaiV)

原文发表时间:2017-08-19

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

发表于

我来说两句

0 条评论
登录 后参与评论

相关文章

来自专栏Jackson0714

【SQL进阶】03.执行计划之旅1 - 初探

35570
来自专栏杨建荣的学习笔记

临时表相关 (r4笔记第52天)

临时表在日常工作中可能使用比较多,但是大家都对临时表相关的一些知识了解比较少。我们来简单说数理一下。 首先是临时表空间,临时表都存储在临时表空间中,对于临时表...

28050
来自专栏北京马哥教育

MySQL/MariaDB基础性知识及DDL操作详解

前言 MySQL/MariaDB是一个开放源码的小型关联式数据库管理系统,由于其体积小、速度快、总体拥有成本低,尤其是开放源码这一特点,许多中小型网站为了降...

52160
来自专栏Grace development

MySQL SQL模式特点汇总

MySQL服务器可以在不同的SQL模式下运行,并且可以针对不同的客户端以不同的方式应用这些模式,具体取决于sql_mode系统变量的值。DBA可以设置全局SQL...

16520
来自专栏MYSQL轻松学

MySQL replace用法简介

今天在工作的过程中碰到一个问题,要把数据库中某个列的所有值中含有"ceshi.test.com"的字符去掉,本来可以写个脚本,把所有的值都取出再导入进行处理,但...

39490
来自专栏兵马勇的专栏

sparksql 中外连接查询中的谓词下推处理

上月听了本部门 sparksqll 大牛的 sparksql 调优分享,当时对一个点不是很理解,回去好好理了一下,整理成文。

88210
来自专栏java达人

join和where区别以及各类join的示例

1 WHERE子句中使用的连接语句,在数据库语言中,被称为隐性连接。INNER JOIN……ON子句产生的连接称为显性连接。(其他JOIN参数也是显性连接...

220100
来自专栏python3

mysql-索引

数据库中专门用于帮助用户快速查找数据的一种数据结构。类似于字典中的目录,查找字典内容时可以根据目录查找到数据的存放位置吗,然后直接获取

21220
来自专栏Jackson0714

【SQL进阶】03.执行计划之旅1 - 初探

13010
来自专栏Java后端技术栈

为什么你创建的数据库索引没有生效?

几乎所有的小伙伴都可以随口说几句关于创建索引的优缺点,也知道什么时候创建索引能够提高我们的查询性能,什么时候索引会更新,但是你有没有注意到,即使你设置了索引,有...

8710

扫码关注云+社区

领取腾讯云代金券