一、一个 Criteria将所有条件整合,注意(对同一个属性加两次限制需使用andOperator,并且只能使用一次)
分、 排序、按时间查询
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");
二、使用query.addCriteria()添加多个Criteria条件,query的条件,可以多次查询使用,先使用条件查询总数量,然后根据该条件查询记录分页
Query query = new Query();
if(null!=message){
if(StringUtils.isNotBlank(message.getDeviceAddr())){
//criteria.andOperator(Criteria.where("deviceAddr").is(message.getDeviceAddr()));
query.addCriteria(Criteria.where("deviceAddr").is(message.getDeviceAddr()));
}
if(StringUtils.isNotBlank(message.getFunctionCode())){
//criteria.andOperator(Criteria.where("functionCode").is(message.getFunctionCode()));
query.addCriteria(Criteria.where("functionCode").is(message.getFunctionCode()));
}
if(StringUtils.isNotBlank(message.getStartTime())&&StringUtils.isBlank(message.getEndTime())){
//criteria.andOperator(Criteria.where("messageTime").gte(DateUtil.StringToDate(message.getStartTime())));
query.addCriteria(Criteria.where("messageTime").gte(DateUtil.StringToDate(message.getStartTime())));
}
if(StringUtils.isNotBlank(message.getEndTime())&&StringUtils.isBlank(message.getStartTime())){
//criteria.andOperator(Criteria.where("messageTime").lte(DateUtil.StringToDate(message.getEndTime())));
query.addCriteria(Criteria.where("messageTime").lte(DateUtil.StringToDate(message.getEndTime())));
}
if(StringUtils.isNotBlank(message.getStartTime())&&StringUtils.isNotBlank(message.getEndTime())){
/*criteria.andOperator(Criteria.where("messageTime").gte(DateUtil.StringToDate(message.getStartTime()))
.lte(DateUtil.StringToDate(message.getEndTime())));
*/
query.addCriteria(Criteria.where("messageTime").gte(DateUtil.StringToDate(message.getStartTime()))
.lte(DateUtil.StringToDate(message.getEndTime())));
}
}
int count = (int) mongoTemplate.count(query,BaseMessage.class,"message");
pageResult.initPageInfo(message.getPageSize(),message.getPageNumber(),count);
query.with(new Sort(Sort.Direction.DESC, "messageTime"));
//分页
query.skip(pageResult.getBeginRowNumber()).limit(pageResult.getPageSize());
List<BaseMessageDto> msgList = mongoTemplate.find(query, BaseMessageDto.class,"message");
注意:query.andOperator();只能使用一次,不可以同时使用多个andOperator,但可以一个andOperator,添加多个Criteria条件:query.andOperator(Criteria1,Criteria2,Criteria3);