APP下载

Java架构SpringBoot整合MongoDB 使用mongoTemplate实现高阶查询

消息来源:baojiabao.com 作者: 发布时间:2024-05-14

报价宝综合消息Java架构SpringBoot整合MongoDB 使用mongoTemplate实现高阶查询

一、前言

最近专案使用MongoDB作为资料主要存取的地方

又是第一次接触MongoDB,也是踩了不少坑...

维护资料无非就是增删改查,而里面最复杂的就是查询了

所以来总结一下有关MongoDB的查询方法

当然如果你在此之前你对MongoDB一点都不了解的话

个人建议点选这里,花三十分钟初步了解一下MongoDB

ok,正文开始

二、正文

1.使用mongoTemplate物件常常会呼叫如下两种方法

① findAll(Class entityClass, String collectionName)

分析:此方法入两个引数,前者entityClass是类型别 即某个实体类,后者collectionName是String型别

即MongoDB的某个集合名,那么这个方法很明显就是根据入参的集合名称到MongoDB中查询并转换为指定的类型别。

注:entityClass引数的写法应为 xxx.class ,如Student学生类:Student.class

② find(Query query, Class entityClass, String collectionName)

分析:此方法三个引数,与①不同的是,多了第一个query引数,这个query就是用来封装查询条件的

2.Query的使用(这里以我自己的一个业务逻辑角度写的,下面有这个逻辑的连贯程式码)

① 首先在这个方法里面需要定义如下两个物件

//用来封装所有条件的物件

Query query = new Query();

//用来构建条件

Criteria criteria = new Criteria();

② 先来一个模糊查询的条件

/**

* 这里使用的正则表示式的方式

* 第二个引数Pattern.CASE_INSENSITIVE是对字元大小写不明感匹配

*/

Pattern pattern = Pattern.compile("^.*"+这里拼接你的查询条件字串+".*$", Pattern.CASE_INSENSITIVE);

/**

* criteria.and().regex() 在这里是构建了一个模糊查询的条件,并且用 'and' 相连

* query.addCriteria 把条件封装起来

*/

query.addCriteria(criteria.and("这里填写你MongoDB集合中的key").regex(pattern));

③ 再来一个精准查询的条件

/**

* criteria.and().is() 在这里是构建了一个精准查询的条件,并且用 'and' 相连

* query.addCriteria 把条件封装起来

*/

query.addCriteria(criteria.and("你MongoDB中的key").is("你的条件");

④ 来一个在某个值之间的条件(类似于sql中的BETWEEN ... AND)

如果在这里,模仿精准查询,把 is() 方法换成 gt() 或 lt() ,然后执行,肯定会报错,具体的错误资讯我没有记录下来,大概意思就是同一个字段连续出现了两次

这里需要用到 andOperator 方法,如下

//大于方法

Criteria gt = Criteria.where("你MongoDB中的key").gt("你的条件");

//小于方法

Criteria lt = Criteria.where("你MongoDB中的key").lt("你的条件");

/**

* new Criteria().andOperator(gt,lt) 把上面的大于和小于放在一起,注意上面两个key一定是一样的

* andOperator() 这个方法就是关键的方法了,把同key的多个条件组在一起

* 但是 andOperator() 有个很坑的地方就是,在一个query中只能出现一次

* 如果你有很固定很明确的入参,那还好,直接呼叫一次 andOperator()

* 如果是多个key需要多个条件,而且条件数量还是动态的,怕不是魔鬼吧...

*/

query.addCriteria(new Criteria().andOperator(gt,lt));

⑤ 当得知一个query中只能存在一个 andOperator() 方法的时候,就应该把思考方向放在如何

把不确定个数的 Criteria 物件放入一个 andOperator() 方法中,这里是把多个 Criteria 物件用逗号分隔的,其实 andOperator() 方法还可以入参 Criteria[] 阵列

定义阵列的话,那么问题又来了,如何确定阵列的长度...即使定义了一个 [1024] 这样长度的阵列

那如果逻辑中还有 if 判断隔开了,那阵列的下标如何保证连续不错误,于是就又定义了一个List

泛型集合,先往集合里面存,完事了后就把集合遍历放入阵列,最后把阵列入参到 andOperator() 方法

//定义一个泛型集合,型别为 Criteria

List criteriaList = new ArrayList();

//定义一个无长度的阵列,型别为 Criteria

Criteria[] criteriaArray = {};

//往集合里面新增条件物件

if(你的逻辑){

//大于方法

Criteria gt = Criteria.where("你MongoDB中的key").gt("你的条件");

//小于方法

Criteria lt = Criteria.where("你MongoDB中的key").lt("你的条件");

if(gt!=null && lt!=null){

criteriaList.add(gt);

criteriaList.add(lt);

}else if(gt!=null){

query.addCriteria(gt);

}else if(lt!=null){

query.addCriteria(lt);

}

}

//是否有条件

if(criteriaList.size()>0){

//把无长度的阵列例项出来,长度就位集合的个数

criteriaArray = new Criteria[criteriaList.size()];

for(int i = 0 ; i //把集合中的条件物件全部存入阵列中

criteriaArray[i] = criteriaList.get(i);

}

}

//最后把阵列入参到 andOperator() 方法中

query.addCriteria(new Criteria().andOperator(criteriaArray));

⑥ 最后一步,呼叫 mongoTemplate 物件的 find() 方法

/**

* xxxxx 即为实体类,也是此方法返回泛型型别

* 如 xxxxx 为 Student (Student.class),那么此方法就会返回 List

*/

mongoTemplate.find(query,xxxxx.class,collectionName);

3. 连贯程式码例项,因为没有写demo,程式码中有很多敏感资讯,我就替换成文字说明,但是我会尽量

写的通俗易懂

/**

* 定义了一个方法,返回型别就是等会最后入参的 xxxxx.class 型别的泛型集合

* 引数

* 条件 --- > 条件集合

* collectionName --- > MongoDB的集合名称

*/

public List getXxxxxByCollectionNameAndCondition(List 条件,String collectionName) throws Exception{

//用来封装所有条件的物件

Query query = new Query();

//用来构建条件

Criteria criteria = new Criteria();

/**

* 这里最多会出现两个多条件的key

* 所以我定义了两个集合和两个阵列

*/

//定义一个泛型集合,型别为 Criteria

List criteriaList_first = new ArrayList();

//定义一个无长度的阵列,型别为 Criteria

Criteria[] criteriaArray_first = {};

//定义一个泛型集合,型别为 Criteria

List criteriaList_second = new ArrayList();

//定义一个无长度的阵列,型别为 Criteria

Criteria[] criteriaArray_second = {};

//遍历所有条件

for(条件型别 条件物件 : 条件){

if(条件物件){

//往集合里面新增条件物件

if(你的逻辑){

//大于方法

Criteria gt = Criteria.where("你MongoDB中的key").gt("你的条件");

//小于方法

Criteria lt = Criteria.where("你MongoDB中的key").lt("你的条件");

if(gt!=null && lt!=null){

criteriaList_first.add(gt);

criteriaList_first.add(lt);

}else if(gt!=null){

query.addCriteria(gt);

}else if(lt!=null){

query.addCriteria(lt);

}

}else if(你的逻辑){

//大于方法

Criteria gt = Criteria.where("你MongoDB中的key").gt("你的条件");

//小于方法

Criteria lt = Criteria.where("你MongoDB中的key").lt("你的条件");

if(gt!=null && lt!=null){

criteriaList_second.add(gt);

criteriaList_second.add(lt);

}else if(gt!=null){

query.addCriteria(gt);

}else if(lt!=null){

query.addCriteria(lt);

}

}else if(你的逻辑){

...

}

}else if(其他条件物件){

...

}

}

//是否有条件

if(criteriaList_first.size()>0){

//把无长度的阵列例项出来,长度就位集合的个数

criteriaArray_first = new Criteria[criteriaList_first.size()];

for(int i = 0 ; i //把集合中的条件物件全部存入阵列中

criteriaArray_first[i] = criteriaList_first.get(i);

}

}

//是否有条件

if(criteriaList_second.size()>0){

//把无长度的阵列例项出来,长度就位集合的个数

criteriaArray_second = new Criteria[criteriaList_second.size()];

for(int i = 0 ; i //把集合中的条件物件全部存入阵列中

criteriaArray_second[i] = criteriaList_second.get(i);

}

}

//如果两个引数阵列中任意一个存在值

if(criteriaArray_first.length > 0 || criteriaArray_second.length > 0){

//呼叫合并阵列方法,并入参到query中(合并阵列的方法紧接着下面写了)

query.addCriteria(new Criteria().andOperator(this.concat(criteriaArray_first,criteriaArray_second)));

}

//呼叫 find() 方法并返回

return mongoTemplate.find(query,返回型别.class,collectionName);

}

/**

* 把两个数组合并为一个数组

*/

private Criteria[] concat(Criteria[] criteria1 , Criteria[] criteria2){

Criteria[] c= new Criteria[criteria1.length+criteria2.length];

System.arraycopy(criteria1, 0, c, 0, criteria1.length);

System.arraycopy(criteria2, 0, c, criteria1.length, criteria2.length);

return c;

}

4. 到此全部程式码已经写完了

2019-06-26 14:22:00

相关文章