当前位置: 首页 > 知识库问答 >
问题:

无法使用 WebFlux 在 Spring 引导中使用 H2 和 R2DBC 创建连接工厂错误

华子昂
2023-03-14

我使用WebFlux反应式模块、H2内存数据库和R2DBC反应式驱动程序创建了一个JavaSpring Boot服务。

当我运行该服务时,它失败并显示“无法创建连接工厂”错误:

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 ]

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

在仔细阅读了生成的堆栈跟踪并没有发现任何问题的迹象后,我能找到的唯一线索是,我的CUomConntionFactory初始化器类中的“连接工厂”输入参数(请参见下文)正在用红色曲线突出显示(“无法自动装配。有不止一个‘连接工厂’类型的bean”)…除了没有。至少只有一个显式定义的bean——我的自定义连接工厂初始化器类中的那个。

知道这里发生了什么吗?

细节

这是一个Gradle项目,也是我的版本。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()
}

我已经添加了一个主/资源下的schema.sql文件,其中包含以下内容:

< code >创建表contentitem ( contentItemId INT默认生成为IDENTITY主键,localized name VARCHAR(100)NOT NULL);

我在同一目录中用 data.sql 文件填充表:

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

我创建了一个自定义连接工厂初始化器来创建和填充数据库:

@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定义了一个“测试”配置文件,并使其在我的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

我的内容项模型为:

@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);
}

使这一切变得复杂的是,H2控制台,我用spring.h2.console.enabled=true在application.properties文件中启用的,当我用http://localhost:8081/h2-console调用它时,它失败了,出现了404未找到错误。

共有2个答案

张绍晖
2023-03-14

对我来说,r2dbc-postgreql在pom.xml中丢失了

<dependency>
    <groupId>io.r2dbc</groupId>
    <artifactId>r2dbc-postgresql</artifactId>
</dependency>
海灵均
2023-03-14

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

 类似资料:
  • 我使用WebFlux反应式模块、内存中的H2数据库和R2DBC反应式驱动程序创建了一个JavaSpringBoot服务。这在端口8081上构建并运行良好。 我添加了一个模式。main/resources下的sql文件,其中包含以下内容: 我在同一目录中用 data.sql 文件填充表: 我的ContentItem模型是: 我的ContentItem计数器是: 我的ContentItemServic

  • 得到错误"表客户已经存在"当我试图创建一个表在H2内存数据库使用schema.sql.我使用的是Spring启动版本:2.5.4和以下是我的pom.xml.它的工作正常,如果我使用Spring启动版本:2.4.3 这是我的代码: 当我启动应用程序时,我收到以下错误。如何强制H2使用schema.sql创建表格? 原因:io。r2dbc。spi。R2dbcBadGrammarException:表“

  • 在本地,我的应用程序可以很好地连接到内置的netty连接工厂,并且在启动或发送主题消息方面没有问题。我的本地盒子是独立的JBoss 5.1和独立的大黄蜂Q。 但是,当部署到我们的DEV服务器(运行集群JBoss 5.1和集群HornetQ)时,我无法连接,得到以下堆栈跟踪: 我正在尝试使用默认的内置netty连接器,除了我自己的JMS主题之外,没有额外的配置。我相对不知道DEV服务器设置,因为它超

  • 我正在使用ApacheCommonsHttpClient 4.3。x和spring3。我正在尝试将connectionpool与其关联的socketconfig实例连接起来。 http://hc.apache.org/httpcomponents-client-ga/httpclient/apidocs/org/apache/http/impl/conn/PoolingHttpClientConn

  • 无法使用C3P0创建Hibernate-JPA连接池。面对以下错误日志: 请求请提供一个解决方案如何创建连接池使用JPA在KARAF。