[有意思的代码] lambda-query: 基于Lambda的查询器 --> JPA lambda查询器 --> MongoDb lambda查询器-开发中

[](#lambda-query-10-%E7%89%88%E6%9C%AC)lambda-query 1.0 版本

Maven Central

[](#%E4%BB%8B%E7%BB%8D)介绍

LambdaQuery 将支持通过Lambda进行多种数据源的查询 实现java端的简单数据的统一查询

[](#%E5%8A%9F%E8%83%BD%E8%A7%84%E5%88%92)功能规划

[](#%E6%80%BB%E4%BD%93%E5%8A%9F%E8%83%BD%E8%A7%84%E5%88%92)总体功能规划

  • 实现基础查询功能
  • 实现LoadRef功能,通过selectIn的方式进行数据表join, 实现跨服务,分布式数据库,跨不同数据库之间的join
  • 增加redisCache功能,实现在loadRef的时候 可以通过配置项进行设置是否通过cache 进行加载

[](#1-mongodb)1. MongoDb

  • 实现基础的Lambda查询(已完成)
  • 实现 新增,删除,更新等基础操作
  • 新增LoadJoin功能,通过selectIn的方式进行数据表join

[](#2-mybatis-plus)2. mybatis-plus

  • 接入mybatis-plus的查询接口(已完成)
  • 接入mybatis-plus 的新增,删除,更新操作
  • 新增LoadJoin功能,通过selectIn的方式进行数据表join
  • 新增Cache功能,采用redis 进行数据缓存,配合selectIn方式避免join查询直接访问数据库
  • 新增Map接口,实现selectIn后数据合并问题

[](#3-httpserverhttpclient)3. HttpServer&HttpClient

  • 新增Http模式,实现微服务之间 关联数据join 显示问题
  • 扩展全功能查询,实现微服务之间的HTTP接口数据查询功能
  • 扩展 Http 自定义查询字段和结果集字段,可以实现灵活空值查询字段与条件
  • 新增拦截器,实现对查询,新增,修改操作的全局拦截,可以实现后端租户拦截,http接口的权限拦截限制

[](#%E5%8A%9F%E8%83%BD%E6%94%AF%E6%8C%81)功能支持

[](#1-%E5%9F%BA%E7%A1%80%E6%9F%A5%E8%AF%A2%E6%9D%A1%E4%BB%B6)1. 基础查询条件

  • 相等,eq
  • 不等,ne
  • 空值,isNull
  • 大于,gt
  • 大于等于,gte
  • 小于,lt
  • 小于等于,lte
  • 包含,in
  • 不包含,notIn
  • 之间 ,between

[](#2-%E7%BB%93%E6%9E%9C%E6%9F%A5%E8%AF%A2)2. 结果查询

  • 通过ID查询
  • 查询列表
  • 分页查询
  • count 查询

[](#%E4%BD%BF%E7%94%A8%E8%AF%B4%E6%98%8E)使用说明

[](#1%E4%BE%9D%E8%B5%96%E5%BC%95%E5%85%A5)1.依赖引入

  1. springBoot自动配置

<!--Mongo 查询器依赖-->
<dependency>
<groupId>com.github.xuejike</groupId>
<artifactId>lambda-query-mongo-starter</artifactId>
<version>${jkquery.version}</version>
</dependency>
<!--MybatisPlus 查询器依赖-->
<dependency>
<groupId>com.github.xuejike</groupId>
<artifactId>lambda-query-mybatis-plus-starter</artifactId>
<version>${jkquery.version}</version>
</dependency>

  1. 手动配置

引入依赖

<!--Mongo 查询器依赖-->
<dependency>
<groupId>com.github.xuejike</groupId>
<artifactId>lambda-query-mongo</artifactId>
<version>${jkquery.version}</version>
</dependency>
<!--MybatisPlus 查询器依赖-->
<dependency>
<groupId>com.github.xuejike</groupId>
<artifactId>lambda-query-mybatis-plus</artifactId>
<version>${jkquery.version}</version>
</dependency>

初始化工厂类

// MongoDB 查询器初始化
@Bean
public MongoDaoFactory mongoDaoFactory(MongoTemplate mongoTemplate){
return new MongoDaoFactory(mongoTemplate);
}
// MybatisPlus 查询器初始化
@Bean
public MyBatisPlusDaoFactory myBatisPlusDaoFactory(Collection<BaseMapper> mapperCollection){
MyBatisPlusDaoFactory myBatisPlusDaoFactory = new MyBatisPlusDaoFactory(mapperCollection);
return myBatisPlusDaoFactory;
}

[](#2mongo%E6%9F%A5%E8%AF%A2%E5%99%A8%E4%BD%BF%E7%94%A8)2.Mongo查询器使用

[](#1-%E5%88%9B%E5%BB%BA%E5%AE%9E%E4%BD%93%E7%B1%BB)1. 创建实体类

@Document("demo_doc")
@Data
// 采用mongo进行查询
@MongoDaoSelect
public class TestDoc {
@MongoId
private String id;
private String name;
private String title;
private Long num;
private List<Title> toc;
@Data
public static class Title{
private String title;
private String desc;
}
}

[](#2mybatisplus%E6%9F%A5%E8%AF%A2%E5%99%A8%E4%BD%BF%E7%94%A8)2.MybatisPlus查询器使用

mybatis-plus 实体初始化

@Data
@TableName("u1")
@MyBatisPlusDaoSelect
public class U1 {
@TableId(type = IdType.AUTO)
private Long id;
private String name;
private String type;
}

[](#3-http%E6%9F%A5%E8%AF%A2%E5%99%A8)3. HTTP查询器

  1. 暴露接口

    @PostConstruct
    public void init(){
    LambdaQueryHttpConfig.getInstance().registerService("u1", U1.class);
    HttpClientFactory httpClientFactory = new HttpClientFactory();
    }

  2. 定义查询器

@HttpDaoSelect( serverAddress = "http://127.0.0.1:7000",path = "/lambda/u1/")
@Data
public class HttpEntity {
private Long id;
private String name;
private String type;
private Long u2Id;
}

  1. 使用查询功能

    @Test
    public void list(){
    JQuerys.lambdaQuery(HttpRequest.class).eq(HttpRequest::getName,"xxx").eq(HttpRequest::getUserName,"un").list();
    }

[](#%E5%8A%9F%E8%83%BD%E8%AF%B4%E6%98%8E)功能说明

[](#1-%E5%9F%BA%E7%A1%80%E6%9F%A5%E8%AF%A2%E5%8A%9F%E8%83%BD)1. 基础查询功能

/**
* == 查询
*/
@Test
public void testEq(){
List<TestDoc> list = JQuerys.lambdaQuery(TestDoc.class).eq(TestDoc::getName, "name_1").list();
Assertions.assertEquals(list.size(),1);
TestDoc testDoc = list.get(0);
Assertions.assertEquals(testDoc.getTitle(),"title_1");
}
/**
* 大于号查询
*
*/
@Test
public void testGt(){
List<TestDoc> list = JQuerys.lambdaQuery(TestDoc.class).gt(TestDoc::getNum,3 ).list();
Assertions.assertEquals(list.size(),1);
TestDoc testDoc = list.get(0);
Assertions.assertEquals(testDoc.getTitle(),"title_4");
}
/**
* 大于等于查询
*/
@Test
public void testGte(){
List<TestDoc> list = JQuerys.lambdaQuery(TestDoc.class).gte(TestDoc::getNum,4 ).list();
Assertions.assertEquals(list.size(),1);
TestDoc testDoc = list.get(0);
Assertions.assertEquals(testDoc.getTitle(),"title_4");
}
/**
* 小于号查询
*/
@Test
public void testLt(){
List<TestDoc> list = JQuerys.lambdaQuery(TestDoc.class).lt(TestDoc::getNum,1 ).list();
Assertions.assertEquals(list.size(),1);
TestDoc testDoc = list.get(0);
Assertions.assertEquals(testDoc.getTitle(),"title_0");
}
/**
* 小于等于查询
*/
@Test
public void testLte(){
List<TestDoc> list = JQuerys.lambdaQuery(TestDoc.class).lte(TestDoc::getNum,0 ).list();
Assertions.assertEquals(list.size(),1);
TestDoc testDoc = list.get(0);
Assertions.assertEquals(testDoc.getTitle(),"title_0");
}
/**
* In 查询
*/
@Test
public void testIn(){
List<TestDoc> list = JQuerys.lambdaQuery(TestDoc.class)
.in(TestDoc::getTitle,"title_0" ).list();
Assertions.assertEquals(list.size(),1);
TestDoc testDoc = list.get(0);
Assertions.assertEquals(testDoc.getTitle(),"title_0");
}
/**
* NotIn 查询
*/
@Test
public void testNotIn(){
List<TestDoc> list = JQuerys.lambdaQuery(TestDoc.class)
.notIn(TestDoc::getTitle,"title_0","title_1","title_2","title_3" ).list();
Assertions.assertEquals(list.size(),1);
TestDoc testDoc = list.get(0);
Assertions.assertEquals(testDoc.getTitle(),"title_4");
}
/**
* or 查询
*/
@Test
public void testOr(){
List<TestDoc> list = JQuerys.lambdaQuery(TestDoc.class).or().eq(TestDoc::getNum, 0).or().eq(TestDoc::getNum, 1).list();
Assertions.assertEquals(list.size(),2);
list = JQuerys.lambdaQuery(TestDoc.class).or(it->{
it.eq(TestDoc::getNum,0).eq(TestDoc::getName,"name_0");
}).or(it->{
it.eq(TestDoc::getNum,1).eq(TestDoc::getName,"name_1");
}).list();
Assertions.assertEquals(list.size(),2);
}
/**
* 排序查询
*/
@Test
public void testOrder(){
List<TestDoc> list = JQuerys.lambdaQuery(TestDoc.class).in(TestDoc::getNum, 1, 2).orderAsc(TestDoc::getNum).list();
Assertions.assertEquals(list.size(),2);
Assertions.assertEquals(list.get(0).getNum(),1);
Assertions.assertEquals(list.get(1).getNum(),2);
list = JQuerys.lambdaQuery(TestDoc.class).in(TestDoc::getNum, 1, 2).orderDesc(TestDoc::getNum).list();
Assertions.assertEquals(list.size(),2);
Assertions.assertEquals(list.get(0).getNum(),2);
Assertions.assertEquals(list.get(1).getNum(),1);
}

[](#2-%E4%BA%8C%E7%BA%A7%E5%AD%97%E6%AE%B5%E6%9F%A5%E8%AF%A2json-%E5%AD%97%E6%AE%B5%E6%9F%A5%E8%AF%A2%E6%9C%AA%E5%AE%8C%E6%88%90)2. 二级字段查询&json 字段查询(未完成)

/**
* 二级字段查询
*/
@Test
public void testSubField(){
List<TestDoc> list = JQuerys.lambdaQuery(TestDoc.class).eq(of().subList(TestDoc::getToc).sub(TestDoc.Title::getTitle), "sub_title_0_0").list();
Assertions.assertEquals(list.size(),1);
Assertions.assertEquals(list.get(0).getNum(),0);
}
public CascadeField<TestDoc,TestDoc> of(){
return new CascadeField<>();
}

[](#3-loadjoin-%E5%8A%9F%E8%83%BD%E6%9F%A5%E8%AF%A2)3. loadJoin 功能查询

采用selectIn 和并行计算方式进行 join查询合并

@GetMapping("list")
public Object testList(){
JLambdaQuery<HttpEntity> query = JQuerys.lambdaQuery(HttpEntity.class);
Object list = query.or().eq(HttpEntity::getName,"name1").or()
.eq(HttpEntity::getName,"name2")
// 属性 u2Id 关联实体 U2 的id字段,并映射结果到U1Vo
.loadRef(HttpEntity::getU2Id, U2.class,U2::getId).map(U1Vo.class).list();
return list;
}

@Data
public class U1Vo {
private Long id;
private String name;
private String type;
@SetRefValue("u2")
private Long u2Id;
@RefValue("#u2.name")
private String u2Name;
}

原网址: 访问
创建于: 2021-03-03 11:28:22
目录: default
标签: 无

未标明原创文章均为采集，版权归作者所有，转载无需和我联系，请注明原出处，南摩阿彌陀佛，知识，不只知道，要得到

请先后发表评论
  • 最新评论
  • 总共0条评论