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

admin管理员组

文章数量:1334697

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?

本文标签： How to implement a repository in quarkusreactiveStack Overflow