博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
使用spring data api查询分组中的mongodb最大值
阅读量:6145 次
发布时间:2019-06-21

本文共 1782 字,大约阅读时间需要 5 分钟。

  hot3.png

1,实现一个

GroupOperation groupOperation = Aggregation.group("stockno").max("volume").as("volume");

        Aggregation agg = Aggregation.newAggregation(StockQuotation.class,groupOperation);
        AggregationResults<java.util.Map> results = mongoTemplate.aggregate(agg,StockQuotation.class,java.util.Map.class);
        java.util.Map<String, Integer> classMaxScoreMap = new HashMap<String, Integer>();
        if(results.getMappedResults() != null && results.getMappedResults().size() != 0){
          for(java.util.Map map:results.getMappedResults()){
             classMaxScoreMap.put(map.get("_id").toString(), Integer.valueOf(map.get("volume").toString()));
             System.out.println("==============" + map.get("_id").toString() + " | " + Integer.valueOf(map.get("volume").toString()));
          }
        }

 

打印结果:

==============600004 | 6465485

==============600000 | 74449284

因为Aggregation.group()函数,参数不能为空,所以必须要分组,如果查询整个表里面某个列的最大值,这办法不行

2,写个日期的

//stockno,tradingDay是实体类中的字段,maxTradingDay是别名

        GroupOperation groupOperation = Aggregation.group("stockno").max("tradingDay").as("maxTradingDay");
        Aggregation agg = Aggregation.newAggregation(StockQuotation.class,groupOperation);
        AggregationResults<java.util.Map> results = mongoTemplate.aggregate(agg,StockQuotation.class,java.util.Map.class);
        java.util.Map<String, Object> classMaxScoreMap = new HashMap<String, Object>();
        if(results.getMappedResults() != null && results.getMappedResults().size() != 0){
          for(java.util.Map map:results.getMappedResults()){
             classMaxScoreMap.put(map.get("_id").toString(), map.get("maxTradingDay").toString());
             System.out.println("==============" + map.get("_id").toString() + " | " + map.get("maxTradingDay").toString());
          }
        }

打印结果:

==============600004 | Mon May 12 00:00:00 CST 2008

==============600000 | Mon May 12 00:00:00 CST 2008

转载于:https://my.oschina.net/hfq/blog/1817816

你可能感兴趣的文章
JS中apply方法和call方法
查看>>
how to write excellent code
查看>>
允许IP地址访问某个端口
查看>>
OSChina 周五乱弹 —— 你午睡用什么姿势?
查看>>
char * char[] int *指向char*的地址
查看>>
idea 常用插件
查看>>
lucene IKAnalyzer中文分词器学习(1)
查看>>
HTML条件注释判断IE<!--[if IE]><!--[if lt IE 9]>
查看>>
发布和逸出-构造过程中使this引用逸出
查看>>
Oracle执行计划发生过变化的SQL语句脚本
查看>>
使用SanLock建立简单的HA服务
查看>>
MySQL主从复制--MySQL5.6基于GTID及多线程复制
查看>>
发现一个叫阿尔法城的小站(以后此贴为我记录日常常用网址的帖子了)
查看>>
java 判断字符串是否为整数
查看>>
Apache Beam的架构概览
查看>>
url 传汉字方法
查看>>
Subversion使用Redmine帐户验证简单应用、高级应用以及优化
查看>>
Javascript Ajax 异步请求
查看>>
DBCP连接池
查看>>
cannot run programing "db2"
查看>>