快捷導(dǎo)航

Java中stream流處理實(shí)現(xiàn)數(shù)據(jù)分組合并

更新時(shí)間：2026年03月10日 09:56:15 作者：不良手殘

本文主要介紹了Java中stream流處理實(shí)現(xiàn)數(shù)據(jù)分組合并,文中通過示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧

期望效果

將下面的數(shù)據(jù)，根據(jù)project_number分組，合并生成一個(gè)新的數(shù)據(jù)結(jié)構(gòu)

[
	{
		"bop_id": "1877304831014735872",
		"bop_name": "產(chǎn)品名稱-wsas-1-衍生數(shù)據(jù)",
		"bop_number": "cil0000001177",
		"bop_rdmExtensionType": "ProjectProductBOP",
		"bop_rdmExtensionTypeCN": "產(chǎn)品名稱",
		"project_id": "1872524834802634752",
		"project_name": "wsas-8005",
		"project_number": "P000000244",
		"project_rdmExtensionType": "Project",
		"project_rdmExtensionTypeCN": null
	},
	{
		"bop_id": "1878637661451849728",
		"bop_name": "產(chǎn)品名稱-wsas-1",
		"bop_number": "cil0000001180",
		"bop_rdmExtensionType": "ProjectProductBOP",
		"bop_rdmExtensionTypeCN": "產(chǎn)品名稱",
		"project_id": "1872524834802634752",
		"project_name": "wsas-8005",
		"project_number": "P000000244",
		"project_rdmExtensionType": "Project",
		"project_rdmExtensionTypeCN": null
	}
]

期望新的數(shù)據(jù)結(jié)構(gòu)如下：

[
	{
		"project_id": "1872524834802634752",
		"project_name": "wsas-8005",
		"project_number": "P000000244",
		"project_rdmExtensionType": "Project",
		"project_rdmExtensionTypeCN": null,
		"bop": [
			{
				"bop_id": "1877304831014735872",
				"bop_name": "產(chǎn)品名稱-wsas-1-衍生數(shù)據(jù)",
				"bop_number": "cil0000001177",
				"bop_rdmExtensionType": "ProjectProductBOP",
				"bop_rdmExtensionTypeCN": "產(chǎn)品名稱"
			},
			{
				"bop_id": "1878637661451849728",
				"bop_name": "產(chǎn)品名稱-wsas-1",
				"bop_number": "cil0000001180",
				"bop_rdmExtensionType": "ProjectProductBOP",
				"bop_rdmExtensionTypeCN": "產(chǎn)品名稱"
			}
		]
	}
]

實(shí)現(xiàn)思路

將 List<BOPDataCheckVO> 按照 project_number 分組，并生成一個(gè)新的 List<UseDataCheckVO>。具體步驟如下：

檢查輸入列表是否為空：如果 bopDataCheckVOList 為空，直接返回空列表。
按項(xiàng)目編號(hào)分組：使用流式處理將BOPDataCheckVO 列表按 project_number 分組。
創(chuàng)建新的 UseDataCheckVO對(duì)象：對(duì)于每個(gè)分組，取第一個(gè) BOPDataCheckVO 的信息填充到新的 UseDataCheckVO 對(duì)象中，并將整個(gè)分組的BOPDataCheckVO 列表賦值給 UseDataCheckVO 的 bopDataCheckVOs 屬性。
收集結(jié)果：將所有生成的 UseDataCheckVO 對(duì)象收集到一個(gè)列表并返回。

源碼

List<BOPDataCheckVO> ：

@Getter
@Setter
public class BOPDataCheckVO {

    public  String bop_id;
    public  String bop_name;
    public  String bop_number;
    public  String bop_rdmExtensionType;
    public  String bop_rdmExtensionTypeCN;
    public  String bop_versionIteration;

    public  String project_id;
    public  String project_name;
    public  String project_number;
    public  String project_rdmExtensionType;
    public  String project_rdmExtensionTypeCN;

    public String iteration;
    public String version;


    /**
     * 計(jì)算屬性：得到完整的版本號(hào)：A.1
     * @return
     */
    public String getBop_versionIteration(){
        if (null == this.getVersion() || StrConstant.STRING_NULL.equals(this.getVersion()) || null == this.getIteration()) {
            return null;
        }
        return this.getVersion() + StrConstant.SYMBOL_DOT + this.getIteration();
    }

}

List<UseDataCheckVO>：

@Getter
@Setter
public class UseDataCheckVO {

    public  String project_id;
    public  String project_name;
    public  String project_number;
    public  String project_rdmExtensionType;
    public  String project_rdmExtensionTypeCN;

    public List<BOPDataCheckVO> bopDataCheckVOs;
}

核心處理方法：

/**
     * 將 List<BOPDataCheckVO> 以 project_number 分組合并，生成一個(gè)新的 List<UseDataCheckVO>
     * @param bopDataCheckVOList 輸入的 BOPDataCheckVO 列表
     * @return 處理后的 UseDataCheckVO 列表
     */
    public List<UseDataCheckVO> mergeBOPDataCheckVOByProjectNumber(List<BOPDataCheckVO> bopDataCheckVOList) {
        if (org.apache.commons.collections4.CollectionUtils.isEmpty(bopDataCheckVOList)) {
            return Collections.emptyList();
        }
        return bopDataCheckVOList.stream()
                .collect(Collectors.groupingBy(BOPDataCheckVO::getProject_number))
                .entrySet().stream()
                .map(entry -> {
                    BOPDataCheckVO firstEntry = entry.getValue().get(0);
                    UseDataCheckVO useDataCheckVO = new UseDataCheckVO();
                    useDataCheckVO.setProject_id(firstEntry.getProject_id());
                    useDataCheckVO.setProject_name(firstEntry.getProject_name());
                    useDataCheckVO.setProject_number(firstEntry.getProject_number());
                    useDataCheckVO.setProject_rdmExtensionType(firstEntry.getProject_rdmExtensionType());
                    useDataCheckVO.setProject_rdmExtensionTypeCN(firstEntry.getProject_rdmExtensionTypeCN());
                    useDataCheckVO.setBopDataCheckVOs(entry.getValue());
                    return useDataCheckVO;
                })
                .collect(Collectors.toList());
    }

到此這篇關(guān)于Java中stream流處理實(shí)現(xiàn)數(shù)據(jù)分組合并的文章就介紹到這了,更多相關(guān)Java stream分組合并內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: