【发布时间】:2023-01-05 20:50:32
【问题描述】:
我正在将我的存储库移至 reactive 存储库。
我正在使用网络通量:
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-webflux</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-jpa</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-r2dbc</artifactId>
</dependency>
这是我的课:
@RequiredArgsConstructor
public class QdCFCriteriaRepository {
@PersistenceContext
private final EntityManager entityManager;
private final SessionFactory sessionFactory;
@Override
public List<QdCF> findByDataBaixaNull() {
CriteriaBuilder criteriaBuilder = this.entityManager.getCriteriaBuilder();
CriteriaQuery<QdCF> criteriaQuery = criteriaBuilder.createQuery(QdCF.class);
Root<QdCF> qdcf = criteriaQuery.from(QdCF.class);
Predicate dataBaixaPredicate = criteriaBuilder.isNull(qdcf.get("dataBaixa"));
criteriaQuery = criteriaQuery.where(dataBaixaPredicate);
TypedQuery<QdCF> query = this.entityManager.createQuery(criteriaQuery);
return query.getResultList();
}
}
我不太清楚如何将此标准代码移动到反应性标准代码。
我的意思是,我怎样才能得到Mono of List<QdCF>?
【问题讨论】:
标签: spring-data spring-webflux spring-data-r2dbc