sharding-jdbc中SQL改写用法
发表于：2024-11-16 作者：千家信息网编辑
千家信息网最后更新 2024年11月16日，这篇文章主要介绍"sharding-jdbc中SQL改写用法"，在日常操作中，相信很多人在sharding-jdbc中SQL改写用法问题上存在疑惑，小编查阅了各式资料，整理出简单好用的操作方法，希望对
千家信息网最后更新 2024年11月16日sharding-jdbc中SQL改写用法
这篇文章主要介绍"sharding-jdbc中SQL改写用法"，在日常操作中，相信很多人在sharding-jdbc中SQL改写用法问题上存在疑惑，小编查阅了各式资料，整理出简单好用的操作方法，希望对大家解答"sharding-jdbc中SQL改写用法"的疑惑有所帮助！接下来，请跟着小编一起来学习吧！
本文主要以SELECT i.* FROM t_order_1 o, t_order_item_1 i WHERE o.order_id = i.order_id and o.order_id = ? and o.user_id = ?一个简单查询语句，来分析ss大致如何来改写sql的，不同类型sql改写需自行查看对应的sql token生成器
比如分页查看OffsetTokenGenerator
1.BaseShardingEngine#shard执行改写，主要查看rewriteAndConvert方法
@RequiredArgsConstructorpublic abstract class BaseShardingEngine { //分库分表规则 private final ShardingRule shardingRule; //分片参数 private final ShardingProperties shardingProperties; //分片元数据 private final ShardingMetaData metaData; //路由钩子 private final SPIRoutingHook routingHook = new SPIRoutingHook(); /** * Shard. * * @param sql SQL * @param parameters parameters of SQL * @return SQL route result */ public SQLRouteResult shard(final String sql, final List2.改写SQL，SQLRewriteEngine#generateSQL
public final class SQLRewriteEngine { //规则 private final BaseRule baseRule; //优化后的Statement private final OptimizedStatement optimizedStatement; //token private final List sqlTokens; //sql构建者 private final SQLBuilder sqlBuilder; //参数构建者 private final ParameterBuilder parameterBuilder; public SQLRewriteEngine(final ShardingRule shardingRule, final SQLRouteResult sqlRouteResult, final List 3.构建SQL，SQLBuilder#toSQL
@RequiredArgsConstructorpublic final class SQLBuilder { //逻辑sql private final String logicSQL; //sql token private final List sqlTokens; /** * Convert to SQL. * * @return SQL */ public String toSQL() { return toSQL(null, Collections.emptyMap()); } /** * Convert to SQL. * * @param routingUnit routing unit * @param logicAndActualTables logic and actual map * @return SQL */ public String toSQL(final RoutingUnit routingUnit, final Map logicAndActualTables) { if (sqlTokens.isEmpty()) { return logicSQL; } return createLogicSQL(routingUnit, logicAndActualTables); } private String createLogicSQL(final RoutingUnit routingUnit, final Map logicAndActualTables) { StringBuilder result = new StringBuilder(); //截取逻辑sql，从0截取到第一个token start index //如:SELECT i.* FROM t_order_1 o, t_order_item_1 i WHERE o.order_id = i.order_id and o.order_id = ? and o.user_id = ? //以上面sql为例，sqlTokens为: //[TableToken(startIndex=16,stopIndex=22,tableName=t_order), TableToken(startIndex=27,stopIndex=38,tableName=t_order_item)] result.append(logicSQL.substring(0, sqlTokens.get(0).getStartIndex())); //截取结果为select * from //遍历token for (SQLToken each : sqlTokens) { //以改写表为例 //此处为根据逻辑表改写为真实表 result.append(getSQLTokenLiterals(each, routingUnit, logicAndActualTables)); //结果为t_order_0 //此处则是处理别名 result.append(getConjunctionLiterals(each));//结果为 o, } return result.toString(); } private String getSQLTokenLiterals(final SQLToken sqlToken, final RoutingUnit routingUnit, final Map logicAndActualTables) { //判断token是否可变(Alterable)，调用对应token的toString方法 //如是Alterable，返回逻辑表对应的真实表，即t_order:t_order_0，返回t_order_0 return sqlToken instanceof Alterable ? ((Alterable) sqlToken).toString(routingUnit, logicAndActualTables) : sqlToken.toString(); } private String getConjunctionLiterals(final SQLToken sqlToken) { //TableToken(startIndex=16,stopIndex=22,tableName=t_order) //TableToken(startIndex=27,stopIndex=38,tableName=t_order_item) //找到当前sqlToken的index //第一次遍历currentSQLTokenIndex为0 int currentSQLTokenIndex = sqlTokens.indexOf(sqlToken); //计算需要截取的结束位置 //第一次遍历stopIndex为27 int stopIndex = sqlTokens.size() - 1 == currentSQLTokenIndex ? logicSQL.length() : sqlTokens.get(currentSQLTokenIndex + 1).getStartIndex(); //计算需要截取的起始位置 //判断当前sqlToken的起始位置是否大于逻辑sql长度，如果起始位置大于逻辑sql的长度时，则为逻辑sql长度，否则获取当前sqlToken的起始位置 //第一次遍历 startIndex:23 stopIndex:27，截取结果为 o, return logicSQL.substring(getStartIndex(sqlToken) > logicSQL.length() ? logicSQL.length() : getStartIndex(sqlToken), stopIndex); } private int getStartIndex(final SQLToken sqlToken) { //判断token是否可替代，如别名 return sqlToken instanceof Substitutable ? ((Substitutable) sqlToken).getStopIndex() + 1 : sqlToken.getStartIndex(); }} 到此，关于"sharding-jdbc中SQL改写用法"的学习就结束了，希望能够解决大家的疑惑。理论与实践的搭配能更好的帮助大家学习，快去试试吧！若想继续学习更多相关知识，请继续关注网站，小编会继续努力为大家带来更多实用的文章！
逻辑
单元
位置
生成
结果
路由
学习
起始
参数
方法
第一次
规则
长度
分库
分表
别名
引擎
更多
类型
封装
数据库的安全要保护哪些东西
数据库安全各自的含义是什么
生产安全数据库录入
数据库的安全性及管理
数据库安全策略包含哪些
海淀数据库安全审计系统
建立农村房屋安全信息数据库
易用的数据库客户端支持安全管理
连接数据库失败ssl安全错误
数据库的锁怎样保障安全
无锡华为服务器维修网点
马鞍山软件开发公司
网络安全专题片观影
手机如何远程管理电脑服务器
ssis支持哪些数据库
大一网络技术结课论文
文明校园网络安全手抄报图片
暑假网络安全教育答题
杭州蟹蟹网络技术有限公司
浪潮服务器增加新阵列
网络安全问题的探讨
描述网络技术发展的主要方向
dlg数据库
小程序模板怎样导入数据库
前端连接数据库为何不安全
网络安全评审
温馨网络技术咨询服务部
软件开发度量指标
河南通信软件开发服务以客为尊
武汉有遗嘱数据库吗
武汉信德网络技术
蒲公英x1 打印共享服务器
上海服务器电源报价多少钱
网络安全题库 2017
服务器管理一直正在关闭服务
flash软件开发的特点
咸宁软件开发外包
跑跑卡丁车服务器认证
网络技术 视频教学 百度云
数据库mysql教程
