zoukankan      html  css  js  c++  java
  • sql-builder 2.x 介绍

    原文链接:sql-builder 2.x 介绍

    针对sql-builder 用法不友好问题,所以花了很大的决心试着想 sql-builder 重写了一遍(2.x版本),希望能用得更加爽点,之后再重写一遍 ibit-mybatis,支持 sql-builder 2.x。详细用法参考sql-builder 2.x api文档

    核心类说明

    使用SqlFactory 构造Sql对象

    @UtilityClass
    public class SqlFactory {
    
        /**
         * 创建搜索
         *
         * @return 搜索sql
         */
        public SearchSql createSearch() {
            return new SearchSqlImpl();
        }
    
    
        /**
         * 创建计数
         *
         * @return 计数sql
         */
        public CountSql createCount() {
            return new CountSqlImpl();
        }
    
        /**
         * 创建删除
         *
         * @return 删除sql
         */
        public DeleteSql createDelete() {
            return new DeleteSqlImpl();
        }
    
        /**
         * 创建插入
         *
         * @return 插入sql
         */
        public InsertSql createInsert() {
            return new InsertSqlImpl();
        }
    
        /**
         * 创建更新
         *
         * @return 更新sql
         */
        public UpdateSql createUpdate() {
            return new UpdateSqlImpl();
        }
    
    }
    

    sql对象说明

    接口 说明
    SearchSql 搜索
    CountSql 计数
    DeleteSql 删除
    InsertSql 插入
    UpdateSql 更新

    说明: 上述类都继承 SqlSupport<T>, 方法 PrepareStatement getPrepareStatement(); 返回的对应的预查询sql对象(包含预查询sql和对应参数列表)。

    PrepareStatement 说明

    @Data
    @AllArgsConstructor
    public class PrepareStatement {
    
        /**
         * 预查询SQL
         */
        private String prepareSql;
    
        /**
         * 插入值列表
         */
        private List<ColumnValue> values;
    
        /**
         * 获取空的PrepareStatement
         *
         * @return PrepareStatement
         */
        public static PrepareStatement empty() {
            return new PrepareStatement("", Collections.emptyList());
        }
    
        /**
         * 获取参数列表
         *
         * @return 参数列表
         */
        public List<Object> getParams() {
            if (CollectionUtils.isEmpty(values)) {
                return Collections.emptyList();
            }
            return values.stream().map(ColumnValue::getValue).collect(Collectors.toList());
        }
    }
    

    说明: values 为 ColumnValue, 主要为了之后做字段加密解密预留的,知道对应列与相应的值。

    Sql构造示例

    详细测试用例查看:tech.ibit.sqlbuilder.SqlTest

    select

    // 传入列
    SearchSql sql = SqlFactory.createSearch()
            .column(
                    Arrays.asList(
                            UserProperties.userId,
                            UserProperties.name)
            )
            .from(UserProperties.TABLE);
    assertPrepareStatementEquals("SELECT u.user_id, u.name FROM user u", sql.getPrepareStatement());
    
    // 支持聚合函数
    sql = SqlFactory.createSearch()
            .column(
                    Arrays.asList(
                            UserProperties.userId.sum("user_id_sum"),
                            UserProperties.userId.avg("user_id_avg")
                    )
            ).from(UserProperties.TABLE)
            .groupBy(UserProperties.userId);
    assertPrepareStatementEquals(
            "SELECT SUM(u.user_id) AS user_id_sum, AVG(u.user_id) AS user_id_avg FROM user u GROUP BY u.user_id",
            sql.getPrepareStatement());
    
    

    select distinct

    SearchSql sql = SqlFactory.createSearch()
            .distinct()
            .column(UserProperties.email)
            .from(UserProperties.TABLE);
    assertPrepareStatementEquals(
            "SELECT DISTINCT u.email FROM user u",
            sql.getPrepareStatement());
    

    select 传入类

    SearchSql sql = SqlFactory.createSearch()
            .columnPo(UserPo.class)
            .from(UserProperties.TABLE);
    assertPrepareStatementEquals(
            "SELECT u.user_id, u.login_id, u.email, u.mobile_phone, u.type FROM user u",
            sql.getPrepareStatement());
    
    

    select distinct 传入类

    SearchSql sql = SqlFactory.createSearch()
            .distinct()
            .columnPo(UserPo.class)
            .from(UserProperties.TABLE).limit(1000);
    
    assertPrepareStatementEquals(
            "SELECT DISTINCT u.user_id, u.login_id, u.email, u.mobile_phone, u.type FROM user u LIMIT ?, ?",
            Arrays.asList(
                    getStartColumn().value(0),
                    getLimitColumn().value(1000)
            ), sql.getPrepareStatement());
    

    count

    CountSql sql = SqlFactory.createCount()
            .from(UserProperties.TABLE);
    assertPrepareStatementEquals("SELECT COUNT(*) FROM user u", sql.getPrepareStatement());
    

    count distinct

    // 传入单列
    CountSql sql = SqlFactory.createCount()
            .distinct()
            .column(UserProperties.userId)
            .from(UserProperties.TABLE);
    assertPrepareStatementEquals(
            "SELECT COUNT(DISTINCT u.user_id) FROM user u",
            sql.getPrepareStatement());
    
    // 传入多列
    sql = SqlFactory.createCount()
            .distinct()
            .column(
                    Arrays.asList(
                            UserProperties.name,
                            UserProperties.email
                    )
            )
            .from(UserProperties.TABLE);
    assertPrepareStatementEquals(
            "SELECT COUNT(DISTINCT u.name, u.email) FROM user u",
            sql.getPrepareStatement());
    

    delete from(异常)

    // 删除操作必须包含where语句,不然这个操作很危险
    DeleteSql sql = SqlFactory.createDelete()
            .deleteFrom(UserProperties.TABLE);
    thrown.expect(RuntimeException.class);
    thrown.expectMessage("Where cannot be empty when do deleting!");
    sql.getPrepareStatement();
    

    delete from(单表删除)

    // 代码片段1:正常删除
    DeleteSql sql = SqlFactory.createDelete()
            .deleteFrom(UserProperties.TABLE)
            .andWhere(UserProperties.userId.eq(1));
    assertPrepareStatementEquals(
            "DELETE u.* FROM user u WHERE u.user_id = ?",
            Collections.singletonList(
                    UserProperties.userId.value(1)
            ),
            sql.getPrepareStatement());
            
    // 代码片段2:等价于代码片段1
    sql = SqlFactory.createDelete()
            .delete(UserProperties.TABLE)
            .from(UserProperties.TABLE)
            .andWhere(UserProperties.userId.eq(1));
    assertPrepareStatementEquals(
            "DELETE u.* FROM user u WHERE u.user_id = ?",
            Collections.singletonList(
                    UserProperties.userId.value(1)
            ),
            sql.getPrepareStatement());             
    

    delete from(多表删除)

    // 代码片段1:支持join on
    DeleteSql sql = SqlFactory.createDelete()
            .deleteFrom(UserProperties.TABLE)
            .andWhere(UserProperties.userId.eq(1))
            .leftJoinOn(
                    OrganizationProperties.TABLE,
                    Arrays.asList(
                            UserProperties.orgId,
                            OrganizationProperties.orgId
                    )
            );
    assertPrepareStatementEquals(
            "DELETE u.* FROM user u LEFT JOIN organization o ON u.org_id = o.org_id WHERE u.user_id = ?",
            Collections.singletonList(
                    UserProperties.userId.value(1)
            ),
            sql.getPrepareStatement()); 
    
    // 代码片段2:支持多from
    sql = SqlFactory.createDelete()
            .delete(UserProperties.TABLE)
            .from(
                    Arrays.asList(
                            UserProperties.TABLE,
                            OrganizationProperties.TABLE
                    )
            )
            .andWhere(OrganizationProperties.orgId.eq(UserProperties.orgId))
            .andWhere(UserProperties.userId.eq(1));
    assertPrepareStatementEquals(
            "DELETE u.* FROM user u, organization o WHERE o.org_id = u.org_id AND u.user_id = ?",
            Collections.singletonList(
                    UserProperties.userId.value(1)
            ),
            sql.getPrepareStatement());
    
    

    update(异常)

    // update操作必须包含where语句,不然这操作很危险
    Sql sql = new Sql()
            .update(UserProperties.TABLE)
            .set(new ColumnValue(UserProperties.name, "IBIT"));
    thrown.expect(RuntimeException.class);
    thrown.expectMessage("Where cannot be empty when do updating!");
    sql.getSqlParams();
    

    update(正常更新)

    UpdateSql sql = SqlFactory
            .createUpdate()
            .update(UserProperties.TABLE)
            .set(UserProperties.name.set("IBIT"))
            .andWhere(UserProperties.userId.eq(1));
    
    assertPrepareStatementEquals(
            "UPDATE user u SET u.name = ? WHERE u.user_id = ?",
            Arrays.asList(
                    UserProperties.name.value("IBIT"),
                    UserProperties.userId.value(1)
            ),
            sql.getPrepareStatement());
    

    set

    UpdateSql sql = SqlFactory.createUpdate()
            .update(UserProperties.TABLE)
            .set(
                    Arrays.asList(
                            UserProperties.name.set("IBIT"),
                            UserProperties.loginId.set("188"),
                            UserProperties.avatarId.set(null)
                    )
            ).andWhere(UserProperties.userId.eq(1));
    
    assertPrepareStatementEquals(
            "UPDATE user u SET u.name = ?, u.login_id = ?, u.avatar_id = ? WHERE u.user_id = ?",
            Arrays.asList(
                    UserProperties.name.value("IBIT"),
                    UserProperties.loginId.value("188"),
                    UserProperties.avatarId.value(null),
                    UserProperties.userId.value(1)
            ),
            sql.getPrepareStatement());
    

    set 字段增长

    UpdateSql sql = SqlFactory.createUpdate()
            .update(UserProperties.TABLE)
            .set(UserProperties.loginTimes.increaseSet(2))
            .andWhere(UserProperties.userId.eq(1));
    assertPrepareStatementEquals(
            "UPDATE user u SET u.login_times = u.login_times + ? WHERE u.user_id = ?",
            Arrays.asList(
                    UserProperties.loginTimes.value(2),
                    UserProperties.userId.value(1)
            ),
            sql.getPrepareStatement());
    

    set 字段递减

    UpdateSql sql = SqlFactory.createUpdate()
            .update(UserProperties.TABLE)
            .set(UserProperties.loginTimes.decreaseSet(2))
            .andWhere(UserProperties.userId.eq(1));
    assertPrepareStatementEquals(
            "UPDATE user u SET u.login_times = u.login_times - ? WHERE u.user_id = ?",
            Arrays.asList(
                    UserProperties.loginTimes.value(2),
                    UserProperties.userId.value(1)
            ),
            sql.getPrepareStatement());
    

    insert into & values

    InsertSql sql = SqlFactory.createInsert()
            .insert(UserProperties.TABLE)
            .values(
                    Arrays.asList(
                            UserProperties.name.value("IBIT"),
                            UserProperties.loginId.value("188"),
                            UserProperties.avatarId.value(null)
                    )
            );
    
    assertPrepareStatementEquals(
            "INSERT INTO user(name, login_id, avatar_id) VALUES(?, ?, ?)",
            Arrays.asList(
                    UserProperties.name.value("IBIT"),
                    UserProperties.loginId.value("188"),
                    UserProperties.avatarId.value(null)
            ),
            sql.getPrepareStatement());
    

    from

    // 单个from
    SearchSql sql = SqlFactory.createSearch()
            .column(
                    Arrays.asList(
                            ProjectProperties.projectId,
                            ProjectProperties.name
                    )
            )
            .from(ProjectProperties.TABLE);
    assertPrepareStatementEquals(
            "SELECT p.project_id, p.name FROM project p",
            sql.getPrepareStatement());
    
    // 多个from    
    sql = SqlFactory.createSearch()
            .column(
                    Arrays.asList(
                            UserProperties.userId, 
                            UserProperties.name, 
                            ProjectProperties.name
                    )
            )
            .from(UserProperties.TABLE)
            .from(ProjectProperties.TABLE)
            .andWhere(UserProperties.currentProjectId.eq(ProjectProperties.projectId));
    assertPrepareStatementEquals(
            "SELECT u.user_id, u.name, p.name FROM user u, project p WHERE u.current_project_id = p.project_id",
            sql.getPrepareStatement());
    

    join on(left, right, full, inner)

    // 代码片段1:join on
    SearchSql sql = SqlFactory.createSearch()
            .column(
                    Arrays.asList(
                            UserProperties.userId, 
                            UserProperties.name, 
                            ProjectProperties.name
                    )
            )
            .from(UserProperties.TABLE)
            .joinOn(
                    ProjectProperties.TABLE, 
                    Arrays.asList(
                            UserProperties.currentProjectId, 
                            ProjectProperties.projectId
                    )
            );
    assertPrepareStatementEquals(
            "SELECT u.user_id, u.name, p.name FROM user u JOIN project p ON u.current_project_id = p.project_id", 
            sql.getPrepareStatement());
    
    // 代码片段:left join on
    sql = SqlFactory.createSearch()
            .column(
                    Arrays.asList(
                            UserProperties.userId, 
                            UserProperties.name, 
                            ProjectProperties.name
                    )
            )
            .from(UserProperties.TABLE)
            .leftJoinOn(
                    ProjectProperties.TABLE, 
                    Arrays.asList(
                            UserProperties.currentProjectId, 
                            ProjectProperties.projectId
                    )
            );
    assertPrepareStatementEquals(
            "SELECT u.user_id, u.name, p.name FROM user u LEFT JOIN project p ON u.current_project_id = p.project_id", 
            sql.getPrepareStatement());
    
    // 省略其他join
    

    复杂 join on(支持on后面增加条件,left, right, full, inner)

    // 代码片段1:on 列相等
    SearchSql sql = SqlFactory.createSearch()
            .column(
                    Arrays.asList(
                            UserProperties.userId,
                            UserProperties.name,
                            ProjectProperties.name
                    )
            )
            .from(UserProperties.TABLE)
            .complexLeftJoinOn(
                    ProjectProperties.TABLE,
                    Collections.singletonList(
                            UserProperties.currentProjectId.eq(ProjectProperties.projectId)
                    )
            );
    assertPrepareStatementEquals(
            "SELECT u.user_id, u.name, p.name FROM user u LEFT JOIN project p ON u.current_project_id = p.project_id",
            sql.getPrepareStatement());
    
    // 代码片段2:on 条件语句
    sql = SqlFactory.createSearch()
            .column(
                    Arrays.asList(
                            UserProperties.userId,
                            UserProperties.name,
                            ProjectProperties.name
                    )
            )
            .from(UserProperties.TABLE)
            .complexLeftJoinOn(
                    ProjectProperties.TABLE,
                    Arrays.asList(
                            UserProperties.currentProjectId.eq(ProjectProperties.projectId),
                            ProjectProperties.name.like("小%")
                    )
            );
    assertPrepareStatementEquals(
            "SELECT u.user_id, u.name, p.name FROM user u LEFT JOIN project p ON u.current_project_id = p.project_id AND p.name LIKE ?",
            Collections.singletonList(
                    ProjectProperties.name.value("小%")
            ),
            sql.getPrepareStatement());
            
    // 省略其他join
    ...
    

    where(支持构造复杂的where语句)

    List<CriteriaItem> xiaoLikeItems = Arrays.asList(
            UserProperties.name.like("小%"),
            UserProperties.email.like("xiao%"));
    
    CriteriaItem userIdItem = UserProperties.userId.gt(100);
    CriteriaItem type1Item = UserProperties.type.eq(1);
    CriteriaItem type2Item = UserProperties.type.eq(2);
    
    SearchSql sql = SqlFactory.createSearch()
            .column(
                    Arrays.asList(
                            UserProperties.userId,
                            UserProperties.name
                    )
            )
            .from(UserProperties.TABLE)
            .where(
                    Criteria.ands(
                            Arrays.asList(
                                    Criteria.ors(xiaoLikeItems),
                                    userIdItem)
                    )
            );
    assertPrepareStatementEquals(
            "SELECT u.user_id, u.name FROM user u WHERE (u.name LIKE ? OR u.email LIKE ?) AND u.user_id > ?",
            Arrays.asList(
                    UserProperties.name.value("小%"),
                    UserProperties.email.value("xiao%"),
                    UserProperties.userId.value(100)
            ),
            sql.getPrepareStatement());
    
    
    sql = SqlFactory.createSearch()
            .column(
                    Arrays.asList(
                            UserProperties.userId,
                            UserProperties.name
                    )
            ).from(UserProperties.TABLE)
            .where(
                    Criteria.ands(
                            Arrays.asList(
                                    Criteria.ors(xiaoLikeItems),
                                    Criteria.ors(Collections.singletonList(userIdItem))
                            )
                    )
            );
    assertPrepareStatementEquals(
            "SELECT u.user_id, u.name FROM user u WHERE (u.name LIKE ? OR u.email LIKE ?) AND u.user_id > ?",
            Arrays.asList(
                    UserProperties.name.value("小%"),
                    UserProperties.email.value("xiao%"),
                    UserProperties.userId.value(100)
            ),
            sql.getPrepareStatement());
    
    sql = SqlFactory.createSearch()
            .column(
                    Arrays.asList(
                            UserProperties.userId,
                            UserProperties.name)
            )
            .from(UserProperties.TABLE)
            .where(
                    Criteria.ors(Arrays.asList(
                            Criteria.ands(
                                    Arrays.asList(
                                            Criteria.ands(
                                                    Arrays.asList(
                                                            Criteria.ors(xiaoLikeItems),
                                                            Criteria.ors(Collections.singletonList(userIdItem)))
                                            ),
                                            type1Item)
                            ), type2Item))
            );
    assertPrepareStatementEquals(
            "SELECT u.user_id, u.name FROM user u WHERE (((u.name LIKE ? OR u.email LIKE ?) AND u.user_id > ?) AND u.type = ?) OR u.type = ?",
            Arrays.asList(
                    UserProperties.name.value("小%"),
                    UserProperties.email.value("xiao%"),
                    UserProperties.userId.value(100),
                    UserProperties.type.value(1),
                    UserProperties.type.value(2)
            ),
            sql.getPrepareStatement());
    

    where and

    SearchSql sql = SqlFactory.createSearch()
            .column(
                    Arrays.asList(
                            UserProperties.userId,
                            UserProperties.name
                    )
            )
            .from(UserProperties.TABLE)
            .andWhere(UserProperties.userId.eq(1))
            .limit(1);
    
    assertPrepareStatementEquals(
            "SELECT u.user_id, u.name FROM user u WHERE u.user_id = ? LIMIT ?, ?",
            Arrays.asList(
                    UserProperties.userId.value(1),
                    getStartColumn().value(0),
                    getLimitColumn().value(1)
            ),
            sql.getPrepareStatement());
    
    sql = SqlFactory.createSearch()
            .column(
                    Arrays.asList(
                            UserProperties.userId,
                            UserProperties.name
                    )
            )
            .from(UserProperties.TABLE)
            .andWhere(
                    Criteria.ors(
                            Arrays.asList(
                                    UserProperties.name.like("小%"),
                                    UserProperties.email.like("xiao%"))
                    )
            )
            .limit(1);
    

    where or

    SearchSql sql = SqlFactory.createSearch()
            .column(
                    Arrays.asList(
                            UserProperties.userId,
                            UserProperties.name
                    )
            )
            .from(UserProperties.TABLE)
            .orWhere(UserProperties.userId.eq(1))
            .limit(1);
    assertPrepareStatementEquals(
            "SELECT u.user_id, u.name FROM user u WHERE u.user_id = ? LIMIT ?, ?",
            Arrays.asList(
                    UserProperties.userId.value(1),
                    getStartColumn().value(0),
                    getLimitColumn().value(1)
            ),
            sql.getPrepareStatement());
    
    sql = SqlFactory.createSearch()
            .column(
                    Arrays.asList(
                            UserProperties.userId,
                            UserProperties.name
                    )
            ).from(UserProperties.TABLE)
            .orWhere(
                    Criteria.ands(
                            Arrays.asList(
                                    UserProperties.name.like("小%"),
                                    UserProperties.email.like("xiao%")
                            )
                    )
            )
            .limit(1);
    assertPrepareStatementEquals(
            "SELECT u.user_id, u.name FROM user u WHERE (u.name LIKE ? AND u.email LIKE ?) LIMIT ?, ?",
            Arrays.asList(
                    UserProperties.name.value("小%"),
                    UserProperties.email.value("xiao%"),
                    getStartColumn().value(0),
                    getLimitColumn().value(1)
            ),
            sql.getPrepareStatement());
    

    where 支持flag条件

    SearchSql sql = SqlFactory.createSearch()
            .column(
                    Arrays.asList(
                            UserProperties.userId,
                            UserProperties.name
                    )
            )
            .from(UserProperties.TABLE)
            .andWhere(UserProperties.userId.noFlgs(1));
    assertPrepareStatementEquals(
            "SELECT u.user_id, u.name FROM user u WHERE u.user_id & ? = 0",
            Collections.singletonList(
                    UserProperties.userId.value(1)
            ),
            sql.getPrepareStatement());
            
    // Column 还有 allFlgs(), anyFlgs()方法
    ...              
    

    order by

    SearchSql sql = SqlFactory.createSearch()
            .column(
                    Arrays.asList(
                            UserProperties.userId,
                            UserProperties.name,
                            ProjectProperties.name)
            )
            .from(UserProperties.TABLE)
            .leftJoinOn(
                    ProjectProperties.TABLE,
                    Arrays.asList(
                            UserProperties.currentProjectId,
                            ProjectProperties.projectId)
            )
            .orderBy(
                    Arrays.asList(
                            ProjectProperties.projectId.orderBy(),
                            UserProperties.userId.orderBy(true)
                    ))
            .limit(1000);
    assertPrepareStatementEquals(
            "SELECT u.user_id, u.name, p.name FROM user u LEFT JOIN project p ON u.current_project_id = p.project_id ORDER BY p.project_id, u.user_id DESC LIMIT ?, ?",
            Arrays.asList(
                    getStartColumn().value(0),
                    getLimitColumn().value(1000)
            ),
            sql.getPrepareStatement());
    

    自定义order by(mysql语法)

    SearchSql sql = SqlFactory.createSearch()
            .column(
                    Arrays.asList(
                            UserProperties.userId,
                            UserProperties.name,
                            ProjectProperties.name)
            )
            .from(UserProperties.TABLE)
            .leftJoinOn(
                    ProjectProperties.TABLE,
                    Arrays.asList(
                            UserProperties.currentProjectId,
                            ProjectProperties.projectId
                    )
            )
            .orderBy(
                    Arrays.asList(
                            ProjectProperties.projectId.orderBy(),
                            UserProperties.userId.customerOrderBy(Arrays.asList(1, 2, 3), true)
                    )
            );
    assertPrepareStatementEquals(
            "SELECT u.user_id, u.name, p.name FROM user u LEFT JOIN project p ON u.current_project_id = p.project_id ORDER BY p.project_id"
                    + ", FIELD(u.user_id, ?, ?, ?) DESC",
            Arrays.asList(
                    UserProperties.userId.value(1),
                    UserProperties.userId.value(2),
                    UserProperties.userId.value(3)
            ),
            sql.getPrepareStatement());
    

    聚合列 order by

    AggregateColumn minAge = UserProperties.age.min("min_age");
    AggregateColumn maxAge = UserProperties.age.max("max_age");
    
    SearchSql sql = SqlFactory.createSearch()
            .column(
                    Arrays.asList(
                            minAge,
                            maxAge,
                            UserProperties.gender
                    ))
            .from(UserProperties.TABLE)
            .andWhere(UserProperties.age.egt(0))
            .groupBy(UserProperties.gender)
            .andHaving(
                    minAge.egt(1)
            )
            .orderBy(
                    Arrays.asList(
                            UserProperties.gender.orderBy(),
                            minAge.orderBy(true)
                    )
            );
    assertPrepareStatementEquals(
            "SELECT MIN(u.age) AS min_age, MAX(u.age) AS max_age, u.gender FROM user u WHERE u.age >= ? " +
                    "GROUP BY u.gender HAVING min_age >= ? ORDER BY u.gender, min_age DESC",
            Arrays.asList(
                    UserProperties.age.value(0),
                    minAge.value(1)
            ),
            sql.getPrepareStatement());
    

    group by & having

    AggregateColumn minAge = UserProperties.age.min("min_age");
    AggregateColumn maxAge = UserProperties.age.max("max_age");
    
    SearchSql sql = SqlFactory.createSearch()
            .column(
                    Arrays.asList(
                            minAge,
                            maxAge,
                            UserProperties.gender
                    ))
            .from(UserProperties.TABLE)
            .andWhere(UserProperties.age.egt(0))
            .groupBy(UserProperties.gender)
            .having(minAge.egt(1).and());
    assertPrepareStatementEquals(
            "SELECT MIN(u.age) AS min_age, MAX(u.age) AS max_age, u.gender FROM user u WHERE u.age >= ? GROUP BY u.gender HAVING min_age >= ?",
            Arrays.asList(
                    UserProperties.age.value(0),
                    minAge.value(1)
            ),
            sql.getPrepareStatement());
    

    having and

    SearchSql sql = SqlFactory.createSearch()
            .column(
                    Arrays.asList(
                            minAge,
                            maxAge,
                            UserProperties.gender
                    ))
            .from(UserProperties.TABLE)
            .andWhere(UserProperties.age.egt(0))
            .groupBy(UserProperties.gender)
            .andHaving(
                    Criteria.ors(
                            Arrays.asList(
                                    minAge.egt(1),
                                    maxAge.egt(2)
                            )
                    )
            )
            .andHaving(
                    Criteria.ors(
                            Arrays.asList(
                                    minAge.egt(3),
                                    maxAge.egt(4)
                            ))
            );
    assertPrepareStatementEquals("SELECT MIN(u.age) AS min_age, MAX(u.age) AS max_age, u.gender FROM user u WHERE u.age >= ? GROUP BY u.gender "
                    + "HAVING (min_age >= ? OR max_age >= ?) AND (min_age >= ? OR max_age >= ?)",
            Arrays.asList(
                    UserProperties.age.value(0),
                    minAge.value(1),
                    maxAge.value(2),
                    minAge.value(3),
                    maxAge.value(4)
            ),
            sql.getPrepareStatement());
    

    having or

    SearchSql sql = SqlFactory.createSearch()
            .column(
                    Arrays.asList(
                            UserProperties.age.min("min_age"),
                            UserProperties.age.max("max_age"),
                            UserProperties.gender
                    ))
            .from(UserProperties.TABLE)
            .andWhere(UserProperties.age.egt(0))
            .groupBy(UserProperties.gender)
            .orHaving(
                    Criteria.ands(
                            Arrays.asList(
                                    minAge.egt(1),
                                    maxAge.egt(2)
                            )
                    )
            )
            .orHaving(
                    Criteria.ands(
                            Arrays.asList(
                                    minAge.egt(3),
                                    maxAge.egt(4)
                            ))
            );
    assertPrepareStatementEquals("SELECT MIN(u.age) AS min_age, MAX(u.age) AS max_age, u.gender FROM user u WHERE u.age >= ? GROUP BY u.gender "
                    + "HAVING (min_age >= ? AND max_age >= ?) OR (min_age >= ? AND max_age >= ?)",
            Arrays.asList(
                    UserProperties.age.value(0),
                    minAge.value(1),
                    maxAge.value(2),
                    minAge.value(3),
                    maxAge.value(4)
            ),
            sql.getPrepareStatement());
    
    

    limit

    SearchSql sql = SqlFactory.createSearch()
            .column(
                    Arrays.asList(
                            UserProperties.userId,
                            UserProperties.name,
                            ProjectProperties.name
                    )
            )
            .from(UserProperties.TABLE)
            .leftJoinOn(
                    ProjectProperties.TABLE,
                    Arrays.asList(
                            UserProperties.currentProjectId,
                            ProjectProperties.projectId
                    )
            )
            .orderBy(
                    Arrays.asList(
                            ProjectProperties.projectId.orderBy(),
                            UserProperties.userId.orderBy(true)
                    )
            )
            .limit(10);
    assertPrepareStatementEquals("SELECT u.user_id, u.name, p.name FROM user u LEFT JOIN project p ON u.current_project_id = p.project_id ORDER BY p.project_id"
                    + ", u.user_id DESC LIMIT ?, ?",
            Arrays.asList(
                    getStartColumn().value(0),
                    getLimitColumn().value(10)
            ),
            sql.getPrepareStatement());
    

    其他说明

    tech.ibit.sqlbuilder.Column

    @Getter
    @Setter
    @AllArgsConstructor
    public class Column implements IColumn,
            IColumnCriteriaItemBuilder, IColumnAggregateBuilder, IColumnSetItemBuilder, IColumnOrderByBuilder { 
    
         // 省略实现代码
         ...
         
    }
    

    实现了多个接口支持快速通过类创建where语句聚合函数set语句order by语句

    相关maven依赖包

    <dependency>
      <groupId>tech.ibit</groupId>
      <artifactId>sql-builder</artifactId>
      <version>2.x</version>
    </dependency>
    

    版权声明: Apache 2

    公众号

    喜欢我的文章,请关注公众号

  • 相关阅读:
    sort uniq 命令 企业应用场景实战排序
    网络管理相关命令常用必回基础实战
    Zabbix 3.0入门到企业实战(自带模板介绍)
    jsp页面指令
    jsp九大内置对象
    如何将静态页面转化为动态页面
    转发与重定向区别
    cookie的保存时间
    登陆界面 实现思路
    卸载了mysql之后,mysql服务仍在,显示读取描述失败,错误代码2
  • 原文地址:https://www.cnblogs.com/javaDeveloper/p/13086150.html
Copyright © 2011-2022 走看看