前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >spring-data-mongodb之Aggregation

spring-data-mongodb之Aggregation

作者头像
猿天地
发布2018-04-03 12:24:37
3.6K0
发布2018-04-03 12:24:37
举报
文章被收录于专栏:猿天地

这篇文章主要介绍下在data框架中如何使用Aggregation进行分组统计。

基本的操作包括:

  1. $project - 可以从子文档中提取字段,可以重命名字段。
  2. $match - 可以实现查找的功能。
  3. $limit - 接受一个数字n,返回结果集中的前n个文档。
  4. $skip - 接受一个数字n,丢弃结果集中的前n个文档。
  5. $group - 统计操作, 还提供了一系列子命令。
  6. $avg, $sum 等等函数…。
  7. $sort - 排序。

基于我们之前文章的数据我们就简单的统计下每个用户发过多少篇文章。 如果是用的mysql那么查询语句如下:

代码语言:javascript
复制
select article.author, count(*) as count from article_info as article group by article.author having count > 0

既然我们要用mongodb来实现,还要用框架来做,那么首先我们得知道用原始的语句怎么写,如下:

代码语言:javascript
复制
db.article_info.aggregate([
    {
        "$group": {
            "_id": "$author",
            "count": {
                "$sum": 1
            },
            "name": {
                "$first": "$author"
            }
        }
    },
    {
        "$project": {
            "name": 1,
            "count": 1,
            "_id": 0
        }
    },
    {
        "$match": {
            "count": {
                "$gt": 0
            }
        }
    }
]);

$group:根据author分组,然后统计次数,用$sum函数,显示第一个名称 $project:定义要显示的key,1为显示,0为不显示 $match:过滤掉没发过文章的用户,次数大于0

下面看spring-data-mongodb中我们要怎么去实现这个功能

代码语言:javascript
复制
Aggregation agg = newAggregation(
  group("author").count().as("count").first("author").as("name"),
  project("name","count"),
  sort(Direction.DESC, "count"),
  match(Criteria.where("count").gt(0))
);
AggregationResults<ArticleResult> results = mongoTemplate.aggregate(agg, "article_info", ArticleResult.class);
List<ArticleResult> tagCount = results.getMappedResults();
for (ArticleResult studentResult : tagCount) {
    System.out.println(studentResult.getName() + "\t" + studentResult.getCount());
} 

按照原始的语句,用框架的语法拼出来就可以了

当然还有的小伙伴还是用习惯了java驱动的写法,也可以,就是没上面简洁

代码语言:javascript
复制
List<DBObject> pipeline = new ArrayList<DBObject>();
BasicDBObject group = new BasicDBObject();
group.put("$group", new  BasicDBObject("_id","$author")
     .append("count", new  BasicDBObject("$sum",1))
     .append("name", new BasicDBObject("$first","$author")));

BasicDBObject project = new BasicDBObject();
project.put("$project", new  BasicDBObject("name",1)
       .append("count", 1).append("_id", 0));
pipeline.add(group);
pipeline.add(project);
AggregationOutput output = mongoTemplate.getCollection("article_info").aggregate(pipeline);
Iterable<DBObject> iterable = output.results();
for (DBObject dbObject : iterable) {
     System.out.println(dbObject);
} 
本文参与 腾讯云自媒体同步曝光计划,分享自微信公众号。
原始发表:2016-09-11,如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 猿天地 微信公众号,前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体同步曝光计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
相关产品与服务
云数据库 SQL Server
腾讯云数据库 SQL Server (TencentDB for SQL Server)是业界最常用的商用数据库之一,对基于 Windows 架构的应用程序具有完美的支持。TencentDB for SQL Server 拥有微软正版授权,可持续为用户提供最新的功能,避免未授权使用软件的风险。具有即开即用、稳定可靠、安全运行、弹性扩缩等特点。
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档