jOOQ和Kotlin合作得好吗？

Question

Kotlin协程和“挂起函数”使程序员在不停止线程的情况下很容易等待输入/输出的结果（在输入/输出完成之前，线程还有其他工作要做）。

jOOQ是一个Java的产品，用于以类型安全的方式编写和执行SQL，但它本身并不明确使用静态编程语言协程。

可以从静态编程语言协例程范围调用jOOQ以获得易于编写和线程高效甚至在IO期间的好处吗？

suspend fun myQuery() {
  return dsl.select()
  // .etc()
  .fetch()  // <- could this be a 'suspend' call?
}

Answer 1

JOOQ添加了R2dbc支持，ResultQuery是一个反应流发布器。

目前最简单的方法是使用Reactor-Kotlin扩展将Reactor-api转换为Kotlin协程api。

  Flux.from(
     ctx.select()
     ...//etc
     ...// do not call fetch
  ) 
  .asFlow()

更新：Jooq家伙取消了DslContext上Kotlin协程的PR，因此现在您必须如上所述使用kotlinx协程ractor。

切换到3.17或更高版本时，直接使用fetchAwait。添加了一系列xxxAwait

ctx.select()
     ...//etc
     .fetchAwait()

Answer 2

A：是的。

org.jooq.结果查询

ANDkotlinx-coroutines-jdk8提供了一系列扩展方法，用于在静态编程语言暂停函数和JDK 8期货之间进行适配。

因此，我们可以做到：

import kotlinx.coroutines.future.await
...
suspend fun myQuery() {
  return dsl.select()
  //.etc()
  .fetchAsync()
  .await()    // <- IS  a suspending call !!!
}

应该注意的是，在ResultQuery上有许多重载的fetchX（）方法，它们为同步调用提供了很多实用工具，但它们对于fetchAsync（）没有类似的重载。这就是Kotlin程序员可能希望熟悉Java未来机制的地方：任何类型的操作都可以在完成阶段使用然后应用{}方法异步完成

suspend fun myQuery() {
  return dsl.select()
  //.etc()
  .fetchAsync()
  .thenApply { it.map(mapping(::Film)) }  // <- done as part of the 'suspend'
  .await()
}

尽管在暂停后这样做是可以的：

suspend fun myQuery() {
  val records = dsl.select()
  //.etc()
  .fetchAsync()
  .await()

  return records.map(mapping(::Film))
}