Jsqlparser简单学习

学习链接

java设计模式：访问者模式

github使用示例参考

测试 JSqlParser使用示例

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

JSqlParser专栏系列教程

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

Sql解析转换之JSqlParse完整介绍

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

模块

访问者模式

访问者模式理解：

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

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

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

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

statement模块

Expression模块

deparser模块

parser模块

测试

TestDrop

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

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.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;

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条件中拼接上刚刚创建的条件, 并使用And连接起来
                AndExpression andExpression = new AndExpression(plainSelect.getWhere(), equalsTo);

                // 替换掉原来的where条件
                plainSelect.setWhere(andExpression);

                // 直接参考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
                System.out.println(statementDeParser.getBuffer());
            }


        }



    }

}