JSqlParser入门系列(2)-JSqlParser简单的增删改查SQL构建_jsqlparser构建sql

前言

JSqlParser可以通过Java代码进行SQL构建。

案例

@SpringBootTest
public class JsqlparserTest {
    /**
     * 简单的构建单表查询
     *
     * @throws JSQLParserException
     */
    @Test
    public void buildSelectSql() throws JSQLParserException {
        Select select01 = SelectUtils.buildSelectFromTable(new Table("test"));
        System.err.println(select01.getSelectBody().toString()); // SELECT * FROM test
        Select select02 = SelectUtils.buildSelectFromTableAndExpressions(new Table("test"), new Column("col1"), new Column("col2"));
        System.err.println(select02.getSelectBody().toString()); // SELECT col1, col2 FROM test
        Select select03 = SelectUtils.buildSelectFromTableAndExpressions(new Table("mytable"), "col1", "col2");
        System.err.println(select03.getSelectBody().toString()); // SELECT col1, col2 FROM test
    }

    /**
     * 构建插入语句
     */
    @Test
    public void buildInsertSql() {
        // 创建表对象设置表名
        Table table = new Table();
        table.setName("table");

        // 创建插入对象
        Insert insert = new Insert();
        insert.setTable(table); // 设置插入对象的表对象

        // 设置插入列
        List<Column> columnList = Arrays.asList(new Column("col01"), new Column("col02"));
        insert.setColumns(columnList);

        // 设置插入值
        MultiExpressionList multiExpressionList = new MultiExpressionList();
        multiExpressionList.addExpressionList(Arrays.asList(new StringValue("1"), new StringValue("2")));
        insert.setItemsList(multiExpressionList);


        System.err.println(insert); // INSERT INTO table (col01, col02) VALUES ('1', '2')
    }

    /**
     * 构建更新语句
     */
    @Test
    public void buildUpdateSql() {
        // 创建表对象设置表名
        Table table = new Table();
        table.setName("table");

        // 创建更新对象
        Update update = new Update();
        update.setTable(table);// 设置更新对象的表对象

        // 设置更新列
        List<Column> columnList = Arrays.asList(new Column("col01"), new Column("col02"));
        update.setColumns(columnList);

        // 设置更新值
        update.setExpressions(Arrays.asList(new StringValue("1"), new StringValue("2")));

        // 添加Where条件
        EqualsTo equalsTo = new EqualsTo(); // 等于表达式
        equalsTo.setLeftExpression(new Column(table,"user_id")); // 设置表达式左边值
        equalsTo.setRightExpression(new StringValue("123456"));// 设置表达式右边值
        update.setWhere(equalsTo); // 设置Where


    }


    /**
     * 构建删除语句
     */
    @Test
    public void buildDeleteSql() {
        // 创建表对象设置表名
        Table table = new Table();
        table.setName("table");

        // 创建更新对象
        Delete delete = new Delete();
        delete.setTable(table);// 设置更新对象的表对象

        // 添加Where条件
        EqualsTo equalsTo = new EqualsTo(); // 等于表达式
        equalsTo.setLeftExpression(new Column(table,"user_id")); // 设置表达式左边值
        equalsTo.setRightExpression(new StringValue("123456"));// 设置表达式右边值
        delete.setWhere(equalsTo); // 设置Where

        // 输入语句
        System.err.println(delete);
    }
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96