r2dbc postgres 没有符合条件的 bean 存储库

Question

我最近尝试将 r2dbc 与 postgres "0.8.8.RELEASE" (pg r2dbc mavendependecy) 和 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

你有什么想法吗？

最好的问候 阿德里安

Answer 1

可能是因为您包含了 RepositoryFactorySupport 的多个实现。您需要让 AnnotationRepositoryConfigurationSource#hasExplicitFilters 函数返回 true。在 spring boot 2.4.2 中，您必须使用 @EnableR2dbcRepositories 并且必须具有“includeFilters”或“excludeFilters” 我的解决方案（kotlin）：

//Custom annotations
//Used on the Repository interface
@Target(AnnotationTarget.CLASS)
@kotlin.annotation.Retention(AnnotationRetention.RUNTIME)
@MustBeDocumented
annotation class R2dbcRepository()
//Use above the configuration class
@EnableR2dbcRepositories(includeFilters = [ComponentScan.Filter(type = FilterType.ANNOTATION, classes = [R2dbcRepository::class])])