反应式SQL客户端（Quarkus/Vert.X）中的Kotlin协程事务

Question

我想在我的反应式sql客户端事务中使用Kotlin协程。为了简单起见，我打算使用提供的助手函数＜code＞io.vertx.mutiny.sqlclient。此处文档中提到的池#withTransaction。由于传递的函数不是协程挂起函数，因此当我试图编译以下代码时，我得到了一个类似＜code＞的错误：挂起函数只能在协程体中调用

val client : PgPool
... 

suspend fun someServiceFunction () {
    client.withTransaction { connection ->
        repository.save(connection, entity).awaitSuspending()   //This is not working
        ...
    }
}

withTransaction的函数头如下所示

@CheckReturnValue
public <T> Uni<T> withTransaction(Function<SqlConnection, Uni<T>> function)

我问自己，是否还有一种方法可以在kotlin协程中使用它，因为我对它们非常陌生。

谢谢你的帮助！

Answer 1

我不熟悉Mutiny和Quarkus，但似乎有一种方法可以从＜code＞延迟转换

因此，您可以创建自己的 withTransaction 挂起版本，如下所示：

import io.vertx.mutiny.sqlclient.SqlConnection
import io.vertx.mutiny.sqlclient.Pool

@OptIn(ExperimentalCoroutinesApi::class)
suspend fun <T> Pool.withTransaction(block: suspend (SqlConnection) -> T): T = coroutineScope {
    client.withTransaction { connection ->
        async { block(connection) }.asUni()
    }.awaitSuspending()
}

然后使用它：

suspend fun someServiceFunction() {
    client.withTransaction { connection ->
        repository.save(connection, entity).awaitSuspending()
        // potentially other suspending stuff here, without the need to combine()
    }
}

但这就引出了一个问题，如果最终你想使用Kotlin协程，为什么要使用Vertx的Mutiny变体呢？我认为默认情况下，Vertex与Java futures一起工作，后者也与协程集成。