数据库中间件 Sharding-JDBC 源码分析 —— SQL 解析（五）之更新SQL

栏目: Java · 发布时间: 6年前

内容简介：数据库中间件 Sharding-JDBC 源码分析 —— SQL 解析（五）之更新SQL

摘要: 原创出处 http://www.iocoder.cn/Sharding-JDBC/sql-parse-5/ 「芋道源码」欢迎转载，保留摘要，谢谢！

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

数据库中间件 Sharding-JDBC 源码分析 —— SQL 解析（五）之更新SQL

关注 微信公众号：【芋道源码】 有福利：

RocketMQ / MyCAT / Sharding-JDBC 所有源码分析文章列表
RocketMQ / MyCAT / Sharding-JDBC 中文注释源码 GitHub 地址
您对于源码的疑问每条留言都将得到认真回复。 甚至不知道如何读源码也可以请教噢 。
新的源码解析文章实时收到通知。 每周更新一篇左右 。
认真的 源码交流微信群。

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解析主流程如下：

数据库中间件 Sharding-JDBC 源码分析 —— SQL 解析（五）之更新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
}

Sharding-JDBC 正在收集使用公司名单：传送门。
你的登记，会让更多人参与和使用 Sharding-JDBC。传送门
Sharding-JDBC 也会因此，能够覆盖更多的业务场景。传送门
登记吧，骚年！传送门

2. UpdateStatement

更新SQL 解析结果。

public final class UpdateStatement extends AbstractSQLStatement{
}

:smiling_imp: 对，没有其他属性。

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

数据库中间件 Sharding-JDBC 源码分析 —— SQL 解析（五）之更新SQL

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

666. 彩蛋

:stuck_out_tongue_closed_eyes: 比更新SQL解析是不是简单，更不用对比查询SQL解析。:flushed:有一种在水更的感觉。嘿嘿，下一篇（《删除SQL解析》）会更加容易。

道友，帮我分享一波怎么样？

以上所述就是小编给大家介绍的《数据库中间件 Sharding-JDBC 源码分析 —— SQL 解析（五）之更新SQL》，希望对大家有所帮助，如果大家有任何疑问请给我留言，小编会及时回复大家的。在此也非常感谢大家对码农网的支持！

查看所有标签

猜你喜欢:

本站部分资源来源于网络，本站转载出于传递更多信息之目的，版权归原作者或者来源机构所有，如转载稿涉及版权问题，请联系我们。

码农书籍

Smarter Than You Think

Clive Thompson / Penguin Press HC, The / 2013-9-12 / USD 27.95

It's undeniable—technology is changing the way we think. But is it for the better? Amid a chorus of doomsayers, Clive Thompson delivers a resounding "yes." The Internet age has produced a radical new ......一起来看看《Smarter Than You Think》这本书的介绍吧!

码农工具

数据库中间件 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()

666. 彩蛋

Smarter Than You Think

CSS 压缩/解压工具

JSON 在线解析

RGB HSV 转换