Java8 Stream 一行代码实现数据分组统计、排序、最大值、最小值、平均值、总数、合计... |
您所在的位置：网站首页 › Java数据分组 › Java8 Stream 一行代码实现数据分组统计、排序、最大值、最小值、平均值、总数、合计... |
Java8 Stream 一行代码实现数据分组统计、排序、最大值、最小值、平均值、总数、合计...
|
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); 来源：blog.csdn.net/wml_JavaKill/ article/details/132140471后端专属技术群 构建高质量的技术交流社群，欢迎从事编程开发、技术招聘HR进群，也欢迎大家分享自己公司的内推信息，相互帮助，一起进步！ 文明发言，以交流技术、职位内推、行业探讨为主 广告人士勿入，切勿轻信私聊，防止被骗
|
【本文地址】
今日新闻 |
推荐新闻 |