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 {

    @Test
    public void test_drop() {

        // 创建Drop
        Drop drop = new Drop();

        // 创建Table
        Table table = new Table();
        table.setName("sys_user");

        // 设置drop
        drop.setName(table);
        drop.setType("table");
        drop.setIfExists(true);

        // 最终的sql
        StringBuilder stringBuilder = new StringBuilder();

        // 使用DropDeParser来将java对象(封装了sql信息)转为具体的sql语句
        // （这里的代码是参照StatementDeParser#visit(Drop)）
        DropDeParser dropDeParser = new DropDeParser(stringBuilder);
        dropDeParser.deParse(drop);

        // 获取最终的目标sql
        String sql = dropDeParser.getBuffer().toString();

        // DROP table IF EXISTS sys_user
        System.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 {

    @Test
    public 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、WithItem
            SelectDeParser 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 > 10
            System.out.println(buffer);

            SelectBody selectBody = select.getSelectBody();

            if (selectBody instanceof PlainSelect) {

                // 原来的selectBody
                PlainSelect plainSelect = (PlainSelect) select.getSelectBody();

                // age = 18
                EqualsTo 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);

                // 直接参考StatementDeParser
                StatementDeParser 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() {
            @Override
            public void visit(PlainSelect plainSelect) {
                log.info("--------------查询列名----------------------------------------");
                plainSelect.getSelectItems().stream().forEach(selectItem -> {
                    selectItem.accept(new SelectItemVisitorAdapter() {
                        @Override
                        public 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() {
                    @Override
                    public 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
*/

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

如若内容造成侵权/违法违规/事实不符，请联系我们进行投诉反馈qq邮箱809451989@qq.com，一经查实，立即删除！

相关文章

第02章_变量与运算符拓展练习

第02章_变量与运算符拓展练习

文章目录 第02章_变量与运算符拓展练习1、辨别标识符2、数据类型转换简答3、判断如下代码的运行结果(难)4、判断如下程序的运行结果5、判断如下程序的运行结果6、Java的基本数据类型有哪些&#xff1f;String是基本数据类型吗&#xff1f;7、语法判断8、char型变量中是否可以存…
阅读更多...
LeeCode前端算法基础100题（20）找出字符串中第一个匹配项的下标

LeeCode前端算法基础100题（20）找出字符串中第一个匹配项的下标

一、问题详情： 给你两个字符串 haystack 和 needle ，请你在 haystack 字符串中找出 needle 字符串的第一个匹配项的下标（下标从 0 开始）。如果 needle 不是 haystack 的一部分，则返回 -1 。 示例 1： 输入：haystack = "sadbutsad", needle = "s…
阅读更多...
【现代密码学】笔记 补充7-- CCA安全与认证加密《introduction to modern cryphtography》

【现代密码学】笔记 补充7-- CCA安全与认证加密《introduction to modern cryphtography》

【现代密码学】笔记7-- CCA安全与认证加密《introduction to modern cryphtography》 写在最前面7 CCA安全与认证加密 写在最前面 主要在 哈工大密码学课程 张宇老师课件 的基础上学习记录笔记。 内容补充&#xff1a;骆婷老师的PPT 《introduction to modern cryphtography》…
阅读更多...
鸿蒙应用开发学习：让page页面强制横屏

鸿蒙应用开发学习：让page页面强制横屏

一、学习做了个适合横屏的页面但进入页面后是竖屏显示的 前几天在B站上跟着 黑马程序员的 HarmonyOS4.0开发应用教学视频学习了显式动画&#xff08;animateTo&#xff09;和属性动画&#xff08;animation&#xff09;功能&#xff0c;并参照教学视频的内容做了个小鱼动画。…
阅读更多...
助力工业园区作业违规行为检测预警，基于YOLOv7【tiny/l/x】不同系列参数模型开发构建工业园区场景下作业人员违规行为检测识别系统

助力工业园区作业违规行为检测预警，基于YOLOv7【tiny/l/x】不同系列参数模型开发构建工业园区场景下作业人员违规行为检测识别系统

在很多工业园区生产作业场景下保障合规合法进行作业生产操作&#xff0c;对于保护工人生命安全降低安全隐患有着非常重要的作用&#xff0c;但是往往在实际的作业生产中&#xff0c;因为一个安全观念的淡薄或者是粗心大意&#xff0c;对于纪律约束等意思薄弱&#xff0c;导致在…
阅读更多...
绝地求生：【PC】第27赛季第2轮更新公告

绝地求生：【PC】第27赛季第2轮更新公告

各位玩家大家好&#xff01;欢迎收看本期闲游盒更新公告。 正式服维护时间 ※ 下列时间可能会根据维护情况而发生变化。 1月10日上午8:00 – 下午4:30 地图轮换 ※ 地图轮换将于每周三上午10点进行。 ※ 在随机选择地图的地区中&#xff0c;第1周可选择荣都地图&#xff0c…
阅读更多...
UML-通信图和交互概览图（通信图和顺序图的区别与联系）

UML-通信图和交互概览图（通信图和顺序图的区别与联系）

UML-通信图和交互概览图&#xff08;通信图和顺序图的区别与联系&#xff09; 一、通信图简介1.消息2.链接 二、通信图和[顺序图](https://blog.csdn.net/weixin_65032328/article/details/135587782)的联系与区别三、交互概览图四、顺序图转化为通信图练习 一、通信图简介 通…
阅读更多...
CSC8021_computer network_The Transport Layer

CSC8021_computer network_The Transport Layer

Role of the transport layer • The transport layer is responsible for providing a reliable end-to-end connection between two application processes in a network • Abstracting away the physical subnet • Does not involve intermediate nodes • Takes a netwo…
阅读更多...
2024--Django平台开发-Redis集群（十一）

2024--Django平台开发-Redis集群（十一）

内容回顾 主从复制。 哨兵&#xff1a;实例启动了&#xff0c;哨兵节点没启动&#xff0c;Python通过redis-py连接报错。一定要确保实例节点和哨兵节点都启动了。 搭建集群用的是虚拟机的多台centos服务器&#xff0c;你在跟着学习的时候&#xff0c;一定要全部都是虚拟机&am…
阅读更多...
MySQL面试题2

MySQL面试题2

文章目录 面试题 (9-15) 面试题 (9-15) 09&#xff09;查询学过「张三」老师授课的同学的信息 SELECT s.*,c.cname,t.tname FROM t_mysql_teacher t,t_mysql_student s,t_mysql_course c,t_mysql_score sc WHERE t.tidc.tid and c.cidsc.cid and sc.sids.sid and tname ‘张…
阅读更多...
EI级 | Matlab实现VMD-TCN-BiLSTM变分模态分解结合时间卷积双向长短期记忆神经网络多变量光伏功率时间序列预测

EI级 | Matlab实现VMD-TCN-BiLSTM变分模态分解结合时间卷积双向长短期记忆神经网络多变量光伏功率时间序列预测

EI级 | Matlab实现VMD-TCN-BiLSTM变分模态分解结合时间卷积双向长短期记忆神经网络多变量光伏功率时间序列预测 目录 EI级 | Matlab实现VMD-TCN-BiLSTM变分模态分解结合时间卷积双向长短期记忆神经网络多变量光伏功率时间序列预测预测效果基本介绍程序设计参考资料 预测效果 基…
阅读更多...
QLExpress和Groovy对比

QLExpress和Groovy对比

原理 Groovy groovy基于JVM运行。 编译时&#xff1a;将源文件编译成class文件后&#xff0c;用java的classLoader加载&#xff1b;运行时&#xff1a;直接用groovy classLoader加载 QLExpress QLExpress将文本解析成AST&#xff0c;用java对象表达后执行。 特点 Groo…
阅读更多...
如何用LLM和自有知识库搭建智能agent？

如何用LLM和自有知识库搭建智能agent？

用LangChain建立知识库&#xff0c;文末中也推荐其他方案。 项目源码&#xff1a;ChatPDF实现 LangChain Indexes使用 对加载的内容进行索引&#xff0c;在indexes中提供了一些功能&#xff1a; Document Loaders&#xff0c;加载文档Text Splitters&#xff0c;文档切分V…
阅读更多...
android.os.NetworkOnMainThreadException

android.os.NetworkOnMainThreadException

问题 android.os.NetworkOnMainThreadException详细问题 核心代码如下&#xff1a; import android.os.Bundle;import androidx.appcompat.app.AppCompatActivity;import java.io.BufferedReader; import java.io.IOException; import java.io.InputStreamReader; import ja…
阅读更多...
【Java】IDEA中的JFormDesigner使用教程

【Java】IDEA中的JFormDesigner使用教程

目录 1 安装 JFormDesigner 插件2 JFormDesigner 使用教程2.1 新建JFormDesigner Form时的选项2.2 JFormDesigner Form界面布局2.3 JFormDesigner 常用组件 JFormDesigner 是一款用于设计和创建图形用户界面&#xff08;GUI&#xff09;的插件&#xff0c;它允许开发者使用可视…
阅读更多...
鸿蒙Harmony-相对布局（RelativeContainer）详解

鸿蒙Harmony-相对布局（RelativeContainer）详解

成年人的世界&#xff0c;从来没有容易二字&#xff0c;想要什么&#xff0c;就得凭自己的努力去拿&#xff0c;遇到事情就得自己生生的硬抗&#xff0c;希望你即使再辛苦&#xff0c;但还是会选择这滚烫的人生&#xff0c;加油陌生的朋友们 目录 一&#xff0c;定义 二&#x…
阅读更多...
瑞_Java开发手册_（一）编程规约

瑞_Java开发手册_（一）编程规约

文章目录 编程规约的意义&#xff08;一&#xff09;命名风格&#xff08;二&#xff09;常量定义&#xff08;三&#xff09;代码格式&#xff08;四&#xff09;OOP 规约&#xff08;五&#xff09;日期时间&#xff08;六&#xff09;集合处理&#xff08;七&#xff09;并发…
阅读更多...
网络分流规则

网络分流规则

现在的网络是越来越复杂。 有必要进行分流。 有一些geosite.dat是已经整理好的&#xff0c;包含许多的网站的分类&#xff1a; 分流规则&#xff1a; route规则 主要是: {"type": "field","outboundTag": "direct","domain&quo…
阅读更多...
Material Design 进阶（十一）——Chip,ChipGroup,ChipDrawable使用

Material Design 进阶（十一）——Chip,ChipGroup,ChipDrawable使用

流式布局标签发展历程 第一阶段&#xff1a;实现这种界面的时候&#xff0c;基本都是自定义一个控件&#xff0c;然后在Java代码中动态的 添加一个个的TextView&#xff0c;还需要计算布局宽度/高度&#xff0c;进行换行等等处理&#xff0c;比较复杂;第二阶段&#xff1a;使用…
阅读更多...
cad二次开发autolisp（一）

cad二次开发autolisp（一）

文章目录 一、概述1.1 简介1.2 打开编辑器1.3 调试页面 二、数据类型三、函数3.1 用户函数 四、语句4.1 常规语句4.2 流程控制语句 五、图元操作5.1 定义5.2 图元选择5.3 图元属性列表 一、概述 1.1 简介 简介&#xff1a;cad 二次开发语言&#xff0c;后缀名*.lsp适用于编写…
阅读更多...
最新文章

Copyright @ 2022~2023