查看原文
其他

Java8 Stream 一行代码实现数据分组统计、排序、最大值、最小值、平均值、总数、合计

小哈学Java 2024-04-16

来源:blog.csdn.net/xiaoheihai666/article/details/128152182

👉 欢迎加入小哈的星球 ,你将获得: 专属的项目实战(图文+视频) / Java 学习路线 / 一对一提问 / 学习打卡


目前, 正在星球内部带小伙伴做第一个项目:前后端分离博客,手摸手,后端 + 前端全栈开发,从 0 到 1 讲解每个功能点开发步骤,1v1 答疑,直到项目上线。目前已更新了76小节,累计10w+字,讲解图:513张,还在持续爆肝中.. 后续还会上新更多项目,如秒杀系统, 在线商城, IM即时通讯等,戳我加入学习,已有200+小伙伴加入

  • 示例:统计用户status的最大值,最小值,求和,平均值
  • 分组统计:
  • 如果我们想看某个部门下面有哪些数据,可以如下代码
  • 求最大值,最小值
  • 对某个字段求最大,最小,求和,统计,计数
  • 求最大值,最小值还可以这样做
  • 对某个字段求和并汇总
  • 求某个字段的平均值
  • 拼接某个字段的值,可以设置前缀,后缀或者分隔符
  • 根据部门进行分组,并获取汇总人数
  • 根据部门和是否退休进行分组,并汇总人数
  • 根据部门和是否退休进行分组,并取得每组中年龄最大的人

Java8对数据处理可谓十分流畅,既不改变数据,又能对数据进行很好的处理,今天给大家演示下,用Java8的Stream如何对数据进行分组统计,排序,求和等

这些方法属于java 8的汇总统计类:

  • getAverage(): 它返回所有接受值的平均值。
  • getCount(): 它计算所有元素的总数。
  • getMax(): 它返回最大值。
  • getMin(): 它返回最小值。
  • getSum(): 它返回所有元素的总和。

示例:统计用户status的最大值,最小值,求和,平均值

看官可以根据自己的需求进行灵活变通

@GetMapping("/list")
public void list(){
    List<InputForm> inputForms = inputFormMapper.selectList();
    Map<String, IntSummaryStatistics> collect = inputForms.stream()
        .collect(Collectors.groupingBy(InputForm::getCreateUserName, Collectors.summarizingInt(InputForm::getStatus)));

    // 对名字去重
    Set<String> collect1 = inputForms.stream().distinct().map(InputForm::getCreateUserName).collect(Collectors.toSet());

    // 遍历名字,从map中取出对应用户的status最大值,最小值,平均值。。。
    for (String s1 : collect1) {
        IntSummaryStatistics statistics1 = collect.get(s1);

        System.out.println("第一个用户的名字为====" + s1);
        System.out.println("**********************************************");
        System.out.println("status的个数为===" + statistics1.getCount());
        System.out.println("status的最小值为===" + statistics1.getMin());
        System.out.println("status的求和为===" + statistics1.getSum());
        System.out.println("status的平均值为===" + statistics1.getAverage());
        System.out.println();
        System.out.println();
    }
}

结果如下:

图片

分组统计:

@GetMapping("/list")
public void list(){
    List<InputForm> inputForms = inputFormMapper.selectList();
    System.out.println("inputForms = " + inputForms);

    Map<String, Long> collect = inputForms.stream().collect(Collectors.groupingBy(InputForm::getCreateUserName,
        Collectors.counting()));
    
    System.out.println("collect = " + collect);
}

其中Collectors.groupingBy(InputForm::getCreateUserName, Collectors.counting())返回的是一个Map集合,InputForm::getCreateUserName代表key,Collectors.counting()代表value,我是按照创建人的姓名进行统计

可以看到总共有九条数据,其中莫昀锦有两个,周亚丽有七个

如果我们想看某个部门下面有哪些数据,可以如下代码

@GetMapping("/list")
public Map<String, List<InputForm>> list(){
    List<InputForm> inputForms = inputFormMapper.selectList();
    System.out.println("inputForms = " + inputForms);

    Map<String, List<InputForm>> collect = inputForms.stream()
        .collect(Collectors.groupingBy(InputForm::getCreateCompanyName));

    return collect;
}

图片

求最大值,最小值

@GetMapping("/list")
public Map<String, List<InputForm>> list(){
    List<InputForm> inputForms = inputFormMapper.selectList();
    System.out.println("inputForms = " + inputForms);

    Optional<InputForm> min = inputForms.stream()
        .min(Comparator.comparing(InputForm::getId));

    System.out.println("min = " + min);
    return null;
}

图片

可以看到此id是最小的,最大值雷同

对某个字段求最大,最小,求和,统计,计数

@GetMapping("/list")
public void list(){
    List<InputForm> inputForms = inputFormMapper.selectList();
    System.out.println("inputForms = " + inputForms);

    IntSummaryStatistics collect = inputForms.stream()
        .collect(Collectors.summarizingInt(InputForm::getStatus));
    double average = collect.getAverage();
    int max = collect.getMax();
    int min = collect.getMin();
    long sum = collect.getSum();
    long count = collect.getCount();
    
    System.out.println("collect = " + collect);
}

求最大值,最小值还可以这样做

// 求最大值
Optional<InputForm> max = inputForms.stream().max(Comparator.comparing(InputForm::getAgency));
if (max.isPresent()){
    System.out.println("max = " + max);
}

// 求最小值
Optional<InputForm> min = inputForms.stream().min(Comparator.comparing(InputForm::getAgency));
if (min.isPresent()){
    System.out.println("min = " + min);
}

对某个字段求和并汇总

int sum = inputForms.stream().mapToInt(InputForm::getStatus).sum();
        System.out.println("sum = " + sum);

求某个字段的平均值

// 求某个字段的平均值
Double collect2 = inputForms.stream().collect(Collectors.averagingInt(InputForm::getStatus));
System.out.println("collect2 = " + collect2);

// 简化后
OptionalDouble average = inputForms.stream().mapToDouble(InputForm::getStatus).average();
if (average.isPresent()){
    System.out.println("average = " + average);
}

拼接某个字段的值,可以设置前缀,后缀或者分隔符

// 拼接某个字段的值,用逗号分隔,并设置前缀和后缀
String collect3 = inputForms.stream().map(InputForm::getCreateUserName).collect(Collectors.joining(",""我是前缀""我是后缀"));
System.out.println("collect3 = " + collect3);

根据部门进行分组,并获取汇总人数

// 根据部门进行汇总,并获取汇总人数
Map<String, Long> collect4 = inputForms.stream().collect(Collectors.groupingBy(InputForm::getCreateDeptName, Collectors.counting()));
System.out.println("collect4 = " + collect4);

根据部门和是否退休进行分组,并汇总人数

// 根据部门和是否退休进行分组,并汇总人数
Map<String, Map<Integer, Long>> collect5 = inputForms.stream().collect(Collectors.groupingBy(InputForm::getCreateDeptName, Collectors.groupingBy(InputForm::getIsDelete, Collectors.counting())));
System.out.println("collect5 = " + collect5);

根据部门和是否退休进行分组,并取得每组中年龄最大的人

// 根据部门和是否退休进行分组,并取得每组中年龄最大的人
Map<String, Map<Integer, InputForm>> collect6 = inputForms.stream().collect(
    Collectors.groupingBy(InputForm::getCreateDeptName,
        Collectors.groupingBy(InputForm::getIsDelete,
            Collectors.collectingAndThen(
                Collectors.maxBy(
                    Comparator.comparing(InputForm::getAge)), Optional::get))));
System.out.println("collect6 = " + collect6);


👉 欢迎加入小哈的星球 ,你将获得: 专属的项目实战(图文+视频) / Java 学习路线 / 一对一提问 / 学习打卡


目前, 正在星球内部带小伙伴做第一个项目:前后端分离博客,手摸手,后端 + 前端全栈开发,从 0 到 1 讲解每个功能点开发步骤,1v1 答疑,直到项目上线。目前已更新了76小节,累计10w+字,讲解图:513张,还在持续爆肝中.. 后续还会上新更多项目,如秒杀系统, 在线商城, IM即时通讯等,戳我加入学习,已有200+小伙伴加入

1. 面试官:post为什么会发送两次请求?

2. Spring 在多线程环境下如何确保事务一致性?

3. 告别复杂逻辑,项目终于用上了 Spring 状态机,非常优雅!

4. 我的私密学习小圈子~

最近面试BAT,整理一份面试资料Java面试BATJ通关手册,覆盖了Java核心技术、JVM、Java并发、SSM、微服务、数据库、数据结构等等。

获取方式:点“在看”,关注公众号并回复 Java 领取,更多内容陆续奉上。

PS:因公众号平台更改了推送规则,如果不想错过内容,记得读完点一下在看,加个星标,这样每次新文章推送才会第一时间出现在你的订阅列表里。

“在看”支持小哈呀,谢谢啦

继续滑动看下一个
向上滑动看下一个

您可能也对以下帖子感兴趣

文章有问题?点此查看未经处理的缓存