Reactive Relational Database Connectivity (R2DBC)

This project is an exploration of what a Java API for relational database access with Reactive Streams might look like. It uses Project Reactor and only contains an implementation for PostgreSQL. It uses Jdbi as an inspiration.

THIS IS ONLY AN EXPERIEMENT AND NOT SUPPORTED SOFTWARE

Examples

Full fledged examples can be found in the r2dbc-examples project. A quick example of configuration and execution would look like:

PostgresqlConnectionConfiguration configuration = PostgresqlConnectionConfiguration.builder()
    .host("<host>")
    .database("<database>")
    .username("<username>")
    .password("<password>")
    .build();

R2dbc r2dbc = new R2dbc(new PostgresqlConnectionFactory(configuration));

r2dbc.inTransaction(handle ->
    handle.execute("INSERT INTO test VALUES ($1)", 100))

    .thenMany(r2dbc.inTransaction(handle ->
        handle.select("SELECT value FROM test")
            .execute(result -> result.map((row, rowMetadata) -> row.get("value", Integer.class)))))

    .subscribe(System.out::println);

THE PROJECT SYNTAX IS HIGHLY VOLATILE AND THIS EXAMPLE MAY BE OUT OF DATE

Maven

Both milestone and snapshot artifacts (library, source, and javadoc) can be found in Maven repositories. The database implementation artifact (r2dbc-postgresql) is the only artifact that needs to be directly included.

<dependency>
  <groupId>com.nebhale.r2dbc</groupId>
  <artifactId>r2dbc-postgresql</artifactId>
  <version>1.0.0.M3</version>
</dependency>

Artifacts can bound found at the following repositories.

Repositories

<repository>
    <id>nebhale-snapshots</id>
    <url>https://raw.githubusercontent.com/nebhale/r2dbc/maven/snapshot</url>
    <snapshots>
        <enabled>true</enabled>
    </snapshots>
</repository>

<repository>
    <id>nebhale-milestones</id>
    <url>https://raw.githubusercontent.com/nebhale/r2dbc/maven/milestone</url>
    <snapshots>
        <enabled>false</enabled>
    </snapshots>
</repository>

License

This project is released under version 2.0 of the Apache License.