Java WebFlux r2dbc, возможно, не был инициализирован интерфейс репозитория ⇐ JAVA

[Anonymous]

Я создаю приложение Java SpringBoot с помощью WebFlux.
Итак, в этом приложении мне нужно создать несколько API-интерфейсов для получения данных из базы данных TSQL с помощью r2dbc.
Итак, я создаю этот код, это мой репозиторий интерфейса:

Код: Выделить всё

import it.silver.data.pojo.Percorsi;
import org.springframework.data.jpa.repository.Query;
import org.springframework.data.repository.reactive.ReactiveCrudRepository;
import reactor.core.publisher.Flux;

public interface PercorsiRepository extends ReactiveCrudRepository
 {

@Query("SELECT * FROM PRC_Percorsi")
Flux  getRepository();
}

Это мой класс Percorsi, отображающий таблицу:

Код: Выделить всё

import lombok.*;
import org.apache.james.mime4j.dom.datetime.DateTime;
import org.springframework.data.annotation.Id;

@Data
@ToString
@Builder
@AllArgsConstructor
@Table(schema = "PRC_Percorsi")
public class Percorsi {
@Id
@Column(name = "ID")
private Integer id;

@Column(name = "Nome")
private String nome;

@Column(name = "Descrizione")
private String descrizione;

@Column(name = "IDPaese")
private Integer idPaese;
@Column(name = "IDRegione")
private Integer idRegione;
@Column(name = "IDProvincia")
private Integer idProvincia;
@Column(name = "IDComune")
private Integer idComune;
@Column(name = "Distanza")
private Double distanza;
@Column(name = "IDLivelloDifficolta")
private Integer idLivelloDifficolta;
@Column(name = "AltitudineMax")
private Double altitudineMax;
@Column(name = "AltitudineMin")
private Double altitudineMin;
@Column(name = "IDTipoPercorso")
private Integer idTipoPercorso;
@Column(name = "TempoMovimento")
private Integer tempoMovimento;
@Column(name = "TempoTotale")
private Integer tempoTotale;
@Column(name = "Dislivello")
private Integer dislivello;
@Column(name = "NVisualizzazioni")
private Integer nVisualizzazioni;
@Column(name = "NVisitatori")
private Integer nVisitatori;
@Column(name = "MapName")
private String mapName;
@Column(name = "MapPath")
private String mapPath;
@Column(name = "CreationUserId")
private Integer creationUserId;
@Column(name = "CreationDate")
private DateTime creationDate;
@Column(name = "LastChangeUserId")
private Integer lastChangeUserId;
@Column(name = "LastChangeDate")
private DateTime lastChangeDate;
@Column(name = "FileStateID")
private Integer fileStateId;

}

Это мой класс Handler, который предоставляет методы для внешнего вызова:

Код: Выделить всё

import lombok.extern.slf4j.Slf4j;
import org.keycloak.admin.client.resource.RealmResource;
import org.keycloak.admin.client.resource.UsersResource;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.lang.NonNull;
import org.springframework.stereotype.Component;
import org.springframework.util.RouteMatcher;
import org.springframework.web.reactive.function.BodyInserters;
import org.springframework.web.reactive.function.server.ServerRequest;
import org.springframework.web.reactive.function.server.ServerResponse;
import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;

import java.util.ArrayList;
import java.util.List;

import static org.springframework.http.MediaType.APPLICATION_JSON;
import static org.springframework.web.reactive.function.BodyInserters.fromObject;

@Slf4j
@Component
public class SilverMountainHandler extends AbstractTenantAwareHandler {

@Autowired
private KeycloakClientProvider clientProvider;

@Autowired
private KeycloakProperties keycloakProperties;

@Autowired
private ServiceProperties serviceProperties;

@Autowired
private ObjectMapper objectMapper;

private final PercorsiRepository percorsiRepository;

protected SilverMountainHandler(final ServiceProvider serviceProvider) {
super(serviceProvider);
}

private SilverMountainService silverMountainService(final UserInfo userInfo) {
return super.getService(userInfo, SilverMountainService.class);
}

public Mono routes(final ServerRequest request) {
Flux
 people = this.percorsiRepository.findAll();
return people.collectList().flatMap(p->
p.size() <  1 ?
ServerResponse.status(404).build()
:ServerResponse.ok().contentType(APPLICATION_JSON).body(fromObject(p))
);
}
// endregion
}

Теперь у меня возникла такая проблема:

как это исправить?

Подробнее здесь: https://stackoverflow.com/questions/790 ... -interface