java - 使用 Spring Data R2DBC 获取嵌套对象
问题描述
我是 Project Reactor 和 R2DBC 的新手。如何正确使用 Spring Data R2DBC 响应式存储库接收和Flux<Child>
合并?Mono<Parent>
家长:
@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);
孩子:
@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)
类型方法,您可以这样做:
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));
推荐阅读
- c++ - 如何制作一个深常量指针
- php - 使用 Joomla 定制需求(管理世界地图上显示的地点)
- python - 根据输入值对python字典进行排序?
- sql - 我想显示大于 20 的工作时间
- angular - 如何在运行角度应用程序时运行命令提示符命令?
- php - 如何在 PHP restapi 文件中设置 favicon 图标
- c# - 将字节数组数据读入对象的正确方法是什么
- sql - INTERVAL '1' DAY 是否总是等于 INTERVAL '24' HOURS?
- go - 使用 go 模块导入分叉包时出错
- crash - Javascript 无限递归函数在 Android 10 上崩溃 Chromium 50 ARM64 lib