r2dbc postgres 没有合格的 bean 存储库

如何解决r2dbc postgres 没有合格的 bean 存储库

我最近尝试将 r2dbc 与 postgres“0.8.8.RELEASE”（pg r2dbc maven 依赖）和 spring boot“2.5.2”一起使用

我在 application.yml 中声明了以下属性：

   spring:   jpa:
    properties:
      hibernate:
        dialect: org.hibernate.dialect.PostgreSQL82Dialect
    hibernate:
      ddl-auto: create
    show-sql: false
    database-platform: org.hibernate.dialect.PostgreSQLDialect   r2dbc:
    url: r2dbc:postgresql://localhost:5432/postgres
    username: postgres
    password: postgres
    pool:
      enabled: true
      initial-size: 00
      max-size: 500
      max-idle-time: 30m
      validation-query: SELECT 1   sql:
    init:
      schema-locations: classpath:/schema.sql
      mode: always

请听我的 Application.java：

@EnableJpaRepositories(basePackages = {"fr.mycompany.common"})
@EntityScan("fr.mycompany")
@SpringBootApplication(exclude = {DataSourceAutoConfiguration.class})
@EnableConfigurationProperties
public class Application {

我确切地说“fr.company.common”位于另一个拥有自己的实体和存储库的子项目中

我的 DatabaseConfig 类：

@Configuration
@EnableTransactionManagement
@EnableR2dbcRepositories(basePackages = "fr.mycompany.activite.ingester.database.repos")
@Slf4j
public class DatabaseConfig extends AbstractR2dbcConfiguration {

    @Value("${spring.r2dbc.host}")
    private String host;
    @Value("${spring.r2dbc.username}")
    private String username;
    @Value("${spring.r2dbc.password}")
    private String password;
    @Value("${spring.r2dbc.database}")
    private String database;

    @Override
    public ConnectionFactory connectionFactory() {
        log.info("Init rd2dbc with host: {}",host);
        log.info("Init rd2dbc with database: {}",database);
        log.info("Init rd2dbc with username: {}",username);
        log.info("Init rd2dbc with password: {}",password);
        return new PostgresqlConnectionFactory(PostgresqlConnectionConfiguration.builder()
                .username(username)
                .password(password)
                .host(host)
                .database(database)
                .build());
    }

    @Bean
    ReactiveTransactionManager transactionManager(ConnectionFactory connectionFactory) {
        return new R2dbcTransactionManager(connectionFactory);
    }

    @Bean
    public ConnectionFactoryInitializer initializer(ConnectionFactory connectionFactory) {
        ConnectionFactoryInitializer initializer = new ConnectionFactoryInitializer();
        initializer.setConnectionFactory(connectionFactory);
        CompositeDatabasePopulator populator = new CompositeDatabasePopulator();
        populator.addPopulators(new ResourceDatabasePopulator(new ClassPathResource("schema.sql")));
        populator.addPopulators(new ResourceDatabasePopulator(new ClassPathResource("data.sql")));
        initializer.setDatabasePopulator(populator);
        return initializer;
    }

我的仓库：

public interface OrdreDeTravailPivotV2SplittedRepository extends ReactiveCrudRepository<OrdreDeTravailPivotV2SplittedEntity,OrdreDeTravailPivotV2IdEntity> {

    @Query(value = "SELECT * FROM splitted.ordredetravail WHERE idot = :idOt ORDER BY datemajstatut DESC LIMIT 1",nativeQuery = true)
    Optional<OrdreDeTravailPivotV2SplittedEntity> findLastByItOt(String idOt);
}

我的实体：

@Entity
@Getter
@Setter
@IdClass(OrdreDeTravailIdEntity.class)
@Table(name = "ordredetravail",schema = "splitted")
@TypeDef(
        name = "jsonb",typeClass = JsonBinaryType.class
)
public class OrdreDeTravailSplittedEntity implements ISplittedEntity {
    @Id
    @Column(name = "idot")
    private String  idOt;
    @Id
    @Column(name = "datemajstatut")
    private Instant dateMajStatut;

最后是使用我的存储库的业务类：

@Slf4j
@Component
public class OrdreDeTravailConverter implements IModelConverter<OrdreDeTravailRawEntity,OrdreDeTravailSplittedEntity,OrdreDeTravailComputedEntity,OrdreDeTravailInputConversionModel> {

    private final OrdreDeTravailSplittedRepository ordreDeTravailSplittedRepository;
    private final OrdreDeTravailComputedRepository   ordreDeTravailComputedRepository;

    @Autowired
    public OrdreDeTravailConverter(OrdreDeTravailSplittedRepository ordreDeTravailSplittedRepository,OrdreDeTravailComputedRepository ordreDeTravailComputedRepository) {
        this.ordreDeTravailSplittedRepository = ordreDeTravailSplittedRepository;
        this.ordreDeTravailComputedRepository = ordreDeTravailComputedRepository;
    }

当我尝试启动应用程序时，出现以下错误：

Caused by: org.springframework.beans.factory.NoSuchBeanDefinitionException: No qualifying bean of type 'fr.mycompany.activite.demande.orion.ingester.database.repos.splitted.OrdreDeTravailPivotV2SplittedRepository' available: expected at least 1 bean which qualifies as autowire candidate. Dependency annotations: {}
at org.springframework.beans.factory.support.DefaultListableBeanFactory.raiseNoMatchingBeanFound(DefaultListableBeanFactory.java:1790)
at org.springframework.beans.factory.support.DefaultListableBeanFactory.doResolveDependency(DefaultListableBeanFactory.java:1346)
at org.springframework.beans.factory.support.DefaultListableBeanFactory.resolveDependency(DefaultListableBeanFactory.java:1300)
at org.springframework.beans.factory.support.ConstructorResolver.resolveAutowiredArgument(ConstructorResolver.java:887)
at org.springframework.beans.factory.support.ConstructorResolver.createArgumentArray(ConstructorResolver.java:791)
... 85 more

你有什么想法吗？

最好的问候 阿德里安