最新消息:雨落星辰是一个专注网站SEO优化、网站SEO诊断、搜索引擎研究、网络营销推广、网站策划运营及站长类的自媒体原创博客

How to implement a repository in quarkus-reactive - Stack Overflow

programmeradmin0浏览0评论

I am trying to use quarkus-hibernate-reactive-panache for a reactive API that connects to an MSSQL. In Spring Boot, i am doing it like this:

import .springframework.data.r2dbc.repository.R2dbcRepository;
import reactor.core.publisher.Flux;

public interface CommentRepository extends R2dbcRepository<Comment, Long> {
    Flux<Comment> findByPostId(Long postId);
}

When i try to implement PanacheRepository like this:

import jakarta.enterprise.context.ApplicationScoped;
import io.smallrye.mutiny.Multi;
import io.quarkus.hibernate.reactive.panache.PanacheRepository;

@ApplicationScoped
public class CommentRepository implements PanacheRepository<Comment> {

    public Multi<Comment> findByPostId(Long postId) {
        return find("postId", postId).stream();
    }

}

The stream method cannot be resolved. I tried to implement ReactivePanacheRepository but it does not exist in quarkus-hibernate-reactive-panache.

What's the correct way to have a repository like this in quarkus-reactive?

发布评论

评论列表(0)

  1. 暂无评论