快捷導(dǎo)航

Java分析Lambda表達(dá)式Stream流合并分組內(nèi)對象數(shù)據(jù)合并

更新時(shí)間：2022年12月06日 10:40:17 作者：leo825...

Lambda表達(dá)式，基于Lambda所帶來的函數(shù)式編程，又引入了一個(gè)全新的Stream概念，用于解決集合類庫既有的弊端，Lambda 允許把函數(shù)作為一個(gè)方法的參數(shù)（函數(shù)作為參數(shù)傳遞進(jìn)方法中）。使用 Lambda 表達(dá)式可以使代碼變的更加簡潔緊湊

前言

之前寫過《Lambda使用——JDK8新特性》，現(xiàn)在有一個(gè)分組合并的需求正好拿來小試牛刀。

需求

數(shù)據(jù)出自許多接口數(shù)據(jù)，需要將幾個(gè)接口數(shù)據(jù)根據(jù)省份id進(jìn)行分組合并。舉例說明：

A接口返回List里面有值的的字段為：provinceId、field1、field2、field3

B接口返回List里面有值的的字段為：provinceId、field4、field5、field6

C接口返回List里面有值的的字段為：provinceId、field7、field8、field9

最終實(shí)現(xiàn)的效果是返回一個(gè)最終的list，里面的每一個(gè)實(shí)體值是上面所有字段合并后的值（provinceId、field1、field2、field3、field4、field5、field6、field7、field8、field9）

代碼實(shí)現(xiàn)

依賴引入

本文用的是junit測試類

        <dependency>
            <groupId>junit</groupId>
            <artifactId>junit</artifactId>
            <version>4.12</version>
            <scope>test</scope>
        </dependency>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <version>1.16.18</version>
        </dependency>
        <dependency>
            <groupId>cn.hutool</groupId>
            <artifactId>hutool-core</artifactId>
            <version>5.5.6</version>
        </dependency>
    </dependencies>

設(shè)計(jì)實(shí)體類

實(shí)體類包含了所有的字段

package com.leo;
import lombok.Data;
import java.io.Serializable;
@Data
public class TestObj implements Serializable {
    private static final long serialVersionUID = 1L;
    String provinceId;
    String field1;
    String field2;
    String field3;
    String field4;
    String field5;
    String field6;
    String field7;
    String field8;
    String field9;
}

測試代碼

    /**
     * 測試類
     */
    @Test
    public void streamConcat2() {
        TestObj t0 = new TestObj();
        t0.setProvinceId("000");
        t0.setField1("1");
        t0.setField2("2");
        t0.setField3("3");
        TestObj t1 = new TestObj();
        t1.setProvinceId("100");
        t1.setField1("1");
        t1.setField2("2");
        t1.setField3("3");
        TestObj t2 = new TestObj();
        t2.setProvinceId("100");
        t2.setField4("4");
        t2.setField5("5");
        t2.setField6("6");
        TestObj t3 = new TestObj();
        t3.setProvinceId("100");
        t3.setField7("7");
        t3.setField8("8");
        t3.setField9("9");
        TestObj t4 = new TestObj();
        t4.setProvinceId("102");
        t4.setField7("7");
        t4.setField8("8");
        t4.setField9("9");
        List<TestObj> list1 = new ArrayList<>();
        list1.add(t0);
        list1.add(t1);
        List<TestObj> list2 = new ArrayList<>();
        list2.add(t2);
        List<TestObj> list3 = new ArrayList<>();
        list3.add(t3);
        list3.add(t4);
        // 根據(jù)省份id進(jìn)行分組，將同一個(gè)省的不同字段合并成一條數(shù)據(jù)對象
        List<TestObj> list = Stream.concat(Stream.concat(list1.stream(), list2.stream()), list3.stream())
                .filter(e -> e != null)
                .collect(Collectors.toMap(TestObj::getProvinceId, a -> a, (o1, o2) -> {
                    try {
                        // Hutool 的屬性拷貝，最后一個(gè)參數(shù)是設(shè)置為null的字段不拷貝
                        BeanUtil.copyProperties(o1, o2, CopyOptions.create().setIgnoreNullValue(true).setIgnoreError(true));
                    } catch (Exception e) {
                        e.printStackTrace();
                    }
                    return o2;
                })).values().stream().collect(Collectors.toList());
        // 打印數(shù)據(jù)
        list.stream().forEach(System.out::println);
    }
}

測試結(jié)果：

TestObj(provinceId=000, field1=1, field2=2, field3=3, field4=null, field5=null, field6=null, field7=null, field8=null, field9=null)
TestObj(provinceId=100, field1=1, field2=2, field3=3, field4=4, field5=5, field6=6, field7=7, field8=8, field9=9)
TestObj(provinceId=102, field1=null, field2=null, field3=null, field4=null, field5=null, field6=null, field7=7, field8=8, field9=9)

以每個(gè)省id作為進(jìn)行數(shù)據(jù)分組，一個(gè)省只有一行數(shù)據(jù)，將其他有值的字段合并到這一行數(shù)據(jù)上

到此這篇關(guān)于Java分析Lambda表達(dá)式Stream流合并分組內(nèi)對象數(shù)據(jù)合并的文章就介紹到這了,更多相關(guān)Lambda Stream流合并內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: