Jsqlparser简单学习

文章目录

    • 学习链接
    • 模块
      • 访问者模式
      • parser模块
      • statement模块
      • Expression模块
      • deparser模块
    • 测试
      • TestDrop
      • TestSelect
      • TestSelectVisitor

学习链接

java设计模式：访问者模式

github使用示例参考

测试 JSqlParser使用示例

JSqlParse（一）基本增删改查语句build
JSqlParse（二）带where的查询语句build

JSqlParser专栏系列教程

jsqlparser:基于抽象语法树(AST)遍历SQL语句的语法元素

Sql解析转换之JSqlParse完整介绍

JSqlParser系列之二代码结构（原）

JSQLPARSER解析SQL知识入门

jsqlparser基本使用

模块

访问者模式

访问者模式理解：

  1. 有固定结构的数据封装类，结构基本不会发生变化。它们都有1个接收访问者的方法。

  2. 访问者针对每1个具体的结构封装类都有1个具体的访问方法。

  3. 在具体的结构封装类接收访问者的方法中，可直接调用访问者针对当前结构类的方法。

  4. 如果封装类结构不是固定的，那么不能使用这种模式

parser模块

在这里插入图片描述

statement模块

在这里插入图片描述

Expression模块

deparser模块

测试

TestDrop

先创建java对象（结构），使用deparser将java对象转为（得到）sql字符串

import net.sf.jsqlparser.schema.Table;
import net.sf.jsqlparser.statement.drop.Drop;
import net.sf.jsqlparser.util.deparser.DropDeParser;
import org.junit.Test;public class TestDrop {@Testpublic void test_drop() {// 创建DropDrop drop = new Drop();// 创建TableTable table = new Table();table.setName("sys_user");// 设置dropdrop.setName(table);drop.setType("table");drop.setIfExists(true);// 最终的sqlStringBuilder stringBuilder = new StringBuilder();// 使用DropDeParser来将java对象(封装了sql信息)转为具体的sql语句// （这里的代码是参照StatementDeParser#visit(Drop)）DropDeParser dropDeParser = new DropDeParser(stringBuilder);dropDeParser.deParse(drop);// 获取最终的目标sqlString sql = dropDeParser.getBuffer().toString();// DROP table IF EXISTS sys_userSystem.out.println(sql);}}

TestSelect

给原来的sql语句添加查询条件：age > 18 and dept_id in (1,2,3)

package com.zzhua;import net.sf.jsqlparser.JSQLParserException;
import net.sf.jsqlparser.expression.LongValue;
import net.sf.jsqlparser.expression.operators.conditional.AndExpression;
import net.sf.jsqlparser.expression.operators.relational.EqualsTo;
import net.sf.jsqlparser.expression.operators.relational.ExpressionList;
import net.sf.jsqlparser.expression.operators.relational.InExpression;
import net.sf.jsqlparser.parser.CCJSqlParserUtil;
import net.sf.jsqlparser.schema.Column;
import net.sf.jsqlparser.statement.Statement;
import net.sf.jsqlparser.statement.select.PlainSelect;
import net.sf.jsqlparser.statement.select.Select;
import net.sf.jsqlparser.statement.select.SelectBody;
import net.sf.jsqlparser.util.deparser.ExpressionDeParser;
import net.sf.jsqlparser.util.deparser.SelectDeParser;
import net.sf.jsqlparser.util.deparser.StatementDeParser;
import org.junit.Test;import java.util.ArrayList;public class TestSelect {@Testpublic void test_select() throws JSQLParserException {Statement statement = CCJSqlParserUtil.parse("select id,nick_name from sys_user where id > 10");if (statement instanceof Select) {System.out.println("select语句");Select select = (Select) statement;StringBuilder buffer = new StringBuilder();// （这里的代码是参照 StatementDeParser#visit(Select)）// SelectParser实现了SelectVisitor接口, 能够访问PlainSelect、SetOperationList、WithItemSelectDeParser selectDeParser = new SelectDeParser();selectDeParser.setBuffer(buffer);ExpressionDeParser expressionDeParser = new ExpressionDeParser(selectDeParser, buffer);selectDeParser.setExpressionVisitor(expressionDeParser);// SelectBody接收selectParser的访问(访问的结果会添加到buffer中)select.getSelectBody().accept(selectDeParser);// 输出原始的sql: SELECT id, nick_name FROM sys_user WHERE id > 10System.out.println(buffer);SelectBody selectBody = select.getSelectBody();if (selectBody instanceof PlainSelect) {// 原来的selectBodyPlainSelect plainSelect = (PlainSelect) select.getSelectBody();// age = 18EqualsTo equalsTo = new EqualsTo();Column ageColumn = new Column("age");equalsTo.setLeftExpression(ageColumn);equalsTo.setRightExpression(new LongValue(18));// 在原来的where条件中拼接上刚刚创建的条件 age=18, 并使用And连接起来AndExpression andExpression1 = new AndExpression(plainSelect.getWhere(), equalsTo);// dept_id in (1,2,3)InExpression inExpression = new InExpression();inExpression.setLeftExpression(new Column("dept_id"));ExpressionList expressionList = new ExpressionList(new ArrayList<>());expressionList.getExpressions().add(new LongValue(1));expressionList.getExpressions().add(new LongValue(2));expressionList.getExpressions().add(new LongValue(3));inExpression.setRightItemsList(expressionList);AndExpression andExpression2 = new AndExpression(andExpression1, inExpression);// 替换掉原来的where条件plainSelect.setWhere(andExpression2);// 直接参考StatementDeParserStatementDeParser statementDeParser = new StatementDeParser(new StringBuilder());Select newSelect = new Select();newSelect.setSelectBody(plainSelect);statementDeParser.visit(newSelect);// 输出sql: SELECT id, nick_name FROM sys_user WHERE id > 10 AND age = 18 AND dept_id IN (1, 2, 3)System.out.println(statementDeParser.getBuffer());}}}}

TestSelectVisitor

@Slf4j
public class TestSelectVisitor {public static void main(String[] args) throws Exception {String sqlStr ="SELECT\n" +"                su.dept_id `deptId`,\n" +"                su.user_id,\n" +"                sr.role_id,\n" +"                su.user_name,\n" +"                sd.dept_name,\n" +"                sr.role_name\n" +"            FROM\n" +"                sys_user AS su\n" +"                JOIN sys_dept sd ON su.dept_id = sd.dept_id\n" +"                JOIN sys_user_role sur ON sur.user_id = su.user_id\n" +"                JOIN sys_role sr ON sur.role_id = sr.role_id\n" +"            WHERE\n" +"                sd.dept_name = '研发部门'\n" +"                AND su.user_name = 'admin'\n" +"                AND su.dept_id = 103\n" +"                OR sr.role_name = '超级管理员'\n" +"                ORDER BY\n" +"                sd.create_time DESC";Select querySql = (Select)CCJSqlParserUtil.parse(sqlStr);querySql.getSelectBody().accept(new SelectVisitorAdapter() {@Overridepublic void visit(PlainSelect plainSelect) {log.info("--------------查询列名----------------------------------------");plainSelect.getSelectItems().stream().forEach(selectItem -> {selectItem.accept(new SelectItemVisitorAdapter() {@Overridepublic void visit(SelectExpressionItem selectExpressionItem) {log.info(selectExpressionItem.getExpression().toString());if (selectExpressionItem.getAlias()!=null) {log.info("列别名 {}",selectExpressionItem.getAlias().getName());}}});});log.info("--------------From Table Info----------------------------------------");log.info(plainSelect.getFromItem().toString());if (plainSelect.getFromItem().getAlias()!=null) {log.info("表别名"+plainSelect.getFromItem().getAlias().getName());}log.info("--------------Join Table Info----------------------------------------");plainSelect.getJoins().stream().forEach(join -> {log.info(join.toString());log.info("关联表：{} ",join.getRightItem());if (join.getRightItem().getAlias()!=null) {log.info("关联表别名：{}",join.getRightItem().getAlias().getName());}log.info("关联条件：{}",join.getOnExpression().toString());});log.info("--------------Where  Info----------------------------------------");plainSelect.getWhere().accept(new ExpressionVisitorAdapter() {@Overridepublic void visitBinaryExpression(BinaryExpression expr) {log.info("表达式：{}",expr.toString());log.info("表达式左侧：{}",expr.getLeftExpression().toString());log.info("表达式右侧：{}",expr.getRightExpression().toString());}});log.info("--------------增加查询条件----------------------------------------");try {plainSelect.setWhere(new AndExpression(CCJSqlParserUtil.parseCondExpression("1=1"),plainSelect.getWhere()));} catch (JSQLParserException e) {throw new RuntimeException(e);}}});log.info("语句：{}",querySql.toString());}
}/*
--------------查询列名----------------------------------------
su.dept_id
列别名 `deptId`
su.user_id
sr.role_id
su.user_name
sd.dept_name
sr.role_name
--------------From Table Info----------------------------------------
sys_user AS su
表别名su
--------------Join Table Info----------------------------------------
JOIN sys_dept sd ON su.dept_id = sd.dept_id
关联表：sys_dept sd 
关联表别名：sd
关联条件：su.dept_id = sd.dept_id
JOIN sys_user_role sur ON sur.user_id = su.user_id
关联表：sys_user_role sur 
关联表别名：sur
关联条件：sur.user_id = su.user_id
JOIN sys_role sr ON sur.role_id = sr.role_id
关联表：sys_role sr 
关联表别名：sr
关联条件：sur.role_id = sr.role_id
--------------Where  Info----------------------------------------
表达式：sd.dept_name = '研发部门' AND su.user_name = 'admin' AND su.dept_id = 103 OR sr.role_name = '超级管理员'
表达式左侧：sd.dept_name = '研发部门' AND su.user_name = 'admin' AND su.dept_id = 103
表达式右侧：sr.role_name = '超级管理员'
--------------增加查询条件----------------------------------------
语句：SELECT su.dept_id `deptId`, su.user_id, sr.role_id, su.user_name, sd.dept_name, sr.role_name FROM sys_user AS su JOIN sys_dept sd ON su.dept_id = sd.dept_id JOIN sys_user_role sur ON sur.user_id = su.user_id JOIN sys_role sr ON sur.role_id = sr.role_id WHERE 1 = 1 AND sd.dept_name = '研发部门' AND su.user_name = 'admin' AND su.dept_id = 103 OR sr.role_name = '超级管理员' ORDER BY sd.create_time DESC
*/

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/630361.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

力扣（leetcode）第819题最常见的单词（Python）

力扣（leetcode）第819题最常见的单词（Python）

819.最常见的单词 题目链接&#xff1a;819.最常见的单词 给你一个字符串 paragraph 和一个表示禁用词的字符串数组 banned &#xff0c;返回出现频率最高的非禁用词。题目数据 保证 至少存在一个非禁用词&#xff0c;且答案 唯一 。 paragraph 中的单词 不区分大小写 &…
阅读更多...
MCU 是指微控制器单元（Microcontroller Unit）

MCU 是指微控制器单元（Microcontroller Unit）

MCU 是指微控制器单元&#xff08;Microcontroller Unit&#xff09;。 微控制器是一种集成了处理器核心、存储器、输入/输出接口和其他外围设备的集成电路。它通常用于嵌入式系统中&#xff0c;负责控制和执行特定任务&#xff0c;例如控制家电、汽车电子、工业自动化等。 M…
阅读更多...
GitHub API使用--获取GitHub topic

GitHub API使用--获取GitHub topic

目录标题 技术简介申请token简单使用使用Java调用获取GitHub topic总结 技术简介 GitHub API是一个功能强大的工具&#xff0c;为开发者提供了访问和操作GitHub平台上资源的途径。无论是构建个人工具&#xff0c;集成自动化流程&#xff0c;还是开发应用程序&#xff0c;GitHu…
阅读更多...
用js做小功能

用js做小功能

css <style>th,td,tr {width: 100px;border: 1px solid red;}table {/* border: 1px solid red; */border-collapse: collapse;text-align: center;}</style> html <table><thead><tr><th>序号</th><th>书名</th><t…
阅读更多...
【Git】任何位置查看git日志

【Git】任何位置查看git日志

需求 现需要查看指定项目中的某个文件的 Git 日志。如有 项目代码 jflowable &#xff0c;需要查看其下文件 D:\z_workspace\jflowable\src\main\java\com\xzbd\jflowable\controller\TestController.java 的日志。 分析 一般的思路是&#xff0c;进入 jflowable 项目&#…
阅读更多...
网络抓包命令tcpdump

网络抓包命令tcpdump

网络抓包命令tcpdump "tcpdump -i any -nn -vv tcp port 9095 -s 0 -w dump.cap"命令是一个网络抓包命令&#xff0c;用于捕获流经指定网络接口的TCP协议、端口号为9095的网络数据包&#xff0c;并将这些数据包写入到名为"dump.cap"的文件中。 具体参数解…
阅读更多...
ES 之索引和文档

ES 之索引和文档

本文主要介绍ES中的数据组成结构单元。 一、文档(Document) 1、概念 ES的数据存储单元是面向文档的&#xff0c;文档是所有数据存储&#xff0c;搜索的最小单元。 你可以把ES中的文档对应成mysql中的一条条数据记录。到时候你存进ES的数据就是一个个文档。 文档存入ES是序列…
阅读更多...
conda:Collecting package metadata (current_repodata.json): failed

conda:Collecting package metadata (current_repodata.json): failed

使用conda install和conda create命令会出现下面的问题&#xff1a; Collecting package metadata (current_repodata.json): failed Collecting package metadata (current_repodata.json): failed>>>>>>>>>>>>>>>>>>…
阅读更多...
MySQL、Oracle 常用SQL：建表、建视图、数据增删改查、常用condition

MySQL、Oracle 常用SQL：建表、建视图、数据增删改查、常用condition

目录 1 MySQL、Oracle 建表语句整理1.1 MySQL 建表1.2 Oracle 建表1.3 补充1.3.1 主键&#xff1a;新增、删除1.3.2 字段&#xff1a;新增、修改、删除 2 MySQL、Oracle 建视图3 数据&#xff1a;增删改查3.1 插入数据3.1.1 MySQL、Oracle 插入一条数据3.1.2 MySQL、Oracle 插入…
阅读更多...
BRC20通证的诞生与未来展望！如何导入bitget教程

BRC20通证的诞生与未来展望！如何导入bitget教程

BRC-20通证是什么&#xff1f; 嘿&#xff01;你知道BRC-20通证吗&#xff1f;这可是比特币区块链上的超级明星&#xff01;它们不依赖智能合约&#xff0c;而是把JSON代码刻在聪上&#xff0c;聪可是比特币的最小单位哦&#xff01;就像在比特币的乐高积木上盖房子&#xff0…
阅读更多...
dubbo入门案例！！！

dubbo入门案例！！！

入门案例之前我们先介绍一下&#xff1a;zookeeper。 Zookeeper是Apacahe Hadoop的子项目&#xff0c;可以为分布式应用程序协调服务&#xff0c;适合作为Dubbo服务的注册中心&#xff0c;负责服务地址的注册与查找&#xff0c;相当于目录服务&#xff0c;服务提供者和消费者只…
阅读更多...
自动驾驶轨迹规划之碰撞检测（一）

自动驾驶轨迹规划之碰撞检测（一）

欢迎大家关注我的B站&#xff1a; 偷吃薯片的Zheng同学的个人空间-偷吃薯片的Zheng同学个人主页-哔哩哔哩视频 (bilibili.com) 目录 1.碰撞检测的意义 2.安全走廊 3 计算几何 4 AABB与OBB 1.碰撞检测的意义 对于自动驾驶汽车或机器人的路径规划&#xff0c;碰撞检测是其…
阅读更多...
Python 数据类型转换：数据世界的形态转换术

Python 数据类型转换：数据世界的形态转换术

在 Python 中&#xff0c;数据类型转换是一项关键的技能。数据类型的转换使得我们能够在不同类型的数据之间进行转换和操作&#xff0c;提升了我们对数据的处理能力。本文将深入探讨 Python 中的数据类型转换&#xff0c;包括常见的数据类型、转换方法和使用技巧。 常见的数据类…
阅读更多...
HTTP API 认证技术详解（四）：HMAC Authentication

HTTP API 认证技术详解（四）：HMAC Authentication

目录 什么是 HMAC Authentication 认证 HMAC Authentication 原理 HMAC Authentication 认证的步骤 使用 Golang 实现 HMAC Authentication 认证 HMAC Authentication 认证的安全性 HMAC 认证的最佳实践 小结 HTTP API 认证技术主要用于验证客户端身份&#xff0c;并确保…
阅读更多...
M1 MacOS下安卓虚拟化的最佳方案

M1 MacOS下安卓虚拟化的最佳方案

categories: [VM] tags: MacOS VM 写在前面 一直想在桌面环境虚拟化安卓app, 但是看网上的推荐一直感觉不合胃口, 不是要花钱就是有广告, 想着找找开源的实现, 后来发现还是 Google 自家的产品用着舒服. 安装与配置 brew install android-studio然后随便开一个项目, 选默认…
阅读更多...
通过Shell脚本登录MySQL，并执行MySQL命令

通过Shell脚本登录MySQL，并执行MySQL命令

以下是一个通过Shell脚本登录MySQL 8并执行MySQL命令的示例&#xff1a; #!/bin/bash# MySQL服务器地址&#xff08;如果在同一台机器上&#xff0c;可以是localhost或127.0.0.1&#xff09; MYSQL_HOST"localhost"# MySQL服务器端口&#xff08;默认为3306&#xf…
阅读更多...
阿赵UE学习笔记——10、Blender材质和绘制网格体

阿赵UE学习笔记——10、Blender材质和绘制网格体

阿赵UE学习笔记目录   大家好&#xff0c;我是阿赵。   之前介绍了虚幻引擎的材质和材质实例。这次来介绍一个比较有趣的内置的Blender材质。   在用Unity的时候&#xff0c;我做过一个多通道混合地表贴图的效果&#xff0c;而要做过一个刷顶点颜色混合地表和水面的效果。…
阅读更多...
qt绘制生成PDF文件

qt绘制生成PDF文件

引言 之前做项目的时候&#xff0c;需要自己生成一个pdf文件&#xff0c;好久之前保存的草稿&#xff0c;今天就把它发表一下吧&#xff0c;留着自己以后有需要的时候在来查阅。 QString ReportMainWindow::createPdfFile() {QString strDirPath QDir::tempPath() "/T…
阅读更多...
C#封装服务

C#封装服务

C#封装服务 新建服务项目&#xff1b;重构 OnStart 和 OnStop using System; using System.Collections.Generic; using System.ComponentModel; using System.Data; using System.Diagnostics; using System.Linq; using System.ServiceProcess; using System.Text; using S…
阅读更多...
STM32 -- 串口引脚整理

STM32 -- 串口引脚整理

一、引脚分配列表 串口端口发送引脚 &#xff08;TX)接收引脚 (RX)USART1PA9PA10USART2PA2PA3USART3PB10PB11UART4PC10PC11UART5PC12PD2USART6PC6PC7 二、串口引脚的规律 STM32芯片上&#xff0c;引脚功能的布局安排&#xff0c;被设计得很有规律。 不同型号间&#x…
阅读更多...
最新文章

Copyright @ 2022~2023