我是 Project Reactor 和 R2DBC 的新手。如何接收和合并Flux<Child>
与 Mono<Parent>
正确使用 Spring Data R2DBC 响应式(Reactive)存储库?
家长:
@Table("parent")
public class Parent{
@Id
private Long id;
private String name;
@Transient
private Flux<Child> children;
父存储库:
interface ParentRepository extends ReactiveCrudRepository<Parent, Long> {
@Query()
Mono<Parent> findOneByName(String name);
child :
@Table("child")
public class Child{
@Id
private Long id;
子库:
interface ChildRepository extends ReactiveCrudRepository<Child, Long> {
@Query()
Flux<Child> findAllByParentId(Long parentId);
ParentPersistenceAdapter:
public Mono<Parent> findParent(String parentName) {
return parentRepository.findOneByName(parentName)
//how to invoke childRepository.findAllByParentId()
//and set this Flux to Parent's Mono
}
我的解决办法是:
public Mono<Parent> findParent(String parentName) {
return parentRepository.findOneByName(parentName)
.map(parent -> {
Flux<Child> children = childRepository.findAllByParentId(parent.getId())
children.subscribe();
return parent.setChildren(children );
});
}
最佳答案
假设存在 withChildren(Flux<Child> children)
type method ,你可以这样做:
parentRepository.findById(parentId)
.map(p -> p.withChildren(childRepository.findAllByParentId(parentId)));
然而,这有点奇怪——你通常不会有
Flux
在这样的 DAO 上,因为您需要订阅它并单独管理内容。你通常会有一个 List<Child>
反而。对于这种情况,您可以将子流收集为列表,zip()
对应的Mono
出版商在一起,然后将它们组合成您的最终 Parent
目的。所以假设一个
withChildren(List<Child> children)
方法:Mono.zip(parentRepository.findById(parentId),
childRepository.findAllByParentId(parentId).collectList(),
(t1,t2) -> t1.withChildren(t2));
关于java - 使用 Spring Data R2DBC 获取嵌套对象,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/59841705/