5Micronaut Data R2DBC

6Repository

Micronaut R2DBC

Integration with Micronaut and R2DBC

Version: 6.0.0

1 Introduction

This module provides integration between Micronaut and R2DBC.

2 Release History

For this project, you can find a list of releases (with release notes) here:

https://github.com/micronaut-projects/micronaut-r2dbc/releases

3 Quick Start

The quickest way to get started is to create a new Micronaut application with Micronaut Launch and choose the data-r2dbc, mysql and flyway features. This can also be done via the Micronaut 2.2 and above CLI:

Creating an application with the CLI

# For Maven add: --build maven
$ mn create-app --lang java example --features data-r2dbc,flyway,mysql

Or via curl:

Creating an application with curl

# For Maven add to the URL: &build=maven
$ curl https://launch.micronaut.io/demo.zip?lang=java&features=data-r2dbc,flyway,mysql -o demo.zip && unzip demo.zip -d demo && cd demo

The generated application will use MySQL since we passed the mysql feature adding dependency on the R2DBC driver for MySQL:

GradleMaven

runtimeOnly("dev.miku:r2dbc-mysql")

Copy to Clipboard

And for flyway the JDBC driver:

GradleMaven

runtimeOnly("mysql:mysql-connector-java")

Copy to Clipboard

To create configurations for other drivers you can select the appropriate feature: oracle, postgres, sqlserver, h2 or mariadb.

Now define a SQL script that creates your initial schema in src/main/resources/db/migration. For example:

Example V1__create-schema.sql

CREATE TABLE book(id BIGINT NOT NULL AUTO_INCREMENT PRIMARY KEY, title VARCHAR(255), pages INT, author_id BIGINT NOT NULL);
CREATE TABLE author(id BIGINT NOT NULL AUTO_INCREMENT PRIMARY KEY, name VARCHAR(255));

You can now configure your application to connect to the database using src/main/resources/application.yml which contains the application configuration:

Example application.yml

flyway: (1)
  datasources:
    default:
      enabled: true
datasources:
  default: (2)
    url: jdbc:mysql://localhost:3306/mydatabase
r2dbc:
  datasources:
    default: (3)
      url: r2dbc:mysql:///mydatabase

1	The Flyway configuration ensures the schema migration is applied. See Micronaut Flyway for more information.
2	The Flyway configuration needs a JDBC datasource configured, this setting configures one. See Micronaut JDBC for more information.
3	The property `r2dbc.datasources.default.url` is used to configure the default R2DBC `ConnectionFactory`

The R2DBC ConnectionFactory object can be injected anywhere in your code with dependency injection.

Now define a @MappedEntity that maps to the author table defined in the schema:

JavaGroovyKotlin

package example;

import io.micronaut.data.annotation.*;
import io.micronaut.serde.annotation.Serdeable;

@Serdeable
@MappedEntity
public class Author {
    @GeneratedValue
    @Id
    private Long id;
    private final String name;

    public Author(String name) {
        this.name = name;
    }

    public String getName() {
        return name;
    }

    public Long getId() {
        return id;
    }

    public void setId(Long id) {
        this.id = id;
    }
}

Copy to Clipboard

package example

import io.micronaut.data.annotation.*
import io.micronaut.serde.annotation.Serdeable

@Serdeable
@MappedEntity
class Author {
    @GeneratedValue
    @Id
    Long id
    final String name

    Author(String name) {
        this.name = name
    }
}

Copy to Clipboard

package example

import io.micronaut.data.annotation.GeneratedValue
import io.micronaut.data.annotation.Id
import io.micronaut.data.annotation.MappedEntity
import io.micronaut.serde.annotation.Serdeable

@Serdeable
@MappedEntity
data class Author(val name: String) {
    @GeneratedValue
    @Id
    var id: Long? = null
}

Copy to Clipboard

And a repository interface to access the database that extends from ReactiveStreamsRepository:

JavaGroovyKotlin

package example;

import io.micronaut.core.annotation.NonNull;
import io.micronaut.data.model.query.builder.sql.Dialect;
import io.micronaut.data.r2dbc.annotation.R2dbcRepository;
import io.micronaut.data.repository.reactive.ReactiveStreamsCrudRepository;
import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;

import jakarta.validation.constraints.NotNull;

@R2dbcRepository(dialect = Dialect.MYSQL) // (1)
public interface AuthorRepository extends ReactiveStreamsCrudRepository<Author, Long> {
    @NonNull
    @Override
    Mono<Author> findById(@NonNull @NotNull Long aLong); // (2)

    @NonNull
    @Override
    Flux<Author> findAll();
}

Copy to Clipboard

package example

import io.micronaut.core.annotation.NonNull
import io.micronaut.data.model.query.builder.sql.Dialect
import io.micronaut.data.r2dbc.annotation.R2dbcRepository
import io.micronaut.data.repository.reactive.ReactiveStreamsCrudRepository
import reactor.core.publisher.Flux
import reactor.core.publisher.Mono

import jakarta.validation.constraints.NotNull

@R2dbcRepository(dialect = Dialect.MYSQL) // (1)
interface AuthorRepository extends ReactiveStreamsCrudRepository<Author, Long> {
    @NonNull
    @Override
    Mono<Author> findById(@NonNull @NotNull Long aLong) // (2)

    @NonNull
    @Override
    Flux<Author> findAll()
}

Copy to Clipboard

package example

import io.micronaut.data.model.query.builder.sql.Dialect
import io.micronaut.data.r2dbc.annotation.R2dbcRepository
import io.micronaut.data.repository.reactive.ReactiveStreamsCrudRepository
import reactor.core.publisher.Flux
import reactor.core.publisher.Mono
import jakarta.validation.constraints.NotNull

@R2dbcRepository(dialect = Dialect.MYSQL) // (1)
interface AuthorRepository : ReactiveStreamsCrudRepository<Author, Long> {
    override fun findById(id: @NotNull Long): Mono<Author> // (2)
    override fun findAll(): Flux<Author>
}

Copy to Clipboard

1	The @R2dbcRepository annotation can be used to specify the datasource and dialect
2	You can override methods from the super interface to specialize the default Publisher return type with a concrete implementation

You can now inject this interface into controllers and use it to perform R2DBC queries:

JavaGroovyKotlin

package example;

import io.micronaut.http.annotation.Controller;
import io.micronaut.http.annotation.Get;
import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;

@Controller("/authors")
public class AuthorController {
    private final AuthorRepository repository;

    public AuthorController(AuthorRepository repository) {
        this.repository = repository;
    }

    @Get
    Flux<Author> all() { // (1)
        return repository.findAll();
    }

    @Get("/id")
    Mono<Author> get(Long id) { // (2)
        return repository.findById(id);
    }
}

Copy to Clipboard

package example

import io.micronaut.http.annotation.Controller
import io.micronaut.http.annotation.Get
import reactor.core.publisher.Flux
import reactor.core.publisher.Mono

@Controller("/authors")
class AuthorController {
    private final AuthorRepository repository

    AuthorController(AuthorRepository repository) {
        this.repository = repository
    }

    @Get
    Flux<Author> all() { // (1)
        return repository.findAll()
    }

    @Get("/id")
    Mono<Author> get(Long id) { // (2)
        return repository.findById(id)
    }
}

Copy to Clipboard

package example

import io.micronaut.http.annotation.Controller
import io.micronaut.http.annotation.Get
import reactor.core.publisher.Flux
import reactor.core.publisher.Mono

@Controller("/authors")
class AuthorController(private val repository: AuthorRepository) {
    @Get
    fun all(): Flux<Author> { // (1)
        return repository.findAll()
    }

    @Get("/id")
    fun get(id: Long): Mono<Author> { // (2)
        return repository.findById(id)
    }
}

Copy to Clipboard

1	By returning a reactive type that emits many items you can stream data (either Flowable or `Flux`)
2	By returning a reactive type that emits a single item you return the entire response (either Single or `Mono`)

4 Available Drivers

The following drivers are available as of this writing.

H2

R2DBC Driver:

GradleMaven

runtimeOnly("io.r2dbc:r2dbc-h2")

Copy to Clipboard

And for Flyway migrations the JDBC driver:

GradleMaven

runtimeOnly("com.h2database:h2")

Copy to Clipboard

MySQL

R2DBC Driver:

GradleMaven

runtimeOnly("dev.miku:r2dbc-mysql")

Copy to Clipboard

And for Flyway migrations the JDBC driver:

GradleMaven

runtimeOnly("mysql:mysql-connector-java")

Copy to Clipboard

MariaDB

R2DBC Driver:

GradleMaven

runtimeOnly("org.mariadb:r2dbc-mariadb")

Copy to Clipboard

And for Flyway migrations the JDBC driver:

GradleMaven

runtimeOnly("org.mariadb.jdbc:mariadb-java-client")

Copy to Clipboard

Postgresql

R2DBC Driver:

GradleMaven

runtimeOnly("org.postgresql:r2dbc-postgresql")

Copy to Clipboard

And for Flyway migrations the JDBC driver:

GradleMaven

runtimeOnly("org.postgresql:postgresql")

Copy to Clipboard

SQL Server

R2DBC Driver:

GradleMaven

runtimeOnly("io.r2dbc:r2dbc-mssql")

Copy to Clipboard

And for Flyway migrations the JDBC driver:

GradleMaven

runtimeOnly("com.microsoft.sqlserver:mssql-jdbc")

Copy to Clipboard

5 Micronaut Data R2DBC

Micronaut Data builds on this module and provides support for Reactive repositories. See the documentation on Micronaut Data R2DBC for more information and the Quick Start section for a demonstration on how to create an application.

6 Repository

You can find the source code of this project in this repository:

https://github.com/micronaut-projects/micronaut-r2dbc

Table of Contents

Micronaut R2DBC

1 Introduction

2 Release History

3 Quick Start

4 Available Drivers

H2

MySQL

MariaDB

Postgresql

SQL Server

5 Micronaut Data R2DBC

6 Repository