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

素颜马尾好姑娘i 2023-10-10 12:36 13阅读 0赞

### 前言 ###

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);
        }
    }