跳至主要內容

查询

xuejmnet大约 12 分钟

查询

easy-query在java的静态语言特性下，参考众多C# ORM(efcore,freesql,sqlsugar...),和java ORM(mybatis-plus,beetlsql...)实现了支持单表多表，复杂，嵌套的sql表达式，并且拥有强类型语法提示，可以帮助不想写sql的用户，有洁癖的用户多一个选择.

单表查询

//根据条件查询表中的第一条记录
List<Topic> topics = easyEntityQuery
                .queryable(Topic.class)
                .limit(1)
                .toList();
==> Preparing: SELECT t.`id`,t.`stars`,t.`title`,t.`create_time` FROM t_topic t LIMIT 1
<== Total: 1

//根据条件查询表中的第一条记录
Topic topic = easyEntityQuery
                .queryable(Topic.class)
                .firstOrNull();
==> Preparing: SELECT t.`id`,t.`stars`,t.`title`,t.`create_time` FROM t_topic t LIMIT 1
<== Total: 1 

//根据条件查询id为3的记录
Topic topic = easyEntityQuery
        .queryable(Topic.class)
        .where(o->o.id().eq("3"))
        .firstOrNull();
==> Preparing: SELECT t.`id`,t.`stars`,t.`title`,t.`create_time` FROM t_topic t WHERE t.`id` = ? LIMIT 1
==> Parameters: 3(String)
<== Total: 1


Topic topic = easyEntityQuery
        .queryable(Topic.class)
        .where(o->{
                o.id().eq("3");
                o.title().like("3");
        })
        .firstOrNull();
==> Preparing: SELECT t.`id`,t.`stars`,t.`title`,t.`create_time` FROM t_topic t WHERE t.`id` = ? AND t.`title` like ? LIMIT 1
==> Parameters: 3(String),%3%(String)
<== Total: 1

多表


Topic topic = easyEntityQuery
        .queryable(Topic.class)
        .leftJoin(BlogEntity.class, (t,b) -> t.id().eq(b.id()))
        .where((t,b) -> t.id().eq("3"))
        .firstOrNull();

==> Preparing: SELECT t.`id`,t.`stars`,t.`title`,t.`create_time` FROM t_topic t LEFT JOIN t_blog t1 ON t.`id` = t1.`id` WHERE t.`id` = ? LIMIT 1
==> Parameters: 3(String)
<== Total: 1

List<BlogEntity> blogEntities = easyEntityQuery
        .queryable(Topic.class)
        //join 后面是多参数委托,第一个主表,第二个参数为join表
        .innerJoin(BlogEntity.class, (t,b) -> t.id().eq(b.id()))
        .where((t,b) -> {
                t.title().isNotNull();
                b.id().eq("3");
        })
        //select 参数个数和join表个数一样,group后参数为一个,返回一个对象代理
        //可以对其进行自定义赋值比如id().set(t.title())将title赋值给id属性
        .select((t,b)->new BlogEntityProxy().selectAll(t))
        .toList();

==> Preparing: SELECT t1.`id`,t1.`create_time`,t1.`update_time`,t1.`create_by`,t1.`update_by`,t1.`deleted`,t1.`title`,t1.`content`,t1.`url`,t1.`star`,t1.`publish_time`,t1.`score`,t1.`status`,t1.`order`,t1.`is_top`,t1.`top` FROM t_topic t INNER JOIN t_blog t1 ON t.`id` = t1.`id` WHERE t1.`title` IS NOT NULL AND t.`id` = ?
==> Parameters: 3(String)
<== Total: 1

嵌套多表

 EntityQueryable<TopicProxy, Topic> sql = easyEntityQuery
                .queryable(Topic.class)
                .where(o -> o.id().eq("3" ));
//SELECT t.`id`,t.`stars`,t.`title`,t.`create_time` FROM t_topic t WHERE t.`id` = ?

List<BlogEntity> topics = easyEntityQuery
        .queryable(BlogEntity.class)
        .leftJoin(sql,(a,b)->a.id().eq(b.id()))
        .where((a,b) -> {
                a.id().isNotNull();
                b.id().isNotNull();
        })
        .toList();

==> Preparing: SELECT t.`id`,t.`create_time`,t.`update_time`,t.`create_by`,t.`update_by`,t.`deleted`,t.`title`,t.`content`,t.`url`,t.`star`,t.`publish_time`,t.`score`,t.`status`,t.`order`,t.`is_top`,t.`top` FROM `t_blog` t LEFT JOIN (SELECT t1.`id`,t1.`stars`,t1.`title`,t1.`create_time` FROM `t_topic` t1 WHERE t1.`id` = ?) t2 ON t.`id` = t2.`id` WHERE t.`deleted` = ? AND t.`id` IS NOT NULL AND t2.`id` IS NOT NULL
==> Parameters: 3(String),false(Boolean)
<== Total: 1

自定义VO返回结果



@Data
public class BlogEntityTest2 {

    /**
     * 标题
     */
    private String title;
    /**
     * 内容
     */
    private String content;
    /**
     * 博客链接
     */
    @Column("my_url")
    private String url;
    /**
     * 点赞数
     */
    private Integer star;
    /**
     * 发布时间
     */
    private LocalDateTime publishTime;
    /**
     * 评分
     */
    private BigDecimal score;
    /**
     * 状态
     */
    private Integer status;
    /**
     * 排序
     */
    private BigDecimal order;
    /**
     * 是否置顶
     */
    private Boolean isTop;
    /**
     * 是否置顶
     */
    private Boolean top;
}

//以下三种都是一样的结果,但是`toList(BlogEntityTest.class)`这种方式是不需要对返回结果进行后续处理或者自定义的情况下使用的
//映射规则为BlogEntity的属性字段对应的column_name和VO对象BlogEntityTest的属性字段对应的column_name一样即可直接映射
List<BlogEntityTest> list = easyEntityQuery.queryable(BlogEntity.class)
        .select(o->new BlogEntityTestProxy()).toList();

List<BlogEntityTest> list = easyEntityQuery.queryable(BlogEntity.class)
        .select(o->new BlogEntityTestProxy().selectAll(o)).toList();

//下面的写法和上面的都是等价的区别就是上面写法支持后续继续查询,而下面的写法仅支持结果返回

        //如果你只查询一张表并且是全属性映射那么可以直接使用class查询
List<BlogEntityTest> list = easyEntityQuery.queryable(BlogEntity.class)
        .select(BlogEntityTest.class).toList();
        
List<BlogEntityTest> list = easyEntityQuery.queryable(BlogEntity.class)
        .toList(BlogEntityTest.class);

List<BlogEntityTest> list = easyEntityQuery.queryable(BlogEntity.class).toList(BlogEntityTest.class);

==> Preparing: SELECT t.`title`,t.`content`,t.`url`,t.`star`,t.`publish_time`,t.`score`,t.`status`,t.`order`,t.`is_top`,t.`top` FROM `t_blog` t WHERE t.`deleted` = ?
==> Parameters: false(Boolean)
<== Time Elapsed: 3(ms)
<== Total: 100
//如果遇到无法对应的可以通过手动set来实现映射
String sql = easyEntityQuery.queryable(BlogEntity.class)
                .where(o -> o.id().eq( "2"))
                .select(o->new BlogEntityVO1Proxy()
                        .score().set(o.order())//将查询的order映射到vo对象的score上
                )
                .limit(1).toSQL();
Assert.assertEquals("SELECT t.`order` AS `score` FROM `t_blog` t WHERE t.`deleted` = ? AND t.`id` = ? LIMIT 1", sql);


EntityQueryable<BlogEntityTest2Proxy, BlogEntityTest2> queryable = easyEntityQuery.queryable(BlogEntity.class)
                .select(o -> new BlogEntityTest2Proxy()
                        .selectAll(o)//等于*但是不会用*这种暴力的语法会将字段列出
                        .selectIgnores(o.title())//忽略前面的selectAll里面的title列
                        .url().set(o.url())//并且将url映射到my_url上
                );
            String sql = queryable.toSQL();
            Assert.assertEquals("SELECT t.`content`,t.`star`,t.`publish_time`,t.`score`,t.`status`,t.`order`,t.`is_top`,t.`top`,t.`url` AS `my_url` FROM `t_blog` t WHERE t.`deleted` = ?", sql);

API

方法参数返回描述
streamByFunction<Stream<T>,TR> fetcher任意stream的终结方法使用java方式只需要迭代一次返回符合stream的结果
toSqlstring返回当前表达式即将执行的sql语句
anyboolean返回当前表达式是在数据库中是否存在匹配项,存在至少一条返回true,无法匹配任意一条在返回false
requiredvoid返回当前表达式是在数据库中是否存在匹配项,存在至少一条,无法匹配任意一条抛错
alllambdaboolean返回当前表达式是在数据库中是否所有的都匹配,参数为符合条件的表达式
countlong返回当前表达式在数据库中命中的条数有多少,没有匹配数返回0
firstOrNullTEntity返回当前表达式在数据库中命中的第一条,如果没命中就返回null
toListList<TEntity>返回当前表达式在数据库中命中的所有结果,如果没有结果则返回空集合
wherelambdathis对当前表达式进行条件追加
limit1.offset,2.rowsthis对当前表达式进行查询结果返回和偏移进行限制，offset表示跳过多少条，limit表示获取多少条
orderBylambdathis对当前表达式进行查询结果进行排序
sumBigDecimalOrDefaultlambda,默认值BigDecimal用于对lambda列进行求和,返回结果BigDecimal防止结果溢出
sumOrDefaultlambda,默认值列类型用于对lambda列进行求和
maxOrDefaultlambda,默认值列类型用于对lambda列进行最大值查询
minOrDefaultlambda,默认值列类型用于对lambda列进行最小值查询
avgOrDefaultlambda,默认值列类型用于对lambda列进行平均值值查询
lenOrDefaultlambda,默认值列类型用于对lambda列进行长度查询
whereByIdobject 主键this添加单主键条件
whereObjectobject 查询对象this添加对象查询条件
groupBylambdathis查询分组
havinglambdathis查询对分组结果进行筛选
orderByDynamicEasyDynamicOrderByConfigurationthis添加查询动态排序
distinctthis对查询结果进行去重
toPageResultlong,longPageResult对结果进行先count，然后limit+toList查询结果并且封装成PageResult返回
toShardingPageResultlong,long,sequenceCountLinePageResult支持高性能分片下的分页查询,如果第三个参数为null那么和toPageResult行为一致
leftJoinlambdathis左链接
rightJoinlambdathis右链接
innerJoinlambdathis内链接
disableLogicDeletethis本次查询不启用逻辑删除
enableLogicDeletethis本次查询启用逻辑删除
noInterceptorthis本次查询不使用拦截器
noInterceptornamethis不使用指定name的拦截器
useInterceptorthis本次查询使用拦截器
useInterceptornamethis使用指定name的拦截器
asTrackingthis本次查询使用追踪，需要开启追踪后才有效
asNoTrackingthis本次查询不使用追踪,默认就是不使用追踪
asTabletableNamethis指定本次查询最近的表的表名,如果最近的表是匿名表则设置表别名alias
asTablelambdathis指定本次查询最近的表的表名,如果最近的表是匿名表则设置表别名alias,表达式入参为现有表名返回设置的表名
unionqueryablethisunion 查询
unionAllqueryablethisunion all查询
上次编辑于:
贡献者: Hoysing,xuejiaming
Default footer
Copyright © 2024 xuejmnet