1

我正在尝试使用响应式编程（RxGroovy）使用构建器模式创建对象，其中属性值来自数据库查询。我首先在寻找如何去做，其次是思考这是否是一个好主意。

我试图创建的对象属于这种类型：

class Foo {
    final String name;
    final Long[] relatedIds;

    Foo(String name, Long[] relatedIds) {
        this.name = name;
        this.relatedIds = relatedIds;
    }
}

和建设者：

class FooBuilder {
    String name;
    LinkedList<Long> relatedIds;

    {
        relatedIds = new LinkedList<>();
    }

    FooBuilder name(String name) {
        this.name = name;
        return this;
    }

    FooBuilder relatedId(Long id) {
        this.relatedIds.add(id);
        return this;
    }

    Foo build() {
        return new Foo(this.name, this.relatedIds.toArray());
    }

}

我有两个查询，一个返回所有 Foo 对象的名称，然后是一个单独的查询，我为每个 Foo 对象运行一次以获取所有相关的 ID。

我已经有一个方法（调用它queryAsObservable）来进行查询并获得一个发出结果集每一行的 Observable。所以设置name看起来像这样：

Observable<FooBuilder> buidlersWithNameSet = queryAsObservable(queryAllFoos)
.map { return new FooBuilder().name(it.name); }

给定 a FooBuilder，我可以像这样设置relatedIds：

final FooBuilder builder;
queryAsObservable(queryRelatedIds, builder.name)
    .subscribe { builder.relatedId(it.id); }

我的问题是如何将两者联系在一起？如何创建 observable 来为FooBuilder第一个 observable 发出的每个设置相关 ID，如图所示？最后，我只需要获取所有FooBuilder对象，并设置好name和relatedIds属性。

关于 JOIN 的注意事项

我知道我可以通过 JOIN 在一个查询中获取相关的 ID 和名称。我的想法是，我可以使用大量并行运行的较小查询，并在结果可用时使用 Observable 流为每个结果完成工作，而不是等待所有结果进入然后依次构建对象。我对为什么这是一个好主意或坏主意持开放态度。

4

1 回答 1

2

要组合 Observable，请使用 flatMap()。不确定 Groovy 语法，但我会试一试。从你的开始builderWithNameSet：

Observable<FooBuilder> completeBuilder =
    buildersWithNameSet
        .flatMap { builder ->
            return queryAsObservable(queryRelatedIds, builder.name)
                .map { builder.relatedId(it.id); }
        }
于 2015-07-22T17:10:46.713 回答