无法在 Spring 使用 WebFlux 启动时使用 H2 和 R2DBC 创建 ConnectionFactory 错误

Question

我使用 WebFlux 反应模块、H2 内存数据库和 R2DBC 反应驱动程序创建了 Java Spring 引导服务。

当我运行服务时，它失败并显示 “无法创建 ConnectionFactory”错误:

Unable to create a ConnectionFactory for 'ConnectionFactoryOptions{options={driver=h2, protocol=mem, database=contentitem, options=DB_CLOSE_DELAY=-1;DB_CLOSE_ON_EXIT=FALSE}}'. Available drivers: [ pool ]

这是一个嵌套异常，似乎从存储库开始，然后通过服务传播回控制器。

仔细阅读了生成的堆栈跟踪，没有发现任何关于问题可能的迹象，我能找到的唯一线索是我的 CustomConnectionFactoryInitializer [=74] 中的 'connectionFactory' 输入参数=]（请参见下文）用红色波浪线突出显示（“无法自动装配。有多个 'ConnectionFactory' 类型的 bean”）...除了没有。至少只有一个明确定义的 bean——我的 CustomConnectionFactoryInitializer class.

中的那个

知道这里发生了什么吗？

详情

这是一个 Gradle 项目，我的 build.gradle 文件是：

plugins {
    id 'org.springframework.boot' version '2.3.9.RELEASE'
    id 'io.spring.dependency-management' version '1.0.11.RELEASE'
    id 'java'
}

group = 'com.mycorp.service'
version = '0.0.1-SNAPSHOT'
sourceCompatibility = '11'

configurations {
    compileOnly {
        extendsFrom annotationProcessor
    }
}

repositories {
    mavenCentral()
}

dependencies {
    implementation 'org.springframework.boot:spring-boot-starter-data-r2dbc'
    implementation 'org.springframework.boot:spring-boot-starter-webflux'
    compileOnly 'org.projectlombok:lombok'
    runtimeOnly 'com.h2database:h2'
    runtimeOnly 'io.r2dbc:r2dbc-h2'
    runtimeOnly 'io.r2dbc:r2dbc-postgresql'
    runtimeOnly 'org.postgresql:postgresql'
    annotationProcessor 'org.projectlombok:lombok'
    testImplementation('org.springframework.boot:spring-boot-starter-test') {
        exclude group: 'org.junit.vintage', module: 'junit-vintage-engine'
    }
    testImplementation 'io.projectreactor:reactor-test'
    compile 'io.springfox:springfox-swagger2:3.0.0'
    compile 'io.springfox:springfox-swagger-ui:3.0.0'
    compile 'io.springfox:springfox-spring-webflux:3.0.0'
}

test {
    useJUnitPlatform()
}

我在 main/resources 下添加了一个 schema.sql 文件，其中包含以下内容：

CREATE TABLE contentitem ( contentItemId INT GENERATED BY DEFAULT AS IDENTITY PRIMARY KEY, localizedName VARCHAR(100) NOT NULL);

我在同一目录中使用 data.sql 文件填充 table：

INSERT INTO contentitem (contentItemId, localizedName) VALUES (0, 'Zero');
INSERT INTO contentitem (contentItemId, localizedName) VALUES (1, 'One');
INSERT INTO contentitem (contentItemId, localizedName) VALUES (2, 'Two');

我创建了一个 CustomConnectionFactoryInitializer 来创建和填充数据库：

@Configuration
public class CustomConnectionFactoryInitializer {
    @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")));
        initializer.setDatabasePopulator(populator);
        return initializer;
    }
}

我使用内存中的 H2 定义了一个 'test' 配置文件，并在我的 application.yml 文件中激活它：

spring:
  profiles:
    active: test
---
spring:
  profiles: dev
  r2dbc:
    url: r2dbc:postgresql://localhost:5432/test
    username: postgres
    password: postgres
logging:
  level:
    org.springframework.data.r2dbc: Debug
---
spring:
  profiles: test
  r2dbc:
    url: r2dbc:h2:mem:///contentitem?options=DB_CLOSE_DELAY=-1;DB_CLOSE_ON_EXIT=FALSE
    name: sa
    password:
---
spring:
  profiles: prod
  r2dbc:
    url: r2dbc:postgresql://localhost:5432/test
    username: postgres
    password: postgres
  logging:
    level:
      org.springframework.data.r2dbc: Debug

我的 ContentItem 模型是：

@Data
@AllArgsConstructor
@NoArgsConstructor
@Table("contentitem")
public class ContentItem {
    @Id
    @Column("contentItemId")
    private Integer contentItemId;
    @Column("localizedName")
    private String localizedName;
}

我的 ContentItemController 是：

@RestController
@RequestMapping("/contentItems")
public class ContentItemController {
    @Autowired
    private ContentItemService contentItemService;

    @GetMapping("/{contentItemId}")
    public Mono<ResponseEntity<ContentItem>> getContentItemByUserId(@PathVariable Integer contentItemId){
        Mono<ContentItem> contentItem = contentItemService.getContentItemById(contentItemId);
        return contentItem.map( u -> ResponseEntity.ok(u))
                .defaultIfEmpty(ResponseEntity.notFound().build());
    }

我的 ContentItemService 是：

@Service
@Slf4j
@Transactional
public class ContentItemService {

    @Autowired
    private ContentItemRepository contentItemRepository;

    public Mono<ContentItem> getContentItemById(Integer contentItemId){
        return contentItemRepository.findByContentItemId(contentItemId);
    }

}

我的 ContentItemRepository 是：

public interface ContentItemRepository extends ReactiveCrudRepository<ContentItem,Integer> {
    Mono<ContentItem> findByContentItemId(Integer contentItemId);
}

使这一切复杂化的是我在 application.properties 文件中使用 spring.h2.console.enabled=true 启用的 H2 控制台失败，当我使用 http://localhost:8081/h2-console.知道这里会发生什么吗？

Answer 1

好的，所以我逐个文件回顾我的项目文件，将每个文件与我用作指南的存储库副本进行比较。我发现了一些额外的数据库连接配置代码，我认为我已经摆脱了。我一删除它，问题就解决了。感谢所有看过并提出建议的人。

Answer 2

对我来说 pom.xml

中缺少 r2dbc-postgresql

<dependency>
    <groupId>io.r2dbc</groupId>
    <artifactId>r2dbc-postgresql</artifactId>
</dependency>

无法在 Spring 使用 WebFlux 启动时使用 H2 和 R2DBC 创建 ConnectionFactory 错误

Unable to create a ConnectionFactory Error with H2 and R2DBC in Spring Boot with WebFlux

java

spring-boot

h2

spring-webflux

r2dbc