写一个Java代码,使用Druid实现sql解析,并分析字段血缘关系

时间: 2024-02-26 14:59:06 浏览: 29
以下是一个使用Druid解析SQL并分析字段血缘关系的Java代码示例: ``` import com.alibaba.druid.sql.SQLUtils; import com.alibaba.druid.sql.ast.SQLExpr; import com.alibaba.druid.sql.ast.SQLStatement; import com.alibaba.druid.sql.ast.expr.*; import com.alibaba.druid.sql.ast.statement.*; import com.alibaba.druid.sql.dialect.mysql.parser.MySqlStatementParser; import com.alibaba.druid.sql.parser.SQLStatementParser; import java.util.*; public class DruidSqlParser { public static void main(String[] args) { String sql = "SELECT t1.id, t2.name FROM table1 t1 JOIN table2 t2 ON t1.id = t2.id WHERE t1.age > 18"; List<ColumnInfo> columnInfoList = analyzeSql(sql); for (ColumnInfo columnInfo : columnInfoList) { System.out.println(columnInfo); } } public static List<ColumnInfo> analyzeSql(String sql) { List<ColumnInfo> columnInfoList = new ArrayList<>(); SQLStatementParser parser = new MySqlStatementParser(sql); List<SQLStatement> statementList = parser.parseStatementList(); for (SQLStatement statement : statementList) { if (statement instanceof SQLSelectStatement) { SQLSelectStatement selectStatement = (SQLSelectStatement) statement; SQLSelectQueryBlock queryBlock = selectStatement.getSelect().getQueryBlock(); analyzeSelectItems(queryBlock.getSelectList(), columnInfoList); analyzeWhere(queryBlock.getWhere(), columnInfoList); analyzeJoin(queryBlock.getFrom(), columnInfoList); } } return columnInfoList; } private static void analyzeSelectItems(List<SQLSelectItem> selectItems, List<ColumnInfo> columnInfoList) { for (SQLSelectItem selectItem : selectItems) { SQLExpr expr = selectItem.getExpr(); String columnName = null; String tableName = null; if (expr instanceof SQLPropertyExpr) { SQLPropertyExpr propertyExpr = (SQLPropertyExpr) expr; columnName = propertyExpr.getName(); tableName = propertyExpr.getOwner().getName(); } else if (expr instanceof SQLIdentifierExpr) { SQLIdentifierExpr identifierExpr = (SQLIdentifierExpr) expr; columnName = identifierExpr.getName(); } if (columnName != null) { ColumnInfo columnInfo = new ColumnInfo(columnName, tableName, true); if (!columnInfoList.contains(columnInfo)) { columnInfoList.add(columnInfo); } } } } private static void analyzeWhere(SQLExpr whereExpr, List<ColumnInfo> columnInfoList) { if (whereExpr instanceof SQLBinaryOpExpr) { SQLBinaryOpExpr binaryOpExpr = (SQLBinaryOpExpr) whereExpr; analyzeWhere(binaryOpExpr.getLeft(), columnInfoList); analyzeWhere(binaryOpExpr.getRight(), columnInfoList); } else if (whereExpr instanceof SQLBinaryOpExprGroup) { SQLBinaryOpExprGroup binaryOpExprGroup = (SQLBinaryOpExprGroup) whereExpr; for (SQLExpr sqlExpr : binaryOpExprGroup.getItems()) { analyzeWhere(sqlExpr, columnInfoList); } } else if (whereExpr instanceof SQLIdentifierExpr) { SQLIdentifierExpr identifierExpr = (SQLIdentifierExpr) whereExpr; String columnName = identifierExpr.getName(); ColumnInfo columnInfo = new ColumnInfo(columnName, null, false); if (!columnInfoList.contains(columnInfo)) { columnInfoList.add(columnInfo); } } } private static void analyzeJoin(SQLTableSource tableSource, List<ColumnInfo> columnInfoList) { if (tableSource instanceof SQLJoinTableSource) { SQLJoinTableSource joinTableSource = (SQLJoinTableSource) tableSource; analyzeJoin(joinTableSource.getLeft(), columnInfoList); analyzeJoin(joinTableSource.getRight(), columnInfoList); SQLExpr onExpr = joinTableSource.getCondition(); if (onExpr instanceof SQLBinaryOpExpr) { SQLBinaryOpExpr binaryOpExpr = (SQLBinaryOpExpr) onExpr; SQLExpr leftExpr = binaryOpExpr.getLeft(); SQLExpr rightExpr = binaryOpExpr.getRight(); if (leftExpr instanceof SQLPropertyExpr && rightExpr instanceof SQLPropertyExpr) { SQLPropertyExpr leftPropertyExpr = (SQLPropertyExpr) leftExpr; SQLPropertyExpr rightPropertyExpr = (SQLPropertyExpr) rightExpr; String leftColumnName = leftPropertyExpr.getName(); String leftTableName = leftPropertyExpr.getOwner().getName(); String rightColumnName = rightPropertyExpr.getName(); String rightTableName = rightPropertyExpr.getOwner().getName(); ColumnInfo leftColumnInfo = new ColumnInfo(leftColumnName, leftTableName, false); ColumnInfo rightColumnInfo = new ColumnInfo(rightColumnName, rightTableName, false); if (columnInfoList.contains(leftColumnInfo)) { int index = columnInfoList.indexOf(leftColumnInfo); columnInfoList.get(index).setTableName(leftTableName); } if (columnInfoList.contains(rightColumnInfo)) { int index = columnInfoList.indexOf(rightColumnInfo); columnInfoList.get(index).setTableName(rightTableName); } } } } else if (tableSource instanceof SQLSubqueryTableSource) { SQLSubqueryTableSource subqueryTableSource = (SQLSubqueryTableSource) tableSource; SQLSelect subSelect = subqueryTableSource.getSelect(); analyzeSelectItems(subSelect.getQueryBlock().getSelectList(), columnInfoList); analyzeWhere(subSelect.getQueryBlock().getWhere(), columnInfoList); analyzeJoin(subSelect.getQueryBlock().getFrom(), columnInfoList); } else if (tableSource instanceof SQLExprTableSource) { SQLExprTableSource exprTableSource = (SQLExprTableSource) tableSource; String tableName = null; if (exprTableSource.getAlias() != null) { tableName = exprTableSource.getAlias(); } else if (exprTableSource.getExpr() instanceof SQLIdentifierExpr) { tableName = ((SQLIdentifierExpr) exprTableSource.getExpr()).getName(); } for (ColumnInfo columnInfo : columnInfoList) { if (columnInfo.getTableName() == null) { columnInfo.setTableName(tableName); } } } } } class ColumnInfo { private String columnName; private String tableName; private boolean isSelectItem; public ColumnInfo(String columnName, String tableName, boolean isSelectItem) { this.columnName = columnName; this.tableName = tableName; this.isSelectItem = isSelectItem; } public String getColumnName() { return columnName; } public void setColumnName(String columnName) { this.columnName = columnName; } public String getTableName() { return tableName; } public void setTableName(String tableName) { this.tableName = tableName; } public boolean isSelectItem() { return isSelectItem; } public void setSelectItem(boolean selectItem) { isSelectItem = selectItem; } @Override public String toString() { return "ColumnInfo{" + "columnName='" + columnName + '\'' + ", tableName='" + tableName + '\'' + ", isSelectItem=" + isSelectItem + '}'; } @Override public boolean equals(Object o) { if (this == o) return true; if (o == null || getClass() != o.getClass()) return false; ColumnInfo that = (ColumnInfo) o; return Objects.equals(columnName, that.columnName) && Objects.equals(tableName, that.tableName); } @Override public int hashCode() { return Objects.hash(columnName, tableName); } } ``` 这个代码实现了对SELECT、WHERE和JOIN三个部分的分析,并且能够正确地识别出每个字段所属的表和是否是SELECT中的选择项。你可以根据自己的需求对这个代码进行扩展和修改。

相关推荐

最新推荐

recommend-type

SpringBoot+Mybatis+Druid+PageHelper实现多数据源并分页方法

本篇文章主要讲述的是SpringBoot整合Mybatis、Druid和PageHelper 并实现多数据源和分页,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
recommend-type

高校学生选课系统项目源码资源

项目名称: 高校学生选课系统 内容概要: 高校学生选课系统是为了方便高校学生进行选课管理而设计的系统。该系统提供了学生选课、查看课程信息、管理个人课程表等功能,同时也为教师提供了课程发布和管理功能,以及管理员对整个选课系统的管理功能。 适用人群: 学生: 高校本科生和研究生,用于选课、查看课程信息、管理个人课程表等。 教师: 高校教师,用于发布课程、管理课程信息和学生选课情况等。 管理员: 系统管理员,用于管理整个选课系统,包括用户管理、课程管理、权限管理等。 使用场景及目标: 学生选课场景: 学生登录系统后可以浏览课程列表,根据自己的专业和兴趣选择适合自己的课程,并进行选课操作。系统会实时更新学生的选课信息,并生成个人课程表。 教师发布课程场景: 教师登录系统后可以发布新的课程信息,包括课程名称、课程描述、上课时间、上课地点等。发布后的课程将出现在课程列表中供学生选择。 管理员管理场景: 管理员可以管理系统的用户信息,包括学生、教师和管理员账号的添加、删除和修改;管理课程信息,包括课程的添加、删除和修改;管理系统的权限控制,包括用户权限的分配和管理。 目标: 为高校学生提
recommend-type

TC-125 230V 50HZ 圆锯

TC-125 230V 50HZ 圆锯
recommend-type

RTL8188FU-Linux-v5.7.4.2-36687.20200602.tar(20765).gz

REALTEK 8188FTV 8188eus 8188etv linux驱动程序稳定版本, 支持AP,STA 以及AP+STA 共存模式。 稳定支持linux4.0以上内核。
recommend-type

管理建模和仿真的文件

管理Boualem Benatallah引用此版本:布阿利姆·贝纳塔拉。管理建模和仿真。约瑟夫-傅立叶大学-格勒诺布尔第一大学,1996年。法语。NNT:电话:00345357HAL ID:电话:00345357https://theses.hal.science/tel-003453572008年12月9日提交HAL是一个多学科的开放存取档案馆,用于存放和传播科学研究论文,无论它们是否被公开。论文可以来自法国或国外的教学和研究机构,也可以来自公共或私人研究中心。L’archive ouverte pluridisciplinaire
recommend-type

:YOLOv1目标检测算法:实时目标检测的先驱,开启计算机视觉新篇章

![:YOLOv1目标检测算法:实时目标检测的先驱,开启计算机视觉新篇章](https://img-blog.csdnimg.cn/img_convert/69b98e1a619b1bb3c59cf98f4e397cd2.png) # 1. 目标检测算法概述 目标检测算法是一种计算机视觉技术,用于识别和定位图像或视频中的对象。它在各种应用中至关重要,例如自动驾驶、视频监控和医疗诊断。 目标检测算法通常分为两类:两阶段算法和单阶段算法。两阶段算法,如 R-CNN 和 Fast R-CNN,首先生成候选区域,然后对每个区域进行分类和边界框回归。单阶段算法,如 YOLO 和 SSD,一次性执行检
recommend-type

info-center source defatult

这是一个 Cisco IOS 命令,用于配置 Info Center 默认源。Info Center 是 Cisco 设备的日志记录和报告工具,可以用于收集和查看设备的事件、警报和错误信息。该命令用于配置 Info Center 默认源,即设备的默认日志记录和报告服务器。在命令行界面中输入该命令后,可以使用其他命令来配置默认源的 IP 地址、端口号和协议等参数。
recommend-type

c++校园超市商品信息管理系统课程设计说明书(含源代码) (2).pdf

校园超市商品信息管理系统课程设计旨在帮助学生深入理解程序设计的基础知识,同时锻炼他们的实际操作能力。通过设计和实现一个校园超市商品信息管理系统,学生掌握了如何利用计算机科学与技术知识解决实际问题的能力。在课程设计过程中,学生需要对超市商品和销售员的关系进行有效管理,使系统功能更全面、实用,从而提高用户体验和便利性。 学生在课程设计过程中展现了积极的学习态度和纪律,没有缺勤情况,演示过程流畅且作品具有很强的使用价值。设计报告完整详细,展现了对问题的深入思考和解决能力。在答辩环节中,学生能够自信地回答问题,展示出扎实的专业知识和逻辑思维能力。教师对学生的表现予以肯定,认为学生在课程设计中表现出色,值得称赞。 整个课程设计过程包括平时成绩、报告成绩和演示与答辩成绩三个部分,其中平时表现占比20%,报告成绩占比40%,演示与答辩成绩占比40%。通过这三个部分的综合评定,最终为学生总成绩提供参考。总评分以百分制计算,全面评估学生在课程设计中的各项表现,最终为学生提供综合评价和反馈意见。 通过校园超市商品信息管理系统课程设计,学生不仅提升了对程序设计基础知识的理解与应用能力,同时也增强了团队协作和沟通能力。这一过程旨在培养学生综合运用技术解决问题的能力,为其未来的专业发展打下坚实基础。学生在进行校园超市商品信息管理系统课程设计过程中,不仅获得了理论知识的提升,同时也锻炼了实践能力和创新思维,为其未来的职业发展奠定了坚实基础。 校园超市商品信息管理系统课程设计的目的在于促进学生对程序设计基础知识的深入理解与掌握,同时培养学生解决实际问题的能力。通过对系统功能和用户需求的全面考量,学生设计了一个实用、高效的校园超市商品信息管理系统,为用户提供了更便捷、更高效的管理和使用体验。 综上所述,校园超市商品信息管理系统课程设计是一项旨在提升学生综合能力和实践技能的重要教学活动。通过此次设计,学生不仅深化了对程序设计基础知识的理解,还培养了解决实际问题的能力和团队合作精神。这一过程将为学生未来的专业发展提供坚实基础,使其在实际工作中能够胜任更多挑战。
recommend-type

"互动学习:行动中的多样性与论文攻读经历"

多样性她- 事实上SCI NCES你的时间表ECOLEDO C Tora SC和NCESPOUR l’Ingén学习互动,互动学习以行动为中心的强化学习学会互动,互动学习,以行动为中心的强化学习计算机科学博士论文于2021年9月28日在Villeneuve d'Asq公开支持马修·瑟林评审团主席法布里斯·勒菲弗尔阿维尼翁大学教授论文指导奥利维尔·皮耶昆谷歌研究教授:智囊团论文联合主任菲利普·普雷教授,大学。里尔/CRISTAL/因里亚报告员奥利维耶·西格德索邦大学报告员卢多维奇·德诺耶教授,Facebook /索邦大学审查员越南圣迈IMT Atlantic高级讲师邀请弗洛里安·斯特鲁布博士,Deepmind对于那些及时看到自己错误的人...3谢谢你首先,我要感谢我的两位博士生导师Olivier和Philippe。奥利维尔,"站在巨人的肩膀上"这句话对你来说完全有意义了。从科学上讲,你知道在这篇论文的(许多)错误中,你是我可以依
recommend-type

:YOLO目标检测算法的挑战与机遇:数据质量、计算资源与算法优化,探索未来发展方向

![:YOLO目标检测算法的挑战与机遇:数据质量、计算资源与算法优化,探索未来发展方向](https://img-blog.csdnimg.cn/7e3d12895feb4651b9748135c91e0f1a.png?x-oss-process=image/watermark,type_ZHJvaWRzYW5zZmFsbGJhY2s,shadow_50,text_Q1NETiBA5rKJ6YaJ77yM5LqO6aOO5Lit,size_20,color_FFFFFF,t_70,g_se,x_16) # 1. YOLO目标检测算法简介 YOLO(You Only Look Once)是一种