zoukankan      html  css  js  c++  java
  • spring boot中 mongdb 多条件复杂查询

    1.dao层继承MongoRepository

    public interface PFlowLineStationHourDao extends MongoRepository<PFlowLineStationHourEntity, Long>{

    }

    2.service层注入PFlowLineStationHourDao ,MongoTemplate

    例:

    @Service

    public class PFlowLineServiceImpl  implements PFlowLineService{

    @Autowired

    public PFlowLineStationHourDao pFlowLineStationHourDao;

    @Autowired

            private MongoTemplate mongoTemplate;

            public List<?> queryPFlowLineStationHour(PFlowQueryParam param) {
    Query query = new Query();
    if(param.getDates().size()>0){
    query.addCriteria(Criteria.where("yearMonthDate").in(param.getDates()));
    }else{
    int beginDate = Integer.parseInt(DateUtil.getYearMonthDayFormat(DateUtil.getDayBefore(param.getBegintime())));
    int endDate = Integer.parseInt(DateUtil.getYearMonthDayFormat(DateUtil.getDayAfter(param.getEndtime())));
    query.addCriteria(Criteria.where("yearMonthDate").gte(beginDate).lte(endDate));
    }
    if(param.getLineCodes().size()>0){
    query.addCriteria(Criteria.where("lineCode").in(param.getLineCodes()));
    }
    if(param.getStationnames().size()>0){
    query.addCriteria(Criteria.where("stationname").in(param.getStationnames()));
    }
    if(param.getAreacodes().size()>0){
    query.addCriteria(Criteria.where("areacode").in(param.getAreacodes()));
    }
    return mongoTemplate.find(query, PFlowLineStationHourEntity.class);
    }

    }


  • 相关阅读:
    广播和多播
    nohup和&后台运行,进程查看及终止
    Java知识汇总——思维导图
    linux 基础命令使用
    scp命令详解
    linux 安装crontab执行定时任务
    linux磁盘挂载
    虚拟机安装网络设置
    Android直播实现srs流媒体服务器部署
    java的(PO,VO,TO,BO,DAO,POJO)解释
  • 原文地址:https://www.cnblogs.com/timeboy/p/9464402.html
Copyright © 2011-2022 走看看