Використання R2DBC

Проект Reactive Relational Database Connectivity (R2DBC) привносить API реактивного програмування до реляційних баз даних. io.r2dbc.spi.Connection з R2DBC передбачає стандартний метод роботи з неблокуючими підключеннями до бази даних. З'єднання передаються за допомогою ConnectionFactory, аналогічно DataSource в jdbc.

Конфігурацією ConnectionFactory керують зовнішні конфігураційні властивості з spring.r2dbc.*. Наприклад, можна оголосити наступний розділ у application.properties:

spring.r2dbc.url=r2dbc:postgresql://localhost/test
spring.r2dbc.username=dbuser
spring.r2dbc.password=dbpass

spring:
  r2dbc:
    url: "r2dbc:postgresql://localhost/test"
    username: "dbuser"
    password: "dbpass"

Щоб налаштувати з'єднання, що створюються ConnectionFactory, тобто зазначити певні параметри, які ти не бажаєш (або не можеш) налаштовувати в конфігурації твоєї центральної бази даних, можна використовувати позначений анотацією @Bean бін ConnectionFactoryOptionsBuilderCustomizer. У цьому прикладі показано, як вручну перевизначити порт бази даних, тоді як інші параметри будуть братися з конфігурації програми:

import io.r2dbc.spi.ConnectionFactoryOptions;
import org.springframework.boot.autoconfigure.r2dbc.ConnectionFactoryOptionsBuilderCustomizer;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
@Configuration(proxyBeanMethods = false)
public class MyR2dbcConfiguration {
    @Bean
    public ConnectionFactoryOptionsBuilderCustomizer connectionFactoryPortCustomizer() {
        return (builder) -> builder.option(ConnectionFactoryOptions.PORT, 5432);
    }
}

import io.r2dbc.spi.ConnectionFactoryOptions
import org.springframework.boot.autoconfigure.r2dbc.ConnectionFactoryOptionsBuilderCustomizer
import org.springframework.context.annotation.Bean
import org.springframework.context.annotation.Configuration
@Configuration(proxyBeanMethods = false)
class MyR2dbcConfiguration {
    @Bean
    fun connectionFactoryPortCustomizer(): ConnectionFactoryOptionsBuilderCustomizer {
        return ConnectionFactoryOptionsBuilderCustomizer { builder ->
            builder.option(ConnectionFactoryOptions.PORT, 5432)
        }
    }
}

У наступних прикладах показано, як встановити певні параметри з'єднання PostgreSQL:

import java.util.HashMap;
import java.util.Map;
import io.r2dbc.postgresql.PostgresqlConnectionFactoryProvider;
import org.springframework.boot.autoconfigure.r2dbc.ConnectionFactoryOptionsBuilderCustomizer;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
@Configuration(proxyBeanMethods = false)
public class MyPostgresR2dbcConfiguration {
    @Bean
    public ConnectionFactoryOptionsBuilderCustomizer postgresCustomizer() {
        Map<String, String> options = new HashMap<>();
        options.put("lock_timeout", "30s");
        options.put("statement_timeout", "60s");
        return (builder) -> builder.option(PostgresqlConnectionFactoryProvider.OPTIONS, options);
    }
}

import io.r2dbc.postgresql.PostgresqlConnectionFactoryProvider
import org.springframework.boot.autoconfigure.r2dbc.ConnectionFactoryOptionsBuilderCustomizer
import org.springframework.context.annotation.Bean
import org.springframework.context.annotation.Configuration
@Configuration(proxyBeanMethods = false)
class MyPostgresR2dbcConfiguration {
    @Bean
    fun postgresCustomizer(): ConnectionFactoryOptionsBuilderCustomizer {
        val options: MutableMap<String, String> = HashMap()
        options["lock_timeout"] = "30s"
        options["statement_timeout"] = "60s"
        return ConnectionFactoryOptionsBuilderCustomizer { builder ->
            builder.option(PostgresqlConnectionFactoryProvider.OPTIONS, options)
        }
    }
}

Якщо є бін ConnectionFactory, звичайна автоконфігурація для DataSource з JDBC відключається. Якщо необхідно зберегти автоконфігурацію для DataSource з JDBC, і водночас тебе влаштовує ризик використання блокуючого JDBC API в реактивному додатку, додай @Import(DataSourceAutoConfiguration.class) до класу, позначеного анотацією @Configuration у своїй програмі, щоб повторно активувати її.

Підтримка вбудованих баз даних

Аналогічно засобам підтримки JDBC фреймворк Spring Boot може автоматично конфігурувати вбудовану базу даних для реактивного режиму використання. URL-адреси будь-якого підключення не потрібно вказувати. Необхідно лише додати залежність збирання до вбудованої бази даних, яку ти хочете використовувати, як це показано в наступному прикладі:

<dependency>
    <groupId>io.r2dbc</groupId>
    <artifactId>r2dbc-h2</artifactId>
    <scope>runtime</scope>
</dependency>

Використання DatabaseClient

Бін DatabaseClient є конфігурованим, але ти можеш прив'язати його через анотацію @Autowire безпосередньо до власних бінів, як це показано в наступному прикладі:

import java.util.Map;
import reactor.core.publisher.Flux;
import org.springframework.r2dbc.core.DatabaseClient;
import org.springframework.stereotype.Component;
@Component
public class MyBean {
    private final DatabaseClient databaseClient;
    public MyBean(DatabaseClient databaseClient) {
        this.databaseClient = databaseClient;
    }
 // ...
 public Flux<Map<String, Object>> someMethod() {
        return this.databaseClient.sql("select * from user").fetch().all();
    }
}

import org.springframework.r2dbc.core.DatabaseClient
import org.springframework.stereotype.Component
import reactor.core.publisher.Flux
@Component
class MyBean(private val databaseClient: DatabaseClient) {
 // ...
 fun someMethod(): Flux<Map<String, Any>> {
        return databaseClient.sql("select * from user").fetch().all()
    }
}

Репозиторії Spring Data R2DBC

Репозиторії Spring Data R2DBC — це інтерфейси, які можна визначити для отримання доступу до даних. Запити створюються автоматично з урахуванням імен методів. Наприклад, інтерфейс CityRepository може оголосити метод findAllByState(String state) для пошуку всіх міст у цьому штаті.

У разі більш складних запитів можна анотувати метод за допомогою анотації Query із Spring Data.

Репозиторії Spring Data зазвичай розширюються за рахунок інтерфейсів Repository або CrudRepository. Якщо ти використовуєг автоконфігурацію, пошук в репозиторіях ведеться від пакета, що містить основний клас конфігурації (той, який анотований @EnableAutoConfiguration або @SpringBootApplication), і вниз за ієрархією.

У наступному прикладі показано типове визначення інтерфейсу взаємодії з репозиторієм Spring Data:

import reactor.core.publisher.Mono;
import org.springframework.data.repository.Repository;
public interface CityRepository extends Repository<City, Long> {
    Mono<City> findByNameAndStateAllIgnoringCase(String name, String state);
}

import org.springframework.data.repository.Repository
import reactor.core.publisher.Mono
interface CityRepository : Repository<City?, Long?> {
    fun findByNameAndStateAllIgnoringCase(name: String?, state: String?): Mono<City?>?
}