Kotysa for Spring R2DBC

Dependency

kotysa-spring-r2dbc is a single dependency you can add to your Spring project.
This is a companion version for spring-r2dbc 6.0.x (included in Spring boot 3.0.x) and does not replace it.

repositories {
    mavenCentral()
}

dependencies {
    implementation 'org.ufoss.kotysa:kotysa-spring-r2dbc:3.2.2'
    
    implementation 'org.springframework:spring-r2dbc'
}

Check this reactive sample project with reactor, and this coroutines sample project for a Spring Boot WebFlux application with a R2DBC backend accessed via kotysa-spring-r2dbc

Coroutines support

kotysa-spring-r2dbc provides a coroutines SQL client on top of spring-r2dbc, it can be obtained via an Extension function directly on spring-r2dbc's DatabaseClient.

It provides a SQL client API using suspend functions and Flow from kotlinx.coroutines.

class Repository(client: DatabaseClient, tables: H2Tables) {

	private val sqlClient = client.coSqlClient(tables)

	// enjoy coroutines sqlClient for spring-r2dbc :)
}

Reactive support

kotysa-spring-r2dbc provides a reactive SQL client on top of spring-r2dbc, it can be obtained via an Extension function directly on spring-r2dbc's DatabaseClient.

It provides a SQL client API using Mono and Flux from Reactor.

class Repository(client: DatabaseClient, tables: Tables) {

	private val sqlClient = client.sqlClient(tables)

	// enjoy reactive sqlClient for spring-r2dbc :)
}

Supported databases

• MySQL
• PostgreSQL
• MSSQL
• MariaDB
• H2
• Oracle

Coroutines transaction

kotysa-spring-r2dbc provides transaction support to use with coroutines SqlClient on top of spring-tx, it can be obtained via an Extension function directly on spring-tx's TransactionalOperator.

class Service(template: TransactionalOperator) {

	private val operator = template.coTransactionalOp()

	// use transaction with coroutines SqlClient
}

Reactive transaction

kotysa-spring-r2dbc provides transaction support to use with reactive SqlClient on top of spring-tx, it can be obtained via an Extension function directly on spring-tx's TransactionalOperator.

class Service(template: TransactionalOperator) {

	private val operator = template.transactionalOp()

	// use transaction with reactive SqlClient
}