jsqlparser无法解析带if语句问题
admin
2024-05-14 07:42:40
0

项目中引入了sharding-sphere encry 包做数据脱敏版本 4.0.1
mybatis-plus版本用的是3.1.0使用内置分页插件,默认引用的jsqlparser版本是1.4,maven中央库的版本范围是1.4-4.5,实际上仅支持到1.4

业务上报了一个奇怪的错误,一下sql语句数组越界

SELECT COUNT(1) FROM ( select u.name,u.telephone,if(u.age>18,'成年','未成年') as ageType,from user uwhere u.deleted = 0AND u.telephone = ?)

这个语句是由mybatis-plus生成的sql,理论上生成出来的应该是优化过的sql,如下

SELECT COUNT(1) FROM from user uwhere u.deleted = 0AND u.telephone = ?

但是为什么用了源sql,这是第一个问题,sql优化使用的是jsqlparser-1.4版本,如果能优化就会生成上面的sql,如果抛异常使用原sql。为什么如此简单的sql会抛异常呢?

于是写了个测试用例,新建一个空项目引入对于版本包

com.github.jsqlparserjsqlparser1.4

用例

public class JsqlparserTest {public static final Logger logger= LoggerFactory.getLogger(JsqlparserTest.class);public static void main(String[] args) throws JSQLParserException {String sql ="SELECT COUNT(1) FROM ( select u.name,u.telephone,if(u.age>18,'成年','未成年') as ageType,\n"+ "        from user u\n"+ "        where u.deleted = 0\n"+ "            AND u.telephone = ?)";Select selectStatement = (Select) CCJSqlParserUtil.parse(sql);PlainSelect plainSelect = (PlainSelect) selectStatement.getSelectBody();SqlInfo parser = parser(sql);System.out.println("xxx");}public static SqlInfo parser(String sql) {if (logger.isDebugEnabled()) {logger.debug(" JsqlParserCountOptimize sql=" + sql);}SqlInfo sqlInfo = SqlInfo.newInstance();try {Select selectStatement = (Select) CCJSqlParserUtil.parse(sql);PlainSelect plainSelect = (PlainSelect) selectStatement.getSelectBody();Distinct distinct = plainSelect.getDistinct();List orderBy = plainSelect.getOrderByElements();List groupBy = plainSelect.getGroupByColumnReferences();// 优化 SQLplainSelect.setSelectItems(countSelectItem());sqlInfo.setSql(selectStatement.toString());return sqlInfo;} catch (Throwable e) {// 无法优化使用原 SQLreturn null;}}private static List countSelectItem() {Function function = new Function();function.setName("COUNT");List expressions = new ArrayList<>();LongValue longValue = new LongValue(1);ExpressionList expressionList = new ExpressionList();expressions.add(longValue);expressionList.setExpressions(expressions);function.setParameters(expressionList);List selectItems = new ArrayList<>();SelectExpressionItem selectExpressionItem = new SelectExpressionItem(function);selectItems.add(selectExpressionItem);return selectItems;}}

执行报错如下

Exception in thread "main" net.sf.jsqlparser.JSQLParserExceptionat net.sf.jsqlparser.parser.CCJSqlParserUtil.parse(CCJSqlParserUtil.java:55)at com.example.democ.JsqlparserTest.main(JsqlparserTest.java:34)
Caused by: net.sf.jsqlparser.parser.ParseException: Encountered unexpected token: "if" "IF"at line 1, column 50.Was expecting one of:
...此处省略
Process finished with exit code 1

异常说的是不支持if语句,这个也好办,使用case when 代替就好了。
第二个问题,即使这里优化不成功,使用原sql为什么sharding-sphere会报数组越界呢?
接着看数组越界的位置

@RequiredArgsConstructor
@Getter
public abstract class AbstractSQLBuilder implements SQLBuilder {private final SQLRewriteContext context;@Overridepublic final String toSQL() {if (context.getSqlTokens().isEmpty()) {return context.getSql();}Collections.sort(context.getSqlTokens());StringBuilder result = new StringBuilder();result.append(context.getSql().substring(0, context.getSqlTokens().get(0).getStartIndex()));for (SQLToken each : context.getSqlTokens()) {result.append(getSQLTokenText(each));result.append(getConjunctionText(each));}return result.toString();}protected abstract String getSQLTokenText(SQLToken sqlToken);private String getConjunctionText(final SQLToken sqlToken) {return context.getSql().substring(getStartIndex(sqlToken), getStopIndex(sqlToken));}private int getStartIndex(final SQLToken sqlToken) {int startIndex = sqlToken instanceof Substitutable ? ((Substitutable) sqlToken).getStopIndex() + 1 : sqlToken.getStartIndex();return Math.min(startIndex, context.getSql().length());}private int getStopIndex(final SQLToken sqlToken) {int currentSQLTokenIndex = context.getSqlTokens().indexOf(sqlToken);return context.getSqlTokens().size() - 1 == currentSQLTokenIndex ? context.getSql().length() : context.getSqlTokens().get(currentSQLTokenIndex + 1).getStartIndex();}
}

我们配置了telephone 字段加密,此时发现sql token集合中出现了4个元素 两个telephone 两个 ?意味着此处投影中的 telephone片段也被作为条件恶意取了个问号填冲进去,原因是它在子查询中。详见EncryptProjectionTokenGenerator
然后升级了个版本4.1.1之后发现,这个类做了一个更新
片段如下

    private SubstitutableColumnNameToken generateSQLToken(ColumnProjectionSegment segment, String tableName) {String encryptColumnName = this.getEncryptColumnName(tableName, segment.getColumn().getIdentifier().getValue());if (!segment.getAlias().isPresent()) {encryptColumnName = encryptColumnName + " AS " + segment.getColumn().getIdentifier().getValue();}return segment.getColumn().getOwner().isPresent() ? new SubstitutableColumnNameToken(((OwnerSegment)segment.getColumn().getOwner().get()).getStopIndex() + 2, segment.getStopIndex(), encryptColumnName) : new SubstitutableColumnNameToken(segment.getStartIndex(), segment.getStopIndex(), encryptColumnName);}

此处将投影和条件做了一个区分,投影字段加了个AS进去,这样在后续解析的时候就能区分的出来哪个是条件需要在preparement阶段加密传进来的参数,哪个是结果集,需要在resultset阶段解密。

总结
将if替换为case when 解决jsqpparser无法解析if的问题
升级shardingphere 4.1.1解决加解密数组越界的问题

由此引发的思考

在各种有相关联组件整合的时候,可能发生你意想不到的问题,可能在这个问题中,你用单独用任何一个包,可能都不会出现问题,但是一旦他们结合就出现问题了。遇到此类问题的时候可以考虑下版本的问题,当然此处的shardingsphere 本身就存在问题

相关内容

热门资讯

linux入门---制作进度条 了解缓冲区 我们首先来看看下面的操作: 我们首先创建了一个文件并在这个文件里面添加了...
C++ 机房预约系统(六):学... 8、 学生模块 8.1 学生子菜单、登录和注销 实现步骤: 在Student.cpp的...
A.机器学习入门算法(三):基... 机器学习算法(三):K近邻(k-nearest neigh...
数字温湿度传感器DHT11模块... 模块实例https://blog.csdn.net/qq_38393591/article/deta...
有限元三角形单元的等效节点力 文章目录前言一、重新复习一下有限元三角形单元的理论1、三角形单元的形函数(Nÿ...
Redis 所有支持的数据结构... Redis 是一种开源的基于键值对存储的 NoSQL 数据库,支持多种数据结构。以下是...
win下pytorch安装—c... 安装目录一、cuda安装1.1、cuda版本选择1.2、下载安装二、cudnn安装三、pytorch...
MySQL基础-多表查询 文章目录MySQL基础-多表查询一、案例及引入1、基础概念2、笛卡尔积的理解二、多表查询的分类1、等...
keil调试专题篇 调试的前提是需要连接调试器比如STLINK。 然后点击菜单或者快捷图标均可进入调试模式。 如果前面...
MATLAB | 全网最详细网... 一篇超超超长,超超超全面网络图绘制教程,本篇基本能讲清楚所有绘制要点&#...
IHome主页 - 让你的浏览... 随着互联网的发展,人们越来越离不开浏览器了。每天上班、学习、娱乐,浏览器...
TCP 协议 一、TCP 协议概念 TCP即传输控制协议(Transmission Control ...
营业执照的经营范围有哪些 营业执照的经营范围有哪些 经营范围是指企业可以从事的生产经营与服务项目,是进行公司注册...
C++ 可变体(variant... 一、可变体(variant) 基础用法 Union的问题: 无法知道当前使用的类型是什...
血压计语音芯片,电子医疗设备声... 语音电子血压计是带有语音提示功能的电子血压计,测量前至测量结果全程语音播报࿰...
MySQL OCP888题解0... 文章目录1、原题1.1、英文原题1.2、答案2、题目解析2.1、题干解析2.2、选项解析3、知识点3...
【2023-Pytorch-检... (肆十二想说的一些话)Yolo这个系列我们已经更新了大概一年的时间,现在基本的流程也走走通了,包含数...
实战项目:保险行业用户分类 这里写目录标题1、项目介绍1.1 行业背景1.2 数据介绍2、代码实现导入数据探索数据处理列标签名异...
记录--我在前端干工地(thr... 这里给大家分享我在网上总结出来的一些知识,希望对大家有所帮助 前段时间接触了Th...
43 openEuler搭建A... 文章目录43 openEuler搭建Apache服务器-配置文件说明和管理模块43.1 配置文件说明...