Spring Boot整合jOOQ+R2DBC时DSLContext注入为空问题

我正在使用Spring Boot、jOOQ和R2DBC，按照相关文档创建了DSLContext Bean，但在Repository中注入的DSLContext为空，抛出空指针异常。

配置类代码 #

@Configuration
open class JooqConfig(private val cfi: ConnectionFactory) {

    @Bean
    open fun jooqContext(): DSLContext {
        return DSL.using(cfi).dsl();
    }
}

application.yml配置 #

spring:
  r2dbc:
    url: r2dbc:h2:mem:///~/db/testdb
    username: sa
    password: password

Repository代码 #

@Repository
@Transactional
open class JooqUserRepository(private val dslContext: DSLContext) {
   suspend fun getUser(): Record {
      return dslContext.select() // dslContext 为空
           .from(USER_MODEL)
          .awaitFirst()
   }
}

抛出的异常 #

Cannot invoke "org.jooq.DSLContext.select(org.jooq.SelectFieldOrAsterisk[])" because "this.dslContext" is null
java.lang.NullPointerException: Cannot invoke "org.jooq.DSLContext.select(org.jooq.SelectFieldOrAsterisk[])" because "this.dslContext" is null

排查情况 #

已确认DSL.using(cfi).dsl()确实返回了有效对象，但Repository中注入的dslContext始终为空。

主类代码（更新） #

@SpringBootApplication
open class BrewServerApplication

fun main(args: Array<String>) {
    SpringApplication.run(BrewServerApplication::class.java, *args)
}

可能的原因与解决办法 #

• 组件扫描范围问题：确保JooqConfig和JooqUserRepository所在的包在BrewServerApplication主类的扫描范围内（主类所在包或其子包），否则Spring无法发现并注册这些Bean。

• Kotlin代理与open类的兼容问题：@Transactional会生成代理类，虽然Repository已标记为open，但私有构造函数参数可能导致代理注入失败。可以尝试：

  • 将dslContext的访问修饰符改为protected；
  • 在@SpringBootApplication上添加@EnableTransactionManagement(proxyTargetClass = true)强制使用CGLIB代理。

• Reactive事务配置：在响应式环境下，显式声明R2DBC事务管理器，并指定给@Transactional：

  @Configuration
  open class TransactionConfig {
      @Bean
      open fun r2dbcTransactionManager(connectionFactory: ConnectionFactory): R2dbcTransactionManager {
          return R2dbcTransactionManager(connectionFactory)
      }
  }
  

  然后修改Repository的注解：

  @Transactional(transactionManager = "r2dbcTransactionManager")
  

• 注入ReactiveDSLContext而非DSLContext：DSL.using(cfi)返回的实际是ReactiveDSLContext实例，直接注入该类型可能解决类型匹配问题：

  @Repository
  @Transactional
  open class JooqUserRepository(private val dslContext: ReactiveDSLContext) {
      suspend fun getUser(): Record {
          return dslContext.select()
              .from(USER_MODEL)
              .awaitFirst()
      }
  }
  

• 依赖检查：确保引入了正确的jOOQ R2DBC依赖，推荐使用Spring Boot starter：

  <dependency>
      <groupId>org.jooq</groupId>
      <artifactId>jooq-r2dbc-spring-boot-starter</artifactId>
      <version>对应jOOQ版本</version>
  </dependency>
  

内容的提问来源于stack exchange，提问作者Michael