r2dbc ReactiveCrudepository如何编写JPQL/HQL

Question

我是SpringWebFlux反应型新手。我使用R2DBC postgresql。我有这样一个存储库：

public interface BookRepository extends ReactiveCrudRepository<Book, Long> {
}

现在我想通过许多复杂的条件为查询添加自定义方法：

public interface CustomBookRepository extends BookRepository {
    Flux<Book> findByVeryComplicatedCondition(MyCriteriaDto criteria);
}

我的实施：

public class CustomBookRepositoryImpl extends CustomBookRepository {

    //How to get it?
    EntityManager em;

    @Override
    public Flux<Book> findByVeryComplicatedCondition(MyCriteriaDto criteria) {
        Query query = em.createQuery("SELECT b from Book b WHERE (VERY COMPLICATED CONDITIONS)");
        //What next?
    }
}

我的问题在上面的代码中：

1. 如何获得EntityManager？
2. 如何从我构建的HQL查询中获取Flux？

当我问这些问题时，我的意思是“如何用Spring反应式/r2dbc方式实现”，而不是“如何用JDBC实现这种常规方式”

Answer 1

Spring数据R2DBC没有像Hibernate这样成熟的ORM框架的支持。因此，不存在EntityManager这样的东西，也不可能编写JQL/HQL查询。

但是，仍然可以使用本机查询来定义更复杂的方法，例如。

interface MyRepository extends ReactiveCrudRepository<...> {

    @Query("SELECT b from Book b WHERE (VERY COMPLICATED CONDITIONS)")
    Flux<...> find(...);
}