Java8流过多层，并在最底层连接所有项目

Question

我目前有一个多层结构数据，如下所示：

行业类有一个私有字段集

公司类有一个私有字段集

Division类有一个私有字段集

组类有一个私有字段GroupName，该字段可以为空，并且可以用getter（getGroupName（））检索。

我试图将一个工业实例一直流到组层，并将所有组名称连接到一个字符串中，中间有“/”。

如果Industry的this实例不包含任何group Name，则返回字符串"null"。

基于我对Java8有限的了解，我正在考虑这样编码：

industry.stream()
     .flatmap(industry -> industry.getCompanies().stream())
     .filter(Objects::nonNull)
     .flatmap(company -> company.getDivisions().stream())
     .filter(Objects::nonNull)
     .flatmap(division -> division.getGroups().stream())
     .map(group -> group.getGroupName)
     .collect(Collectors.joining("/")));

这段代码似乎在某些方面存在缺陷。此外，我不确定在哪里添加这样一条语句：如果行业无法检索任何groupName，而不是将所有groupName连接成一个字符串，只需返回一个字符串“null”。

在我的情况下，使用Java8流的正确方法是什么？

谢谢




Answer 1

下面是一个空检查的示例：

String s = industries.stream()
.filter( i -> i.getCompanies() != null ).flatMap( i -> i.getCompanies().stream() )
    .filter( c -> c != null && c.getDivisions() != null ).flatMap( c -> c.getDivisions().stream() )
        .filter( d -> d != null && d.getGroups() != null ).flatMap( d -> d.getGroups().stream() )
            .filter( g -> g != null && g.getGroupName() != null ).map( g -> g.getGroupName() )                    
.collect( Collectors.joining("/") );   

您可以用Holger的示例替换Collectors.joining ("/")。

Answer 2

我理解你的问题，因为几乎任何东西都可以是空的。在这种情况下，您可以创建自己的函数来处理这个问题。我做了这样一个：

/**
 * Creates a stream function for the provided collection function which ignores all null values.
 * Will filter out null values passed into the collection function and null values from the resulting stream
 * @param collectionFn
 * @param <T>
 * @param <R>
 * @return
 */
public static <T, R> Function<T, Stream<R>> nullSafeMapper(Function<T, Collection<R>> collectionFn) {
    return (v) -> Optional.ofNullable(v)
            .map(collectionFn)
            .map(Collection::stream)
            .orElse(Stream.empty())
            .filter(Objects::nonNull);
}

基本上它是完全空安全的，过滤掉输入和输出中的任何空值。并且可以这样使用：

industries.stream()
    .flatMap(SO46101593.nullSafeMapper(Industry::getCompanies))
    .flatMap(SO46101593.nullSafeMapper(Company::getDivisions))
    .flatMap(SO46101593.nullSafeMapper(Division::getGroups))
    .map(group -> group.getGroupName())
    .filter(Objects::nonNull) // filter out null group names
    .collect(Collectors.joining("/"));

你也可以把这个逻辑直接推到你的表达式中，但是因为它必须重复3次，所以有点...冗长和重复

Answer 3

匿名用户

Collectors.joining（...）基于类StringJoiner。它提供了分隔符、前缀和后缀功能，但不幸的是不能提供空值。

要添加该功能，我们必须重新实现收集器。加入，谢天谢地，当使用StringJoiner时，这并不难。

更改流操作的最后一行

.collect(Collectors.joining("/"));

到

.filter(Objects::nonNull) // elide all null elements
.collect(()->new StringJoiner("/", "", "").setEmptyValue("null"), // use "null" when empty
         StringJoiner::add, StringJoiner::merge).toString();