Spring Data JPA Stream 和 Kotlin

Question

我正在尝试在我的 Kotlin 项目中使用 JPA Streams，但我不断收到You're trying to execute a streaming query method without a surrounding transaction that keeps the connection open so that the Stream can actually be consumed. Make sure the code consuming the stream uses @Transactional or any other way of declaring a (read-only) transaction.

我知道使用 Streams 的先决条件，并且我已经用 @Transactional 包围了我的代码并关闭了 Stream 但它不起作用。

这是我的代码：

@Repository
interface MyRepository : JpaRepository<SomeValue, Long> {
    @QueryHints(value = [
        QueryHint(name = HINT_FETCH_SIZE, value = "100"),
        QueryHint(name = HINT_CACHEABLE, value = "false"),
        QueryHint(name = READ_ONLY, value = "true")
    ])
    @Query(
        """select s.id, s.name
            from Some s
            """,
        nativeQuery = true
    )
    fun findSomeValues(
    ): Stream<SomeValue>
}


@Service
class Someservice(
    private val myRepository: MyRepository,
    ...
) {
    @Transactional(readOnly = true)
    fun retrieveSomeValues(
    ): SomeDto {
        
        val someDto =
            myRepository.findSomeValues().use {
                it.map { SomeObject(it.id, it.name) }
                ....
            }

        return someDto
    }
}

编辑：

相关依赖：

Spring Boot: 2.3.4.RELEASE
Kotlin: 1.3.72
Spring-boot-starter-data-jpa

Answer 1

您是否有可能最终没有关闭流？您应该尝试以下方法：

@Transactional
void someMethod() {

  try (Stream result = repository.streamAllBy()) {
    // … processing goes here
  }
}

流可能会包装底层数据存储特定的资源 因此，必须在使用后关闭。您可以手动 使用 close() 方法或使用 Java 7 关闭 Stream try-with-resources 块，如下例所示：