spring-data-mongodb高级查询用法小结
博客专区 > beanGou 的博客 > 博客详情
spring-data-mongodb高级查询用法小结
beanGou 发表于3个月前
spring-data-mongodb高级查询用法小结
  • 发表于 3个月前
  • 阅读 19
  • 收藏 0
  • 点赞 0
  • 评论 0
摘要: 本文主要讲述使用spring-data-mongodb进行一些比较复杂的查询小结

0.准备工作,先介绍下mongodb的集合名,java bean,以及数据结构

  • mongodb集合名称:doc_pageview

  • 集合数据结构:

    	{
    	"_id" : ObjectId("xxxx"),    
    	"shopId" : "xxx",
    	"domain" : "xxxx",
    	"url" : "xxxx",
    	"pageTitle" : "xxx",
    	"pageId" : "xxxx",
    	"cookie" : "xxx",
    	"ip" : "xxxx",
    	"viewDate" : NumberLong(xxxx),
    	"date" : "yyyy-MM-dd",
    	"stayTime" : NumberLong(xxxx)
    	}
    
  • java bean(为保证代码简洁,@Getter、@Setter的注解,使用到lombok):

    	 @Document(collection = "doc_pageview")
    	 @Getter
    	 @Setter
    	public class PageViewBean {
    	    @Id
    	    private String id; //主键
    	    private String domain; //域名
    	    private String url; //相对链接
    	    private String pageTitle; //页面标题
    	    private String pageId; //页面ID
    	    private String cookie;
    	    private Long viewDate; //访问时间(时间戳)
    	    private String shopId; //店铺ID
    	    private String ip; //访问IP
    	    private String date; // 日期:yyyy-MM-dd
    	    private Long stayTime; // 停留时间
    	}
    

1.相关包的引入(笔者使用版本是1.4.0.RELEASE,读者可以选择更高版本)

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-mongodb</artifactId>
    <version>1.4.0.RELEASE</version>
</dependency>

2.分页、排序操作

分页排序操作使用org.springframework.data.domain.Pageable,如果根据条件查询,使用注解@Query(org.springframework.data.mongodb.repository.Query)即可。eg:查询cookie=111,date=2017-09-07的前100条记录,按照viewDate倒序(注意实现 MongoRepository接口)

public interface PageViewLogRepository extends MongoRepository<PageViewLogBean, String> {

    /**
     * 根据参数查询日志集合
     * @param cookie
     * @param date
     * @param pageable
     * @return
     */
    @Query("{'cookie':?0,'date':?1}")
    List<PageViewLogBean>  findByCookieAndDate(String cookie,String date, Pageable pageable);
}       

测试:

    Pageable pageable = new PageRequest(0, 100, new Sort(Sort.Direction.DESC, "viewDate"));
    Page<PageViewLogBean> page = pageViewLogRepository. findByCookieAndDate("111", "2017-09-07", pageable);

3. 聚合操作(分组、求和、平均值、分页、排序)

刚开始尝试使用上面的@Query来做,后来没有发现解决办法(个人认为@Query只是用来处理比较简答的查询,大家如果有,欢迎提出来);本着关系型数据库能做的,mongodb也能做的指导思想,于是尝试新的api;虽然花了点时间,最终还是找到了,核心是org.springframework.data.mongodb.core.aggregation里面的类。其中,Aggregation.newAggregation这个方法是Aggregation的静态方法,支持可变参数,源码如下:

	/**
	 * Creates a new {@link Aggregation} from the given {@link AggregationOperation}s.
	 *
	 * @param operations must not be {@literal null} or empty.
	 */
	public static Aggregation newAggregation(AggregationOperation... operations) {
		return new Aggregation(operations);
	}
	

AggregationOperation是一个接口,很多聚合操作只需实现该接口即可,以下是所有的实现类。 可以猜到SortOperation(排序)、LimitOperation和SkipOperation(分页);好了,现在回到具体问题上面,eg:查询从2017-08-07到2017-09-07一个月店铺的平均单个页面停留时间(总的停留时间/总的pv数),并按从大到小的顺序排序(貌似没啥具体意义,😁😁😁)

import org.springframework.data.domain.Sort;
import org.springframework.data.mongodb.core.MongoTemplate;
import org.springframework.data.mongodb.core.aggregation.*;
import org.springframework.data.mongodb.core.query.Criteria;

// 根据avgPvTime=sumStayTime/countPv排序,如下
SortOperation sortOperation = sortOperation = Aggregation.sort(new Sort(Sort.Direction.DESC, "avgPvTime"));

// 根据shopId group查询
Aggregation aggregation = Aggregation.newAggregation(
                            Aggregation.match(Criteria.where("date").gte("2017-08-07").lte("2017-09-07")),
                            Aggregation.group("shopId").sum("stayTime").as("sumStayTime").count().as("countPv"),
                            new ProjectionOperation().andInclude("sumStayTime", "countPv").and("sumStayTime").divide("countPv").as("avgPvTime"),
                            sortOperation,
                            Aggregation.skip(0),
                            Aggregation.limit(100));
共有 人打赏支持
粉丝 8
博文 87
码字总数 19929
×
beanGou
如果觉得我的文章对您有用,请随意打赏。您的支持将鼓励我继续创作!
* 金额(元)
¥1 ¥5 ¥10 ¥20 其他金额
打赏人
留言
* 支付类型
微信扫码支付
打赏金额:
已支付成功
打赏金额: