首页 > 解决方案 > 如何使用 JSqlParser 添加新条件?

问题描述

我想向我的 sql 添加新条件。例如如果查询是;

SELECT EMP_ID, FIRST_NAME FROM EMPLOYEES;

我可以使用此代码添加新的 where 原因;

@Override
protected void setLimit(final PlainSelect ps,final long rowLimit) {
    Expression where = ps.getWhere();
    if(where == null) {
         try {
            where = CCJSqlParserUtil.parseCondExpression("ROWNUM < " + (rowLimit+1) );
        } catch (JSQLParserException e) {
            e.printStackTrace();
        }
    }
    ps.setWhere(where);
}

此代码将查询更改为

SELECT EMP_ID, FIRST_NAME FROM EMPLOYEES WHERE ROWNUM < 10;

...

但问题是查询是什么时候;

 SELECT EMP_ID, FIRST_NAME FROM EMPLOYEES WHERE EMP_ID = 10 AND EMP_ID = 10 AND FIRST_NAME = 'Steven'; 

我无法向当前条件添加新条件。有没有办法将此查询更改为喜欢;

 SELECT EMP_ID, FIRST_NAME FROM EMPLOYEES WHERE EMP_ID = 10 AND EMP_ID = 10 AND FIRST_NAME = 'Steven' AND ROWNUM < 10; 

有没有办法用 JSqlParser 做到这一点?

标签: javajsqlparser

解决方案


所以这里有两种可能的解决方案(这次比我之前的评论多一点:)):

    var sql = "SELECT EMP_ID, FIRST_NAME FROM EMPLOYEES WHERE EMP_ID = 10 AND EMP_ID = 10 AND FIRST_NAME = 'Steven'";
    var select = (Select) CCJSqlParserUtil.parse(sql);
    var plainselect = (PlainSelect) select.getSelectBody();
    
    //1. add another condition by deparsing the old one and integrate it into
    //a new expression, which is parsed and then set into your statement.        
    var where = CCJSqlParserUtil.parseCondExpression(plainselect.getWhere() 
           + " and ROWNUM < 10");
   
    //2. second is building a new AndExpression and sets the left item to the
    //original where condition and adds a new condition as the right item.
    var where2 = new AndExpression(plainselect.getWhere(),
           CCJSqlParserUtil.parseCondExpression("ROWNUM < 10"));
    
    //output both versions. in fact they should and are identical.
    plainselect.setWhere(where);
    System.out.println(select.toString());
    
    plainselect.setWhere(where2);
    System.out.println(select.toString());

此代码输出以下两次:

SELECT EMP_ID, FIRST_NAME FROM EMPLOYEES WHERE EMP_ID = 10 AND EMP_ID = 10 AND FIRST_NAME = 'Steven' AND ROWNUM < 10

这是一个 Java >=V10 代码。然而,稍作调整,它也可以使用 JDK 8 运行。

  1. 这个变体只是将实际的 where 语句转换为字符串,然后用它构建你想要的条件。然后使用 JSqlParser ( CCJSqlParserUtil.parseCondExpression ) 解析生成的字符串表达式,并将生成的表达式设置到解析后的普通选择语句 ( plainselect.setWhere )

  2. 第二个变体使用解析的对象并围绕它构建一个AndExpression。要添加的表达式也被构造或再次使用CCJSqlParserUtil.parseCondExpression解析并添加到构造的AndExpression中。

重要的是要知道,这会构造某种JSqlParser对象树项,并且不会一对一地映射到 SQL 的实际语义。为此,您应该使用括号来确保这一点,再次使用类型 1 或 2。顺便说一句,括号是使用Parenthesis对象构造的。

因此,使用这种技术,您可以对JSqlParsers对象树进行各种更改。


推荐阅读