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

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

内容简介：数据库中间件 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》，希望对大家有所帮助，如果大家有任何疑问请给我留言，小编会及时回复大家的。在此也非常感谢大家对码农网的支持！

查看所有标签

猜你喜欢:

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

码农书籍

Cyberwar

Kathleen Hall Jamieson / Oxford University Press / 2018-10-3 / USD 16.96

The question of how Donald Trump won the 2016 election looms over his presidency. In particular, were the 78,000 voters who gave him an Electoral College victory affected by the Russian trolls and hac......一起来看看《Cyberwar》这本书的介绍吧!

码农工具

数据库中间件 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. 彩蛋

Cyberwar

RGB HSV 转换

RGB CMYK 转换工具

HEX CMYK 转换工具