返回顶部
首页 > 资讯 > 后端开发 > JAVA >Java8用Stream流一行代码实现数据分组统计,排序,最大值、最小值、平均值、总数、合计
  • 771
分享到

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

java开发语言 2023-08-31 07:08:49 771人浏览 独家记忆
摘要

Java8对数据处理可谓十分流畅,既不改变数据,又能对数据进行很好的处理,今天给大家演示下,用Java8的Stream如何对数据进行分组统计,排序,求和等 汇总统计方法 找到汇总统计的方法。这些方法属于java 8的汇总统计类。getAve

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

汇总统计方法

找到汇总统计的方法。这些方法属于java 8的汇总统计类。
getAverage(): 它返回所有接受值的平均值。
getCount(): 它计算所有元素的总数。
getMax(): 它返回最大值。
getMin(): 它返回最小值。
getSum(): 它返回所有元素的总和。

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

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

    @GetMapping("/list")    public void list(){        List inputFORMs = inputFormMapper.selectList();        Map collect = inputForms.stream()            .collect(Collectors.groupingBy(InputForm::getCreateUserName, Collectors.summarizingInt(InputForm::getStatus)));        // 对名字去重        Set 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 inputForms = inputFormMapper.selectList();        System.out.println("inputForms = " + inputForms);        Map 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> list(){        List inputForms = inputFormMapper.selectList();        System.out.println("inputForms = " + inputForms);        Map> collect = inputForms.stream()            .collect(Collectors.groupingBy(InputForm::getCreateCompanyName));        return collect;    }

 求最大值,最小值

    @GetMapping("/list")    public Map> list(){        List inputForms = inputFormMapper.selectList();        System.out.println("inputForms = " + inputForms);        Optional min = inputForms.stream()            .min(Comparator.comparing(InputForm::getId));        System.out.println("min = " + min);        return null;    }

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

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

    @GetMapping("/list")    public void list(){        List 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 max = inputForms.stream().max(Comparator.comparing(InputForm::getAgency));        if (max.isPresent()){            System.out.println("max = " + max);        }        // 求最小值        Optional 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 collect4 = inputForms.stream().collect(Collectors.groupingBy(InputForm::getCreateDeptName, Collectors.counting()));        System.out.println("collect4 = " + collect4);

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

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

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

        // 根据部门和是否退休进行分组,并取得每组中年龄最大的人        Map> 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);

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

--结束END--

本文标题: Java8用Stream流一行代码实现数据分组统计,排序,最大值、最小值、平均值、总数、合计

本文链接: https://lsjlt.com/news/384475.html(转载时请注明来源链接)

有问题或投稿请发送至: 邮箱/279061341@qq.com    QQ/279061341

猜你喜欢
软考高级职称资格查询
编程网,编程工程师的家园,是目前国内优秀的开源技术社区之一,形成了由开源软件库、代码分享、资讯、协作翻译、讨论区和博客等几大频道内容,为IT开发者提供了一个发现、使用、并交流开源技术的平台。
  • 官方手机版

  • 微信公众号

  • 商务合作