mongoDB中聚合函数java处理示例详解

 更新时间:2019年04月16日 10:11:19   作者:VV不想说话  
这篇文章主要给大家介绍了关于mongoDB中聚合函数java处理的相关资料,文中通过示例代码介绍的非常详细,对大家学习或者使用mongoDB具有一定的参考学习价值,需要的朋友们下面来一起学习学习吧

1.问题

最近在做项目的时候碰到一个对mongoDB的数据处理,从MongoDB中拿到内嵌文档的时间排序的list。

一开始考虑到直接对mongoDB中的属性排序,后面发现属性存在内嵌文档中,所以处理中需要用到聚合函数。

思考

(key)解决这个问题的过程让我学到很多,发现自己在解决一个问题不仅查找问题的姿势不对,浪费太多时间。而且在碰到问题之后,应该多看看解决办法,甚至解决了之后要去思考问题,回顾问题。而不是像以前一样,解决问题了就万事大吉,抛之脑后。

2.解决

需要对document中的一个tweet_list 集合中的一个属性 timestamp_ms进行排序。 组内排序

使用聚合框架,通过match,unwind,sort等不同的组件创建一个管道。

类似mysql中的多层嵌套子查询。

mongoDB中js代码

db.text.aggregate(
 // Initial document match (uses index, if a suitable one is available)
 [
 { $match: {
  _id : ObjectId("5ca95b4bfb60ec43b5dd0db5")
 }},

 // Expand the scores array into a stream of documents
 { $unwind: '$tweet_list' },
  
  { $match: {
   'tweet_list.timestamp_ms': '1451841845660'
  }},

 // Sort in descending order
 { $sort: {
  'tweet_list.timestamp_ms': 1
 }}
 ]
)

java实现此聚合函数

java中的Aggregation类,查询条件的顺序决定结果。

Aggregation agg = Aggregation.newAggregation(
  Aggregation.match(Criteria.where("_id").is(id)),
  Aggregation.unwind("tweet_list"),
  Aggregation.sort(Sort.Direction.ASC,"tweet_list.timestamp_ms"),
  Aggregation.project("tweet_list.timestamp_ms","tweet_list.text","tweet_list.created_at")

);
AggregationResults<JSONObject> results = mongoTemplate.aggregate(agg, "text", JSONObject.class);
//System.out.println("results"+results.getRawResults()); //获取到的结果是document
//String res = results.getRawResults();
String json = com.mongodb.util.JSON.serialize(results.getRawResults());
System.out.println("JSON serialized Document: " + json);
JSONObject jso= JSON.parseObject(json);
JSONArray resultss=jso.getJSONArray("results");
System.out.println(resultss);

3.扩展

管道pipeline

以下的管道操作符可以按照任意顺序组合在一起使用。每个操作符都会接受一连串文档,对这些文档做了类型转换后,将转换后的文档作为结果传递给下一个操作符。直到最后一个管道操作符,将结果返回给客户端。

筛选match

尽可能将帅选放在管道的前部。两个原因:

1.先过滤掉不需要的文档,减少管道的工作量。

2.如果在project和group之前执行match,查询可以用索引。

3.不能在match中使用地理空间操作符

投射project

类似select操作。可以用管道表达式,数学表达式,日期表达式,字符表达式,逻辑表达式等。

分组group

跟mysql中的分组比较像

排序sort

1 升序 -1 降序

限制limit

限制结果条数

跳过skip

丢弃结果中的前n个文档

拆分unwind

把数组中的每个值拆分为单独的文档,例如此问题中需要对一个document中的tweetlist进行排序,可以使用unwind把tweetlist中的不同map拆分成不同的文档。

结果返回

文档

MapReduce

如果聚合框架中查询语言不能不表达,需要用到MapReduce。

使用:把问题拆分为多个小问题,把各个小问题发送到不同的机器上,每台机器只负责完成一部分的工作,完成之后,再把零碎的解决方案合并。

步骤:

1.映射map:把操作映射到集合中每个文档

2.洗牌shuffle:按照键值分组,并将产生的键值组成列表放到对应的键中。

3.化简reduce:把列表中的值化简成一个单值,值被返回,继续shuffle,然后最终每个键的列表只有一个值,即最终结果,

应用:

1.找到集合中所有键

2.网页分类

总结

以上就是这篇文章的全部内容了,希望本文的内容对大家的学习或者工作具有一定的参考学习价值,谢谢大家对脚本之家的支持。

相关文章

  • 解决MongoDB 位置查询报错planner returned error: unable to find index for $geoNear query的问题

    解决MongoDB 位置查询报错planner returned error: unable to find

    这篇文章主要介绍了MongoDB位置查询报错planner returned error: unable to find index for $geoNear query的解决方案,需要的朋友可以参考下
    2023-08-08
  • Mongodb多键索引中索引边界的混合问题小结

    Mongodb多键索引中索引边界的混合问题小结

    Mongodb为提高数组的查询效率,针对数组构建了多键索引,而Mongodb在应用多键数组查询时,也通过构建,减少数组查询的数值范围,来提高查询性能,本文结合Mongodb官方文档,阐述Mongodb在使用多键索引时的边界优化,感兴趣的朋友一起看看吧
    2024-07-07
  • MongoDB的安装启动及做成windows服务的教程图解

    MongoDB的安装启动及做成windows服务的教程图解

    这篇文章主要介绍了MongoDB的安装启动及做成windows服务的教程图解,非常不错,具有一定的参考借鉴价值,感兴趣的朋友跟随脚本之家小编一起学习吧
    2018-05-05
  • PHP库 查询Mongodb中的文档ID的方法

    PHP库 查询Mongodb中的文档ID的方法

    这篇文章主要介绍了PHP库 查询Mongodb中的文档ID的方法的相关资料,需要的朋友可以参考下
    2016-10-10
  • MongoDB中数据的替换方法实现类Replace()函数功能详解

    MongoDB中数据的替换方法实现类Replace()函数功能详解

    这篇文章主要介绍了MongoDB中数据的替换方法实现类Replace()函数功能详解,需要的朋友可以参考下
    2020-02-02
  • MongoDB入门教程之主从复制配置详解

    MongoDB入门教程之主从复制配置详解

    这篇文章主要介绍了MongoDB入门教程之主从复制配置详解,本文环境是windows+MongoDB,操作部分使用图片来讲解,需要的朋友可以参考下
    2014-08-08
  • mongodb安装_动力节点Java学院整理

    mongodb安装_动力节点Java学院整理

    这篇文章主要介绍了mongodb安装,小编觉得挺不错的,现在分享给大家,也给大家做个参考。一起跟随小编过来看看吧
    2017-08-08
  • MongoDB中的加减乘除运算详解

    MongoDB中的加减乘除运算详解

    这篇文章主要给大家介绍了关于MongoDB中加减乘除运算的相关资料,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2019-01-01
  • MongoDB创建和查询视图的方式

    MongoDB创建和查询视图的方式

    本文整理mongodb的官方文档,介绍mongodb的视图创建和查询,在Mongodb中,允许使用两种方式来创建视图,本文结合实例代码给大家介绍的非常详细,感兴趣的朋友一起看看吧
    2023-12-12
  • MongoDB数据查询方法干货篇

    MongoDB数据查询方法干货篇

    查询操作在我们日常操作数据库的时候是必不可少的一部分,最近有些空闲时间,所有就将MongoDB数据查询的一些方法技巧总结了处理,这篇文章主要介绍了MongoDB数据查询的相关资料,需要的朋友可以参考借鉴,一起来看看吧。
    2017-05-05

最新评论