Spring boot中mongoDB的查询--Query， QueryBuilder、BasicQuery

朱雀 2022-05-24 03:15 408阅读 0赞

NoSQL在日常项目中的使用越来越普遍，尤其以mongoDB为甚。而java开发我们最常使用的框架非spring系列莫属。 因此本文主要介绍如何使用如何使用MongoTemplate进行查询，本文不包含如何使用spring-data-monog中的MongoRepository进行查询，MongoRepository会在其他博文中介绍。

我们可以直接在服务中使用MongoTemplate， 然后依据业务在controller’、或者其他地方调用查询，本文为了简单起见，直接在controller中调用MongoTemplate的查询方法。

*  **Query**

我们先看看query，MongoTemplate中大量方法就是使用query进行查询。

public <T> T findOne(Query query, Class<T> entityClass) 
        public <T> T findOne(Query query, Class<T> entityClass, String collectionName)
        public boolean exists(Query query, Class<?> entityClass)
        public boolean exists(Query query, String collectionName)
        public boolean exists(Query query, Class<?> entityClass, String collectionName) 
        public <T> List<T> find(Query query, Class<T> entityClass) 
        public <T> List<T> find(Query query, Class<T> entityClass, String collectionName) 
        public <T> T findById(Object id, Class<T> entityClass) 
        public <T> T findById(Object id, Class<T> entityClass, String collectionName) 
        ...

我们再看看Query自身主要包含哪些内容，

public class Query { 
        private static final String RESTRICTED_TYPES_KEY = "_$RESTRICTED_TYPES";
        private final Set<Class<?>> restrictedTypes = new HashSet();
        private final Map<String, CriteriaDefinition> criteria = new LinkedHashMap();
        private Field fieldSpec;
        private Sort sort;
        private int skip;
        private int limit;
        private String hint;
        private Meta meta = new Meta();

看一看主要是包含CriteriaDefinition，其次是fieldSpec，也就是要冲collection中的一行数据取出哪些字段。再次是sort，也就是安装什么字段进行排序，最后是skip和limit，也就是和分页相关的。

使用Hibernate的应该对Criteria非常熟悉。criteria可以完成基本的，等于，大于，等于大于，小于，小于等于，不等于，包含，in等最进本的查询比较操作。

例如，要比较时间大小，其中startDate和endDate都是Date类型，timestamp在mongo中储存的也是Date类型。 注意我的数据在collection中都是存储成Document.class， 也就是org.bson.Document类型

Query query = new Query();
    Criteria criteria = Criteria.where("timestamp").gte(startDate).lte(endDate);
    query.addCriteria(criteria);
    query.with(new Sort(Sort.Direction.DESC, "timestamp"));
    
    List<Document> documentList = mongoTemplate.find(query, Document.class, collectionName);

我们Query 的排序和分页比较简单。如上面的例子所示Sort，当然我们需要调用long totalCount = mongoTemplate.count(query, Document.class, collectionName);获取该query总共可以查询多少,然后设置query.skip(start).limit(limit);再调用List documentList = mongoTemplate.find(query, Document.class, collectionName);获得本次要显示的内容。

效果图  
![这里写图片描述][70]

*  **BasicQuery**

BasicQuery集成了Query，更加灵活了。

public class BasicQuery extends Query { 
        private final DBObject queryObject;
        private DBObject fieldsObject;
        private DBObject sortObject;
    
        public BasicQuery(String query) {
            this((DBObject)JSON.parse(query));
        }

我们可以直接将json的查询字符串传递给BasicQuery， 例如\{ “length” : \{ *l**t*:210,  l t : 210 , gt : 100\}\}。

Query query = new BasicQuery(queryJsonStr);
     query.with(new Sort(Sort.Direction.DESC, "timestamp"));
    
     long totalCount = mongoTemplate.count(query, Document.class, collectionName);
     List<Document> documentList = mongoTemplate.find(query, Document.class, collectionName);

效果图  
![这里写图片描述][70 1]

*  **QueryBuilder**

QueryBuilder有些类似于criteria，可以在其中比较各个字段，然后提交给BasicQuery。

QueryBuilder queryBuilder = new QueryBuilder();
             //也是查询desc字段等于传入的desc变量并且conent字段等于传入的conent变量
             queryBuilder.and(new BasicDBObject("desc",desc), new BasicDBObject("content",content));
            Query query = new BasicQuery(queryBuilder.get());
    
            query.with(new Sort(Sort.Direction.DESC, "timestamp"));
    
            long totalCount = mongoTemplate.count(query, Document.class, collectionName);
    
            //查询时指定返回的需要的字段
            BasicDBObject fieldsObject = new BasicDBObject();
            fieldsObject.put("content", 1);
            fieldsObject.put("desc", 1);
            query = new BasicQuery(queryBuilder.get(),fieldsObject);
            List<Document> documentList = mongoTemplate.find(query, Document.class, collectionName);

截图  
![这里写图片描述][70 2]

本博文的全部代码在[这里][Link 1]，具体是springBootMongo工程的 MongoReadWriteController。 欢迎加星，下载

[70]: /images/20220524/b8c798d92cd64e8f9ad84b3126b1849b.png
[70 1]: /images/20220524/1e6983568c2443a787ce0fc2010d4f95.png
[70 2]: /images/20220524/ee573facede8430a88659bf29edd02ac.png
[Link 1]: https://github.com/yqbjtu/mongodbTutorial