时间戳

首页 > 解决方案 > 如何在 Spring Data R2DBC 中将一对多/一对一映射到 POJO

java - 如何在 Spring Data R2DBC 中将一对多/一对一映射到 POJO

问题描述

我正在尝试在新的响应式 Data r2dbc 中复制我在 Spring Data JPA 中使用的一些功能。我知道 r2dbc 不是一个成熟的 ORM，但想了解在 r2dbc 中复制以下场景的最佳方法是什么：

public class Doctor extends BaseModel {

    //other fields and id

    @NotNull
    @Enumerated(EnumType.STRING)
    @ElementCollection(fetch = FetchType.LAZY, targetClass = Language.class)
    @CollectionTable(name = "doctor_language",
        joinColumns = @JoinColumn(name = "doctor_id"))
    @Column(name = "language")
    private List<Language> languages = new ArrayList<>();


    @OneToMany(fetch = FetchType.LAZY, targetEntity = DoctorHealthProvider.class, mappedBy = 
        "doctor")
    private List<DoctorHealthProvider> providers = new ArrayList<>();

    // other fields
}

如果我使用 Spring Data JPA ，对 DoctorRepository（扩展 JpaRepository）的简单 findById 调用将为我doctor提供包含表中语言doctor_language列表和表中健康提供者列表的对象health_provider

我正在阅读有关预测的内容，但似乎无法找出在 Reactive Spring 中实现上述内容的最佳方法。任何帮助/指南/方向表示赞赏。

谢谢

标签： javaspringspring-webfluxspring-data-r2dbcr2dbc

解决方案

你可以看看https://github.com/lecousin/lc-spring-data-r2dbc但看起来还没有完全准备好使用。但是，如果您的需求不是太复杂，它可能会完成这项工作。

例如，您可以声明这样的链接：

@Table
public class TableWithForeignKey {
  ...
  @ForeignKey(optional = false)
  private LinkedTable myLink;
  ...
}

@Table
public class LinkedTable {
  ...
  @ForeignTable(joinkey = "myLink")
  private List<TableWithForeignKey> links;
  ...
}

当您希望链接被映射时，您可以使用延迟加载或连接选择。

如果使用findBy...Spring 存储库的方法（findById、findAll...），则只会加载存储库的表。在这种情况下，您可以使用延迟加载。为此，您需要声明一个具有默认主体的方法，并且您的方法将自动实现：

  public Flux<TableWithForeignKey> lazyGetLinks() {
    return null; // will be implemented
  }

另一种方法是直接在请求中进行连接。当前不支持在存储库中自动执行连接（如 JPA 中的 @EntitiGraph），但您可以像这样实现您的方法：

public interface MyRepository extends LcR2dbcRepository<LinkedTable, Long> {
  
  default Flux<LinkedTable> findAllAndJoin() {
    SelectQuery.from(LinkedTable.class, "root") // SELECT FROM LinkedTable AS root
      .join("root", "links", "link")            // JOIN root.links AS link
      .execute(getLcClient());                  // execute the select and map entities
  }

}

结果将是所有 LinkedTable 实例，以及从数据库一起加载的链接列表。

推荐阅读