Kotlin项目使用Spring Data JPA Stream加@Transactional仍报事务缺失错误

该报错核心是JPA Stream执行终端操作时，没有存活的事务上下文保持数据库连接打开，已加@Transactional仍失效的常见原因如下：

• 事务未实际生效：Spring的@Transactional基于AOP代理实现，代理不生效则事务不开启
• Stream惰性求值的消费时机错误：Stream的中间操作（比如map/filter）不会触发实际数据读取，只有终端操作（比如toList/forEach/count）才会访问数据库连接，如果终端操作的执行时机在事务提交/连接关闭之后，就会触发报错
• 事务配置不匹配：项目存在多事务管理器时未指定JPA对应的事务管理器，或者传播行为配置错误导致未复用已有事务

1. 验证事务是否真的生效：在retrieveSomeValues方法内加入断点或日志，打印TransactionSynchronizationManager.isActualTransactionActive()的返回值，返回true才代表事务正常开启
2. 排查自调用问题：如果retrieveSomeValues是被当前类的其他无事务方法直接调用，Spring AOP不会触发事务切面，事务不会生效
3. 检查Stream操作逻辑：确认Stream的所有终端操作都在@Transactional方法范围内，同时也在use块的闭合范围内，没有将未完成消费的Stream传递到方法外部
4. 检查方法修饰符：确认retrieveSomeValues是public方法，Spring事务注解仅对public方法生效
5. 检查Kotlin编译配置：确认项目引入了kotlin-spring插件，默认Kotlin类和方法都是final类型，没有该插件的话Spring无法生成代理类，事务会失效

1. 补全Stream终端操作 #

最常见的问题是仅做了map等中间操作，没有在事务/use范围内执行终端操作，修改代码如下：

@Transactional(readOnly = true)
fun retrieveSomeValues(): SomeDto {
    val someDto = myRepository.findSomeValues().use { stream ->
        stream
            .map { SomeObject(it.id, it.name) }
            .toList() // 补充终端操作，在连接关闭前完成所有数据读取
            .let { processedList ->
                // 基于已读入内存的processedList生成SomeDto即可
            }
    }
    return someDto
}

2. 修复自调用导致的事务失效 #

如果存在同类内部调用事务方法的场景，通过注入自身代理的方式调用，确保事务切面生效：

@Service
class Someservice(
    private val myRepository: MyRepository,
    @Autowired private val self: Someservice // 注入自身代理对象
) {
    // 外部调用的入口方法
    fun outerBusinessMethod() {
        val dto = self.retrieveSomeValues() // 通过代理调用事务方法
        // 其他业务逻辑
    }

    @Transactional(readOnly = true)
    fun retrieveSomeValues(): SomeDto {
        // 原有逻辑
    }
}

3. 补全Kotlin编译插件 #

在build.gradle.kts中确认添加了spring插件：

plugins {
    id("org.springframework.boot") version "2.3.4.RELEASE"
    id("io.spring.dependency-management") version "1.0.10.RELEASE"
    kotlin("jvm") version "1.3.72"
    kotlin("plugin.spring") version "1.3.72" // 必须引入该插件支持Spring代理生成
    kotlin("plugin.jpa") version "1.3.72" // 存在JPA实体时补充该插件
}

4. 多事务管理器场景指定对应管理器 #

如果项目配置了多个事务管理器，显式指定JPA对应的事务管理器：

@Transactional(value = "jpaTransactionManager", readOnly = true)
fun retrieveSomeValues(): SomeDto {
    // 原有逻辑
}

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