Java分析Lambda表達式Stream流合并分組內(nèi)對象數(shù)據(jù)合并
前言
之前寫過《Lambda使用——JDK8新特性》,現(xiàn)在有一個分組合并的需求正好拿來小試牛刀。
需求
數(shù)據(jù)出自許多接口數(shù)據(jù),需要將幾個接口數(shù)據(jù)根據(jù)省份id進行分組合并。舉例說明:
A接口返回List里面有值的的字段為:provinceId、field1、field2、field3
B接口返回List里面有值的的字段為:provinceId、field4、field5、field6
C接口返回List里面有值的的字段為:provinceId、field7、field8、field9
最終實現(xiàn)的效果是返回一個最終的list,里面的每一個實體值是上面所有字段合并后的值(provinceId、field1、field2、field3、field4、field5、field6、field7、field8、field9)
代碼實現(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>
設計實體類
實體類包含了所有的字段
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進行分組,將同一個省的不同字段合并成一條數(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 的屬性拷貝,最后一個參數(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)
以每個省id作為進行數(shù)據(jù)分組,一個省只有一行數(shù)據(jù),將其他有值的字段合并到這一行數(shù)據(jù)上
到此這篇關(guān)于Java分析Lambda表達式Stream流合并分組內(nèi)對象數(shù)據(jù)合并的文章就介紹到這了,更多相關(guān)Lambda Stream流合并內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!
相關(guān)文章
修改SpringBoot 中MyBatis的mapper.xml文件位置的過程詳解
由于MyBatis默認的mapper.xml的掃描位置是resource文件下,但是不可能整個項目的mapper.xml文件都放在resource下,如果文件較少還行,但是如果文件比較多,太麻煩了,所以本文給大家介紹了修改SpringBoot 中MyBatis的mapper.xml文件位置的過程,需要的朋友可以參考下2024-08-08
MyBatis 中動態(tài) SQL 的作用及執(zhí)行原理解析
MyBatis動態(tài)SQL通過一組XML標簽實現(xiàn)多條件查詢、批量操作和按需更新等復雜場景,提升可讀性和可維護性,并配合#{}防止SQL注入,下面通過本文給大家介紹MyBatis 中動態(tài) SQL 的作用及執(zhí)行原理解析,感興趣的朋友跟隨小編一起看看吧2026-02-02
SpringBoot中熱點KEY緩存優(yōu)化的2種主流策略
所謂熱點KEY,是指在緩存或數(shù)據(jù)庫中被頻繁訪問的少量鍵值,這些鍵往往承載了系統(tǒng)中大部分的訪問流量,本文將分享SpringBoot中三種主流的熱點KEY緩存優(yōu)化策略,大家可以根據(jù)需求進行選擇2025-04-04
詳解Java并發(fā)編程之內(nèi)置鎖(synchronized)
這篇文章主要介紹了Java并發(fā)編程之內(nèi)置鎖(synchronized)的相關(guān)知識,本文給大家介紹的非常詳細,對大家的學習或工作具有一定的參考借鑒價值,需要的朋友可以參考下2021-03-03

