Java新特性Stream流开发技巧

简介: Java新特性Stream流开发技巧

1.组装多个集合的数据,避免for循环操作数据库

假如有这样一个需求,需要我们组装从数据库中查出来的Student集合以及Student对应的班级名称返回给前端StudentVO

public static List<StudentVO> assembleData(List<Long> ids) {
    List<StudentVO> result = new ArrayList<>();
    List<Student> students = this.selectBatchIds(ids);
    // 可能有小伙伴会用students的id一个个去数据库拿,但这样是不对的,会严重影响数据库性能
    for (Person p : PersonList){
        PersonVO vo = new PersonVO();
        Class c = classMapper.selectById(p.getClassId());
        p.setClassName(c.getName);
        result.add(p);
    }
    return result;
}

循环访问数据库,是会严重影响数据库性能的

优化思路就是批量获取所有数据,然后再组装数据
public static List<StudentVO> assembleData(List<Long> ids) {
    //批量查出studnt
    List<Student> students = this.selectBatchIds(ids);
    //批量查出class 也可以写条sql,在sql语句循环查(效果比你for循环里查询数据库好)
    List<Long> classIds = students.stream().map(s -> s::getClassId()).distinct().collect(Collectors.toList());
    List<Class> classes = classMapper.selectBatchIds(classIds);
    //转换成Map
    Map<String, Class> classMap =
    classes.stream().collect(Collectors.toMap(Class::getId, Function.identity()));
    //封装成StudentVO
    return s.stream().map(s -> {
        StudentVO vo = new StudentVO();
        vo.setStudent(s);
        vo.setClassName(classes.get(s.getClassId()).getName())
        return vo;
    }).collect(Collectors.toList());
}
sql参考模板
<select id="selectByUserIds" resultType="com.chenguangzhao.entities.UserInfoDTO" parameterType="java.util.List">
    SELECT
    a.id AS userId,
  a.user_name AS userName,
  b.image_url AS imageUrl
    FROM t_user a
    LEFT JOIN t_image b on a.image_id=b.id
    <where>
      <if test="userIdList.size()>0">
          a.id in
          <foreach collection="userIdList" item="id" index="index" open="(" close=")" separator=",">
            #{id}
      </foreach>
        </if>
   </where>
</select>

2.把List转换为Map

public static Map<Long, Student> listToMap(List<Student> list) {
    return list.stream().collect(Collectors.toMap(Student::getId(), Function.identity()));
}

3.按对象字段排序

public static List<Student> sortBy(List<Student> list) {
    return list.stream().sorted(
      (o1, o2) ->
        (o1.getId().compareTo(o2.getId()))
    ).collect(Collectors.toList());
}
//简化
public static List<Student> sortBy(List<Student> list) {
    return list.stream().sorted(
      Comparator.comparing(Student::getId()) //直接调用类型内部实现的CompareTo
    ).collect(Collectors.toList());
}
//倒序
public static List<Student> sortBy(List<Student> list) {
    return list.stream().sorted(
      Comparator.comparing(Student::getId()).reversed()
    ).collect(Collectors.toList());
}
//多字段排序
public static List<Student> sortBy(List<Student> list) {
    return list.stream().sorted(
      Comparator.comparing(Student::getId())
        .thenComparing(Student::getAge())
    ).collect(Collectors.toList());
}

4.求多个集合的交集

public static List<Student> intersection(List<Student> s1, List<Student> s2) {
    Map<String, Student> m1 = s1.stream().collect(Collectors.toMap(Student::getId(), Function.identity()));
    return s2.stream().filter(s -> m1.get(s.getId())).collect(Collectors.toList());
}

5.把数据分组

在开发项目中我们可能会将从数据库中查出来的数据按照字段分组(其实在数据库中分好组也可以), 但是我们有时需要在业务层面输出

在Java8之前我们可能会这样写

public static Map<String, List<Student>> toGroupingMap(List<Student> list) {
    Map<String, List<Student>> resultMap = new Map<>();
    for (Student s : list) {
        List<Student> students = resultMap.get(s.getAge());
        if (students == null) {
            List<Student> s = new ArrayList<>();
            resultMap.put(s.getAge(), s);
        }
        resultMap.put(s.getAge(), students);
    }
}

Java8之后我们仅需要用stream分组函数就行了

public static Map<String, List<Student>> toGroupingMap(List<Student> list) {
    return list.stream().collect(Collectors.grouping(Student::getAge()));
}


相关文章
|
2天前
|
移动开发 前端开发 Java
Java最新图形化界面开发技术——JavaFx教程(含UI控件用法介绍、属性绑定、事件监听、FXML)
JavaFX是Java的下一代图形用户界面工具包。JavaFX是一组图形和媒体API,我们可以用它们来创建和部署富客户端应用程序。 JavaFX允许开发人员快速构建丰富的跨平台应用程序,允许开发人员在单个编程接口中组合图形,动画和UI控件。本文详细介绍了JavaFx的常见用法,相信读完本教程你一定有所收获!
Java最新图形化界面开发技术——JavaFx教程(含UI控件用法介绍、属性绑定、事件监听、FXML)
|
25天前
|
Java 开发者 微服务
Spring Boot 入门:简化 Java Web 开发的强大工具
Spring Boot 是一个开源的 Java 基础框架,用于创建独立、生产级别的基于Spring框架的应用程序。它旨在简化Spring应用的初始搭建以及开发过程。
46 6
Spring Boot 入门:简化 Java Web 开发的强大工具
|
13天前
|
存储 JavaScript 前端开发
基于 SpringBoot 和 Vue 开发校园点餐订餐外卖跑腿Java源码
一个非常实用的校园外卖系统,基于 SpringBoot 和 Vue 的开发。这一系统源于黑马的外卖案例项目 经过站长的进一步改进和优化,提供了更丰富的功能和更高的可用性。 这个项目的架构设计非常有趣。虽然它采用了SpringBoot和Vue的组合,但并不是一个完全分离的项目。 前端视图通过JS的方式引入了Vue和Element UI,既能利用Vue的快速开发优势,
74 13
|
17天前
|
算法 Java API
如何使用Java开发获得淘宝商品描述API接口?
本文详细介绍如何使用Java开发调用淘宝商品描述API接口,涵盖从注册淘宝开放平台账号、阅读平台规则、创建应用并申请接口权限,到安装开发工具、配置开发环境、获取访问令牌,以及具体的Java代码实现和注意事项。通过遵循这些步骤,开发者可以高效地获取商品详情、描述及图片等信息,为项目和业务增添价值。
52 10
|
11天前
|
前端开发 Java 测试技术
java日常开发中如何写出优雅的好维护的代码
代码可读性太差,实际是给团队后续开发中埋坑,优化在平时,没有那个团队会说我专门给你一个月来优化之前的代码,所以在日常开发中就要多注意可读性问题,不要写出几天之后自己都看不懂的代码。
49 2
|
16天前
|
存储 Java 开发者
什么是java的Compact Strings特性,什么情况下使用
Java 9引入了紧凑字符串特性,优化了字符串的内存使用。它通过将字符串从UTF-16字符数组改为字节数组存储,根据内容选择更节省内存的编码方式,通常能节省10%至15%的内存。
|
20天前
|
JavaScript 安全 Java
java版药品不良反应智能监测系统源码,采用SpringBoot、Vue、MySQL技术开发
基于B/S架构,采用Java、SpringBoot、Vue、MySQL等技术自主研发的ADR智能监测系统,适用于三甲医院,支持二次开发。该系统能自动监测全院患者药物不良反应,通过移动端和PC端实时反馈,提升用药安全。系统涵盖规则管理、监测报告、系统管理三大模块,确保精准、高效地处理ADR事件。
|
25天前
|
存储 Java 数据挖掘
Java 8 新特性之 Stream API:函数式编程风格的数据处理范式
Java 8 引入的 Stream API 提供了一种新的数据处理方式,支持函数式编程风格,能够高效、简洁地处理集合数据,实现过滤、映射、聚合等操作。
41 6
|
26天前
|
Java API 开发者
Java中的Lambda表达式与Stream API的协同作用
在本文中,我们将探讨Java 8引入的Lambda表达式和Stream API如何改变我们处理集合和数组的方式。Lambda表达式提供了一种简洁的方法来表达代码块,而Stream API则允许我们对数据流进行高级操作,如过滤、映射和归约。通过结合使用这两种技术,我们可以以声明式的方式编写更简洁、更易于理解和维护的代码。本文将介绍Lambda表达式和Stream API的基本概念,并通过示例展示它们在实际项目中的应用。
|
16天前
|
Rust 安全 Java
Java Stream 使用指南
本文介绍了Java中Stream流的使用方法,包括如何创建Stream流、中间操作(如map、filter、sorted等)和终结操作(如collect、forEach等)。此外,还讲解了并行流的概念及其可能带来的线程安全问题,并给出了示例代码。