Получение вложенных объектов с использованием Spring Data R2DBC - PullRequest
Новая
       85

Получение вложенных объектов с использованием Spring Data R2DBC

1 голос
/ 21 января 2020

Я новичок в Project Reactor и R2DB C. Как правильно получать и объединять Flux<Child> с Mono<Parent>, используя Spring Data R2DB C реактивные репозитории?

Parent: 

@Table("parent")
public class Parent{

@Id
private Long id;
private String name;

@Transient
private Flux<Child> children;

ParentRepository: 

interface ParentRepository extends ReactiveCrudRepository<Parent, Long> {

@Query()
Mono<Parent> findOneByName(String name);

Child: 

@Table("child")
public class Child{

@Id
private Long id;

ChildRepository: 

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 );
        });      
}

1 Ответ

0 голосов
/ 21 января 2020

Предполагая существование withChildren(Flux<Child> children) метода типа , вы можете просто сделать: 

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));
...