Anybody using Spring R2bc with Kotlin. I am just wondering how to use DB transaction using coroutine...

# server

[nicholasnet]

Anybody using Spring R2bc with Kotlin. I am just wondering how to use DB transaction using coroutine.

[Robert Jaros]

i'm using such helper function:

suspend fun <T> tx(connectionFactory: ConnectionFactory, block: () -> Mono<T>): T {
    val tm = R2dbcTransactionManager(connectionFactory)
    val operator = TransactionalOperator.create(tm)
    return block().`as`<Mono<T>>(operator::transactional).awaitSingle()
}

[Robert Jaros]

as a block you can pass a chain of standard reactive calls joined with then or flatMap

[Sean Keane]

Depending on your DB server maybe this might help.
https://github.com/JetBrains/Exposed

[marstran]

Exposed doesn't support R2DBC yet: https://github.com/JetBrains/Exposed/issues/456