DB transaction using R2BC Kotlin coroutine

Question

I using R2bc in Spring Webflux project with Kotlin. It is working nicely. But I have this method

@Component
class UserRepository(private val client: DatabaseClient, private val operator: TransactionalOperator) {

    suspend fun updateUser(user: User, value: String): Int {

        client.execute("INSERT INTO log(user_id, activity) VALUES (:user_id, :activity)")
              .bind("activity", user.activity)
              .bind("user_id", user.id)
              .fetch()
              .awaitRowsUpdated()

        return client.execute("UPDATE users SET value = :value WHERE id = :id")
                     .bind("value", value)
                     .bind("id", user.id)
                     .fetch()
                     .awaitRowsUpdated()
}

This method is working but I would like to use DB transaction. Is it supported in Kotlin.

why are you using the database client and not spring-data repositories? — Toerktumlare
– Toerktumlare, Commented Feb 15, 2020 at 20:12
Because I need to manage several entities in one method. This one is much simplified version there are few that are more involved. But we do use R2BC repo in most simpler use cases. — nicholasnet
– nicholasnet, Commented Feb 15, 2020 at 21:10
Even if you call from suspended method. I don’t think so can you show me any examples. — nicholasnet
– nicholasnet, Commented Feb 15, 2020 at 22:15

nicholasnet · Accepted Answer · 2020-02-16 18:25:04Z

6

Ok I found the solution I am posting it here so that other can benefit from it. All I had to do was.

@Component
class UserRepository(private val client: DatabaseClient, private val operator: TransactionalOperator) {

    suspend fun updateUser(user: User, value: String) =

        operator.executeAndAwait {

            client.execute("INSERT INTO log(user_id, activity) VALUES (:user_id, :activity)")
                  .bind("activity", user.activity)
                  .bind("user_id", user.id)
                  .await()

            client.execute("UPDATE users SET value = :value WHERE id = :id")
                  .bind("value", value)
                  .bind("id", user.id)
                  .await()
        }

}

edited Feb 16, 2020 at 18:25

answered Feb 15, 2020 at 19:33

nicholasnet

2,3174 gold badges25 silver badges55 bronze badges

Sign up to request clarification or add additional context in comments.

1 Comment

nicholasnet Over a year ago

As per source code it is github.com/spring-projects/spring-framework/blob/…

Collectives™ on Stack Overflow

DB transaction using R2BC Kotlin coroutine

1 Answer 1

1 Comment

Your Answer

Hot Network Questions

Collectives™ on Stack Overflow

1 Answer 1

1 Comment

Your Answer

Sign up or log in

Post as a guest

Related