MongoTemplate复合条件查询

时间:2021-11-08 08:13:43

分、 排序、按时间查询

Query query = new Query();
        //必须条件
        Criteria c = Criteria.where("VINID").is(Map.get(vin));
        //范围条件
        if(!StringUtils.isEmpty(start)&&StringUtils.isEmpty(end)){
            c.and("TIME1").gte(GetTime1(start));
        }else if(StringUtils.isEmpty(start)&&!StringUtils.isEmpty(end)){
            c.and("TIME1").lte(GetTime1(end));
        }else if(!StringUtils.isEmpty(start)&&!StringUtils.isEmpty(end)){

//对同一个属性加两次限制需这样操作
            c.andOperator(
            c.where("TIME1").gte(GetTime1(start)),
            c.where("TIME1").lte(GetTime1(end))
            );
        }
        query.addCriteria(c);
        //总数
        num = (int) mongoTemplate.count(query,CarDataEx.class,"jmevTest");
        System.out.println("总数:"+num);
        ht.put("total", num);
        //分页
        query.skip((page-1)*rows).limit(rows);
        //排序
        query.with(new Sort(Sort.Direction.DESC,"TIME1"));
                //query.with(new Sort(properties));
                rst = mongoTemplate.find(query,CarDataEx.class,"jmevTest");

二分组查询

 public Page<CourseDetail> listCourseDetails(QueryCourseDetailModel queryModel) {

//条件一 where gradeId in (集合) and mark=true
Criteria criteria = Criteria.where("gradeId").in(gradeIds).and("mark").is(true);

if (null != status && status.size() > 0) {
Criteria criteriaChild = new Criteria();
//条件二 criteriaChild 条件查询 ( teacherCommentStatus = XX or parentsReplyTeacherStatus =XX )
criteriaChild.orOperator(Criteria.where("teacherCommentStatus").in(status), Criteria.where("parentsReplyTeacherStatus").is(replayStatus));
}

//拼接最后语句 where gradeId in (集合) and mark=true and ( teacherCommentStatus = XX or parentsReplyTeacherStatus =XX )
criteria.andOperator(criteriaChild); //分组条件
GroupBy groupBy = new GroupBy("gradeId")
.initialDocument("{ count: 0 }")
.reduceFunction("function (doc,pre){pre.count +=1 ;}"); //使用 mongoTemplate.group 分组查询
GroupByResults groupByResults = mongoTemplate.
group(criteria, "homework", groupBy, Homework.class); //获取结果
BasicDBList list = (BasicDBList) groupByResults.getRawResults().get("retval");
list.stream().map(map -> {
BasicDBObject obj = (BasicDBObject) map;
......
return obj;
}).collect(Collectors.toList());

return list; ​}