Spring Data 与MongoDB 集成四:操作篇（查询）

缺乏、安全感 2023-10-17 09:18 127阅读 0赞

## 本文转载至：[http://blog.csdn.net/congcong68/article/details/47183209][http_blog.csdn.net_congcong68_article_details_47183209] ##

## 一．简介 ##

[spring][] Data MongoDB提供了org.springframework.data.mongodb.core.MongoTemplate对MongoDB的CRUD的操作，上一篇我们介绍了对MongoDB的新增和删除， 今天我们要介绍[Java][spring]代码实现对MongoDB实现查询操作。

我们回顾一下，我们在之前介绍了MongoDB的基本文档查询，MongoDB的查询语法：

db.orders.find(\{ \{<field1>:<value1>,<field2>: <value2>, ... \} \},\{field1:<boolean>, field2: <boolean> ... \})

我们介绍是SpringData MongoDB 提供了find方法，方便我们通过java代码实现对MongoDB的查询操作：

mongoTemplate.find (query, entityClass)

参数说明：

entityClass：实体class,也就是要把文档转换成对应的实体。

query查询语句的实现的方式有两种：

**1.org.springframework.data.mongodb.core.query**

构造函数

Query (Criteria criteria)

接受的参数是org.springframework.data.mongodb.core.query.Criteria

Criteria是标准查询的接口，可以引用静态的Criteria.where的把多个条件组合在一起，就可以轻松地将多个方法标准和查询连接起来，方便我们操作查询语句。

例如： 查询条件onumber="002"

mongoTemplate.find (new Query(Criteria.where("onumber").is("002")),entityClass)

多个条件组合查询时：

例如：onumber="002" and cname="zcy"

mongoTemplate.find (new Query(Criteria.where("onumber").is("002").and("cname").is("zcy")),entityClass)

例如：onumber="002" or cname="zcy"

mongoTemplate.findOne(newQuery(newCriteria().orOperator(Criteria.where("onumber").is("002"),Criteria.where("cname").is("zcy"))),entityClass);

我们通过Criteria的and方法，把这个条件组合一起查询

Criteria提供了很多方法，我们这边先介绍基本文档的查询操作符，对于数组文档或者内嵌文档的操作符，我们下一篇在介绍。

<table style="color:rgb(85,85,85); font-family:&quot;microsoft yahei&quot;; font-size:15px"> 
 <tbody> 
 <tr> 
 <td> Criteria </td> 
 <td> Mongodb </td> 
 <td> 说明 </td> 
 </tr> 
 <tr> 
 <td> Criteria and (String key) </td> 
 <td> $and </td> 
 <td> 并且 </td> 
 </tr> 
 <tr> 
 <td> Criteria andOperator (Criteria… criteria) </td> 
 <td> $and </td> 
 <td> 并且 </td> 
 </tr> 
 <tr> 
 <td> Criteria orOperator (Criteria… criteria) </td> 
 <td> $or </td> 
 <td> 或者 </td> 
 </tr> 
 <tr> 
 <td> Criteria gt (Object o) </td> 
 <td> $gt </td> 
 <td> 大于 </td> 
 </tr> 
 <tr> 
 <td> Criteria gte (Object o) </td> 
 <td> $gte </td> 
 <td> 大于等于 </td> 
 </tr> 
 <tr> 
 <td> Criteria in (Object… o) </td> 
 <td> $in </td> 
 <td> 包含 </td> 
 </tr> 
 <tr> 
 <td> Criteria is (Object o) </td> 
 <td> $is </td> 
 <td> 等于 </td> 
 </tr> 
 <tr> 
 <td> Criteria lt (Object o) </td> 
 <td> $lt </td> 
 <td> 小于 </td> 
 </tr> 
 <tr> 
 <td> Criteria lte (Object o) </td> 
 <td> $lte </td> 
 <td> 小等于 </td> 
 </tr> 
 <tr> 
 <td> Criteria nin (Object… o) </td> 
 <td> $nin </td> 
 <td> 不包含 </td> 
 </tr> 
 <tr> 
 <td colspan="3"> 。。。。。。。。。。。。。。 </td> 
 </tr> 
 </tbody> 
</table>

**2、子类 org.springframework.data.mongodb.core.query.BasicQuery**

构造方法

BasicQuery(DBObject queryObject)

BasicQuery(DBObject queryObject, DBObject fieldsObject)

BasicQuery(java.lang.String query)

BasicQuery(java.lang.String query, java.lang.String fields)

DBObject就是转换成JSON格式，提供了我们回顾一下，MongoDB查询时，

db.collection.find(query,projection)，query类型是document，所以，我们想使用JSON字符串查询时，我们使用DBObject创建查询实例。

![Center][]

DBObject是接口，提供了几个子类，

![Center 1][]

我们比较经常使用的比较底层子类，扩展了自己的方法和继承父类，所以功能会比较多。

1. BasicDBObject

BasicBSONObject extendsLinkedHashMap<String,Object> implements BSONObject

BasicDBObject extends BasicBSONObject implementsDBObject

例如：查询条件onumber="002"

DBObject obj = new BasicDBObject();

obj.put( "onumber","002" );

相当于

db.collect.find(\{"onumber":"002"\})

2. BasicDBList

BasicBSONList extendsArrayList<Object> implements BSONObject

BasicDBList extends BasicBSONList implements DBObject

BasicDBList可以存放多个BasicDBObject条件

例如：我们查询onumber=002OR cname=zcy1

BasicDBList basicDBList=**new** BasicDBList();

basicDBList.add(**new** BasicDBObject("onumber","002"));

basicDBList.add(**new** BasicDBObject("cname","zcy1"));

DBObjectobj =**new**BasicDBObject();

obj.put("$or", basicDBList);

Query query=**new** BasicQuery(obj);

相当于

db.orders.find(\{$or:\[\{"onumber":"002"\},\{"cname":"zcy1"\}\]\})

basicDBList.add方法是添加一个文档的查询条件

3. com.mongodb. QueryBuilder

QueryBuilder默认构造函数，是初始化BasicDBObject，QueryBuilder多个方法标准和查询连接起来，方便我们操作查询语句。跟Criteria是标准查询的接口一样，

![Center 2][]

QueryBuilder和BasicDBObject配合使用

QueryBuilder帮我们实现了 $and等操作符，我们查看部分的源代码：QueryBuilder部分的源代码：

**\[java\]** [view plain][] [copy][view plain]

1.  publicclassQueryBuilder \{ 
2.  
3.  /\*\*
4.   \* Creates a builder with an empty query
5.   \*/
6.   publicQueryBuilder() \{ 
7.   \_query = **new** BasicDBObject(); 
8.   \} 
9.   publicQueryBuilder or( DBObject ... ors )\{ 
10.  List l = (List)\_query.get( "$or" ); 
11. **if** ( l == **null** )\{ 
12.  l = **new** ArrayList(); 
13.  \_query.put( "$or" , l ); 
14.  \} 
15. **for** ( DBObject o : ors ) 
16.  l.add( o ); 
17. **return****this**; 
18.  \} 
19. 
20. /\*\*
21.  \* Equivalent to an $and operand
22.  \* @param ands
23.  \* @return
24.  \*/
25. @SuppressWarnings("unchecked") 
26.  publicQueryBuilder and( DBObject ... ands )\{ 
27.  List l = (List)\_query.get( "$and" ); 
28. **if** ( l == **null** )\{ 
29.  l = **new** ArrayList(); 
30.  \_query.put( "$and" , l ); 
31.  \} 
32. **for** ( DBObject o : ands ) 
33.  l.add( o ); 
34. **return****this**; 
35.  \}

接下来我们介绍查询的实现， Criteria提供了很多方法，我们这边就不在一个一个的操作符执行一遍，这跟[学习MongoDB 四： MongoDB查询（一）][MongoDB _ MongoDB]基本文档的操作符介绍的一样。

二．findOne查询

findOne返回满足指定查询条件的文档，如果多个文档满足查询，该方法返回第一个文档，根据自然顺序返回文件在磁盘上的顺序,在覆盖的集合中，自然顺序与插入顺序相同。如果没找到对应的文档，会返回null。

方法：

mongoTemplate.findOne(query,entityClass)

1. 介绍接口以及方法的实现

我们在上一篇有介绍了[实现基本的添加][Link 1]，对整个结构有介绍了，我们这边就不在介绍了，直接介绍往里面添加方法

第一步：我们在基础接口MongoBase.java类新增一个findOne的接口

**\[java\]** [view plain][] [copy][view plain]

1.  //根据条件查询
2.  blic T findOne(Query query,String collectionName);

第二步：我们在OrdersDaoImpl类添加一个具体findOne的实现方法

**\[java\]** [view plain][] [copy][view plain]

1.  @Override
2.  ublic Orders findOne(Query query, String collectionName) \{ 
3.  **return** mongoTemplate.findOne(query, Orders.**class**, collectionName);

第三步：实现测试方法

**\[java\]** [view plain][] [copy][view plain]

1.  /测试testFindOne方法添加 
2.  @Test
3.  **public****void** testFindOne() **throws** ParseException 
4.   \{ 
5.  
6.   Queryquery=newQuery(Criteria.where("onumber").is("002")); 
7.   Ordersorder=ordersDao.findOne(query,collectionName); 
8.   System.out.println(JSONObject.fromObject(order)); 
9.  
10.  \}

我们到MongoDB查询时，有两条onumber值相同的文档

**\[sql\]** [view plain][] [copy][view plain]

1.  > db.orders.find() 
2.  \{ "\_id" : ObjectId("55b3ae9bee10ded9390d0b97"),"\_class" : "com.mongo.model.Orders", "onumber" : "002", "date" :ISODate("2015-01-24T16:07:00Z"), "cname" : "zcy1", "items" : \[ \{ "quantity" : 5,"price" : 4, "pnumber" : "p001" \}, \{ "quantity" : 6, "price" : 8, "pnumber" :"p002" \} \] \} 
3.  \{ "\_id" : ObjectId("55b3aea5ee10f970a2da7017"),"\_class" : "com.mongo.model.Orders", "onumber" : "002", "date" :ISODate("2015-01-24T16:07:00Z"), "cname" : "zcy2", "items" : \[ \{ "quantity" : 5,"price" : 4, "pnumber" : "p003" \}, \{ "quantity" : 6, "price" : 8, "pnumber" :"p004" \} \] \}

我们执行findOne时查询条件为onumber=002，返回第一个记录

**\[sql\]** [view plain][] [copy][view plain]

1.  \{ "cname":"zcy1","date"\{ "date":25,"day":0,"hours":0,"minutes":7,"month":0,"seconds":0,"time":1422115620000,"timezoneOffset":-480,"year":115\},"id":"55b3ae9bee10ded9390d0b97","items":\[\{ "pnumber":"p001","price":4,"quantity":5\},\{ "pnumber":"p002","price":8,"quantity":6\}\],"onumber":"002"\}

##  三．find查询 ##

1.org.springframework.data.mongodb.core.query

构造函数

Query (Criteria criteria)

接受的参数是org.springframework.data.mongodb.core.query.Criteria

例子：查询onumber="002" 并且cname="zcy"

OrdersDaoImpl类实现了find的方法

**\[java\]** [view plain][] [copy][view plain]

1. @Override
2. publicList<Orders> find(org.springframework.data.mongodb.core.query.Queryquery, String collectionName) \{ 
3. **return** mongoTemplate.find(query, Orders.**class**, collectionName); 
4. \}

实现测试方法

Query query=**new** Query(Criteria.*where*("onumber").is("002").and("cname").is("zcy1"));

**\[java\]** [view plain][] [copy][view plain]

1. @Test
2. **public****void** testFind() **throws** ParseException 
3. \{ 
4. Queryquery=newQuery(Criteria.where("onumber").is("002").and("cname").is("zcy1")); 
5. List<Orders>orders=ordersDao.find(query,collectionName); 
6. System.out.println(JSONArray.fromObject(orders)); 
7. \}

我们查看转换成Query 时，是怎么样的，我们断点跟踪一下

![Center 3][]

会转换成对应的文档查询

查询的结果

**\[java\]** [view plain][] [copy][view plain]

1.  \[\{ "cname":"zcy1","date":\{ "date":25,"day":0,"hours":0,"minutes":7,"month":0,"seconds":0,"time":1422115620000,"timezoneOffset":-480,"year":115\},"id":"55b3ae9bee10ded9390d0b97","items":\[\{ "pnumber":"p001","price":4,"quantity":5\},\{ "pnumber":"p002","price":8,"quantity":6\}\],"onumber":"002"\}\]

相当于MongoDB

b.orders.find(\{ "onumber" : "002" ,"cname" : "zcy1"\})

还可以另外一种写法Criteria andOperator(Criteria… criteria)

Queryquery=**new**Query(Criteria.*where*("onumber").is("002").andOperator(Criteria.*where*("cname").is("zcy1")));

一个Criteria中只能有一个andOperator，and可以多个，我们查询并列条件时，比较建议使用and方法。

2、org.springframework.data.mongodb.core.query.BasicQuery

构造方法

BasicQuery(DBObject queryObject)

BasicQuery(DBObject queryObject, DBObject fieldsObject)

BasicQuery(java.lang.String query)

BasicQuery(java.lang.String query, java.lang.String fields)

例子：查询onumber="002" or cname="zcy"

OrdersDaoImpl类实现了find的方法

**\[java\]** [view plain][] [copy][view plain]

1. @Override
2. publicList<Orders> find(org.springframework.data.mongodb.core.query.BasicQueryquery, String collectionName) \{ 
3. returnmongoTemplate.find(query, Orders.**class**, collectionName); 
4. \}

实现测试方法

**\[java\]** [view plain][] [copy][view plain]

1. **public** voidtestFind() throwsParseException 
2. \{ 
3. 
4. BasicDBListbasicDBList=newBasicDBList(); 
5. 
6. basicDBList.add(**new** BasicDBObject("onumber","002")); 
7. basicDBList.add(**new** BasicDBObject("cname","zcy1")); 
8. DBObjectobj = newBasicDBObject(); 
9. obj.put("$or", basicDBList); 
10. Queryquery=newBasicQuery(obj); 
11. List<Orders>orders=ordersDao.find(query,collectionName); 
12. System.out.println(JSONArray.fromObject(orders)); 
13. \}

查询的结果：

**\[sql\]** [view plain][] [copy][view plain]

1.  \[\{ "cname":"zcy1","date":\{ "date":25,"day":0,"hours":0,"minutes":7,"month":0,"seconds":0,"time":1422115620000,"timezoneOffset":-480,"year":115\},"id":"55bb9a3c27547f55fef9a10f","items":\[\{ "pnumber":"p001","price":5,"quantity":6\},\{ "pnumber":"p002","price":9,"quantity":7\}\],"onumber":"001"\},

**\[sql\]** [view plain][] [copy][view plain]

1.  \{ "cname":"zcy1","date":\{ "date":25,"day":0,"hours":0,"minutes":7,"month":0,"seconds":0,"time":1422115620000,"timezoneOffset":-480,"year":115\},"id":"55bb9a2727544d40b95156e1","items":\[\{ "pnumber":"p001","price":5,"quantity":6\},\{ "pnumber":"p002","price":9,"quantity":7\}\],"onumber":"001"\}\]

相当于MongoDB

\{ "$or" : \[ \{ "onumber" :"002"\} , \{ "cname" : "zcy1"\}\]\}

QueryBuilder和BasicDBObject配合使用

QueryBuilder queryBuilder= **new**QueryBuilder();

queryBuilder.or(**new** BasicDBObject("onumber","002"),**new**BasicDBObject("cname","zcy1"));

Query query=**new** BasicQuery(queryBuilder.get());

## 四.find查询时指定返回的需要的字段 ##

org.springframework.data.mongodb.core.query.BasicQuery提供了

构造方法

BasicQuery(DBObject queryObject, DBObject fieldsObject)

BasicQuery(java.lang.String query, java.lang.String fields)

BasicQuery查询语句可以指定返回字段，构造函数

BasicQuery(DBObject queryObject, DBObject fieldsObject)

fieldsObject 这个字段可以指定返回字段

fieldsObject.put(key,value)

key：字段

value：

说明：

1或者true表示返回字段

0或者false表示不返回该字段

\_id:默认就是1，没指定返回该字段时，默认会返回，除非设置为0是，就不会返回该字段。

指定返回字段，有时文档字段多并数据大时，我们指定返回我们需要的字段，这样既节省传输数据量，减少了内存消耗，提高了性能，在数据大时，性能很明显的。

**\[java\]** [view plain][] [copy][view plain]

1.  QueryBuilder queryBuilder = **new** QueryBuilder(); 
2.  queryBuilder.or(**new** BasicDBObject("onumber", "002"), **new** BasicDBObject("cname","zcy1")); 
3.  BasicDBObject fieldsObject=**new** BasicDBObject(); 
4.  fieldsObject.put("onumber", 1); 
5.  fieldsObject.put("cname", 1); 
6.  uery query=**new** BasicQuery(queryBuilder.get(),fieldsObject);

返回结果：

**\[java\]** [view plain][] [copy][view plain]

1.  \[\{ "cname":"zcy1","date":**null**,"id":"55bb9a3c27547f55fef9a10f","items":\[\],"onumber":"001"\},\{ "cname":"zcy1","date":**null**,"id":"55bb9a2727544d40b95156e1","items":\[\],"onumber":"001"\}\]

相当于MongoDB

db.orders.find(\{"$or" : \[ \{ "onumber" : "002"\} , \{"cname" : "zcy1"\}\]\},\{ "onumber":1,"cname":1\})

总结：

我们经常比较使用的是org.springframework.data.mongodb.core.query.BasicQuery，首先提供了4个构造函数，在构造查询语句时，使用的是文档形式，方便我们对复杂查询的语句构造，而且还提供了指定使用投影运算符返回的字段省略此参数返回匹配文档中的所有字段。指定返回字段，有时文档字段多并数据大时，我们指定返回我们需要的字段，这样既节省传输数据量，减少了内存消耗，提高了性能，在数据大时，性能很明显的。

我们今天介绍了基本的文档操作，我们先了解怎么构造查询语句，并使用介绍了这两种方法，方便我们对查询的基本的理解，思路会更加清晰。

[http_blog.csdn.net_congcong68_article_details_47183209]: http://blog.csdn.net/congcong68/article/details/47183209
[spring]: http://lib.csdn.net/base/javaee
[Center]: https://img-blog.csdn.net/20150801073519369?watermark/2/text/aHR0cDovL2Jsb2cuY3Nkbi5uZXQv/font/5a6L5L2T/fontsize/400/fill/I0JBQkFCMA==/dissolve/70/gravity/Center
[Center 1]: https://img-blog.csdn.net/20150801071350646?watermark/2/text/aHR0cDovL2Jsb2cuY3Nkbi5uZXQv/font/5a6L5L2T/fontsize/400/fill/I0JBQkFCMA==/dissolve/70/gravity/Center
[Center 2]: https://img-blog.csdn.net/20150801073545577?watermark/2/text/aHR0cDovL2Jsb2cuY3Nkbi5uZXQv/font/5a6L5L2T/fontsize/400/fill/I0JBQkFCMA==/dissolve/70/gravity/Center
[view plain]: http://blog.csdn.net/congcong68/article/details/47183209#
[MongoDB _ MongoDB]: http://blog.csdn.net/congcong68/article/details/46841075
[Link 1]: http://blog.csdn.net/congcong68/article/details/47064959
[Center 3]: https://img-blog.csdn.net/20150801073543295?watermark/2/text/aHR0cDovL2Jsb2cuY3Nkbi5uZXQv/font/5a6L5L2T/fontsize/400/fill/I0JBQkFCMA==/dissolve/70/gravity/Center