Java 8 Stream API重构：优化关联数据更新与列表过滤操作-java教程-PHP中文网

Java 8 Stream API重构：优化关联数据更新与列表过滤操作

心靈之曲

发布： 2025-11-22 20:23:01

原创

688人浏览过

Java 8 Stream API重构：优化关联数据更新与列表过滤操作

本教程旨在指导如何使用java 8 stream api重构传统java代码中涉及列表遍历、外部数据查询及元素更新与过滤的场景。我们将通过一个具体示例，展示如何将命令式循环转换为更具函数式风格的流操作，包括安全处理 `optional` 类型和高效执行列表元素移除，从而提升代码的简洁性和可读性。

传统代码中的常见问题与Java 8 Stream的引入

在日常开发中，我们经常会遇到需要遍历一个集合，根据集合中每个元素的属性去查询外部数据（如数据库），然后更新该元素的某个字段，最后可能还需要对集合进行过滤的场景。传统的Java做法通常涉及 for 循环和条件判断，这种命令式风格的代码在处理复杂逻辑时，可能会显得冗长且不易维护。

考虑以下一个典型的Java方法，它负责根据制造商ID和价格代码更新 ItemPriceCode 的制造商价格名称，并移除已标记为删除的价格代码。此示例中，manufacturerPriceCodesRepository 模拟了数据库访问层。

import java.util.List;
import java.util.Optional;
import static com.example.Constants.NOT_DELETED; // 假设常量定义
import static com.example.Constants.DELETED;     // 假设常量定义

// 假设Item, ItemPriceCode, ManufacturerPriceCodes是POJO
// 假设manufacturerPriceCodesRepository是JPA Repository或类似的DAO

public class ItemService {

    private ManufacturerPriceCodesRepository manufacturerPriceCodesRepository; // 依赖注入

    // 构造函数或setter注入
    public ItemService(ManufacturerPriceCodesRepository manufacturerPriceCodesRepository) {
        this.manufacturerPriceCodesRepository = manufacturerPriceCodesRepository;
    }

    private Item getItemManufacturerPriceCodes(Item item) {
        List<ItemPriceCode> itemPriceCodes = item.getItemPriceCodes();

        // 遍历并更新ItemPriceCode
        for (ItemPriceCode ipc : itemPriceCodes) {
            Optional<ManufacturerPriceCodes> mpc = manufacturerPriceCodesRepository.findByManufacturerIDAndPriceCodeAndRecordDeleted(
                    item.getManufacturerID(), ipc.getPriceCode(), NOT_DELETED);

            if (mpc.isPresent()) {
                ipc.setManufacturerPriceCode(mpc.get().getName());
            }
        }

        // 过滤并移除已删除的ItemPriceCode
        itemPriceCodes.removeIf(ipc -> DELETED.equals(ipc.getRecordDeleted()));

        return item;
    }
}

// 假设的Repository接口和实体类定义
interface ManufacturerPriceCodesRepository {
    Optional<ManufacturerPriceCodes> findByManufacturerIDAndPriceCodeAndRecordDeleted(
            String manufacturerID, String priceCode, String recordDeleted);
}

class Item {
    private String manufacturerID;
    private List<ItemPriceCode> itemPriceCodes;

    public String getManufacturerID() { return manufacturerID; }
    public void setManufacturerID(String manufacturerID) { this.manufacturerID = manufacturerID; }
    public List<ItemPriceCode> getItemPriceCodes() { return itemPriceCodes; }
    public void setItemPriceCodes(List<ItemPriceCode> itemPriceCodes) { this.itemPriceCodes = itemPriceCodes; }
}

class ItemPriceCode {
    private String priceCode;
    private String manufacturerPriceCode; // 需要更新的字段
    private String recordDeleted;

    public String getPriceCode() { return priceCode; }
    public void setPriceCode(String priceCode) { this.priceCode = priceCode; }
    public String getManufacturerPriceCode() { return manufacturerPriceCode; }
    public void setManufacturerPriceCode(String manufacturerPriceCode) { this.manufacturerPriceCode = manufacturerPriceCode; }
    public String getRecordDeleted() { return recordDeleted; }
    public void setRecordDeleted(String recordDeleted) { this.recordDeleted = recordDeleted; }
}

class ManufacturerPriceCodes {
    private String name; // 需要获取的字段

    public String getName() { return name; }
    public void setName(String name) { this.name = name; }
}

登录后复制

这段代码功能完整，但 for 循环部分显得有些传统。Java 8 引入的 Stream API 提供了一种更声明式、更简洁的方式来处理集合数据。

使用Java 8 Stream API重构

我们将分两步来重构上述方法：首先处理 ItemPriceCode 的更新逻辑，然后处理列表的过滤逻辑。

立即学习“Java免费学习笔记（深入）”；

1. 更新 ItemPriceCode 的制造商价格名称

原代码中使用 for 循环遍历 itemPriceCodes，并在循环内部执行数据库查询和条件更新。在Stream API中，对集合元素的原地修改通常通过 forEach 终端操作来实现。map 操作主要用于将流中的元素转换为另一种类型或创建一个新的元素，而不是修改现有元素。

在这里，我们希望修改 itemPriceCodes 列表中已存在的 ItemPriceCode 对象，因此 forEach 是更合适的选择。

DeepSeek

幻方量化公司旗下的开源大模型平台

10435

查看详情

// 获取ItemPriceCode列表
List<ItemPriceCode> itemPriceCodes = item.getItemPriceCodes();

itemPriceCodes.stream()
    .forEach(ipc -> {
        // 对于每个ItemPriceCode，执行数据库查询
        Optional<ManufacturerPriceCodes> mpc = manufacturerPriceCodesRepository.findByManufacturerIDAndPriceCodeAndRecordDeleted(
                item.getManufacturerID(), ipc.getPriceCode(), NOT_DELETED);

        // 如果查询结果存在，则更新ItemPriceCode的字段
        mpc.ifPresent(m -> ipc.setManufacturerPriceCode(m.getName()));
    });

登录后复制

解释：

itemPriceCodes.stream(): 将列表转换为一个流。
.forEach(ipc -> { ... }): 这是一个终端操作，它会对流中的每个元素执行提供的 Consumer 函数。在这里，我们利用它来执行带有副作用（修改 ipc 对象）的操作。
mpc.ifPresent(m -> ipc.setManufacturerPriceCode(m.getName())): 这是处理 Optional 的推荐方式。它避免了显式的 if (mpc.isPresent()) { mpc.get()... } 结构，使代码更简洁、更安全，防止 NoSuchElementException。

2. 过滤已删除的 ItemPriceCode

原代码中已经使用了 List.removeIf() 方法，这本身就是Java 8引入的函数式风格方法，非常适合原地移除满足特定条件的元素。因此，这部分代码无需修改，它已经符合Java 8的风格。

itemPriceCodes.removeIf(ipc -> DELETED.equals(ipc.getRecordDeleted()));

登录后复制

如果需要创建一个新的列表而不是原地修改，可以使用 filter 和 collect：

// 如果需要返回一个新的列表，而不是修改原列表
List<ItemPriceCode> filteredItemPriceCodes = itemPriceCodes.stream()
    .filter(ipc -> !DELETED.equals(ipc.getRecordDeleted()))
    .collect(Collectors.toList());
// 然后可能需要 item.setItemPriceCodes(filteredItemPriceCodes);

登录后复制

但在本例中，原始方法是修改 item 内部的列表，所以 removeIf 是更直接和高效的选择。

完整的重构方法

将上述两部分结合起来，重构后的 getItemManufacturerPriceCodes 方法如下：

import java.util.List;
import java.util.Optional;
import java.util.stream.Collectors; // 如果使用collect

import static com.example.Constants.NOT_DELETED;
import static com.example.Constants.DELETED;

public class ItemService {

    private ManufacturerPriceCodesRepository manufacturerPriceCodesRepository;

    public ItemService(ManufacturerPriceCodesRepository manufacturerPriceCodesRepository) {
        this.manufacturerPriceCodesRepository = manufacturerPriceCodesRepository;
    }

    private Item getItemManufacturerPriceCodes(Item item) {
        List<ItemPriceCode> itemPriceCodes = item.getItemPriceCodes();

        // 步骤1: 更新ItemPriceCode的制造商价格名称
        itemPriceCodes.stream()
            .forEach(ipc -> {
                Optional<ManufacturerPriceCodes> mpc = manufacturerPriceCodesRepository.findByManufacturerIDAndPriceCodeAndRecordDeleted(
                        item.getManufacturerID(), ipc.getPriceCode(), NOT_DELETED);
                mpc.ifPresent(m -> ipc.setManufacturerPriceCode(m.getName()));
            });

        // 步骤2: 过滤已删除的ItemPriceCode
        itemPriceCodes.removeIf(ipc -> DELETED.equals(ipc.getRecordDeleted()));

        return item;
    }
}

登录后复制