使用 R2DBC 连接规范操作 MySQL 数据库：从头开始！

2023-11-11 11:31:17

简介

R2DBC（反应式关系数据库连接）规范是一个异步、非阻塞的连接规范，允许 Java 应用程序以响应式方式与关系数据库进行交互。R2DBC 为 Java 8 及更高版本提供了一个通用的 API，使开发人员能够轻松地连接到各种关系数据库，包括 MySQL、PostgreSQL 和 Oracle。

连接到 MySQL 数据库

第一步是建立与 MySQL 数据库的连接。为此，我们需要使用 R2DBC 连接工厂类。有几种方法可以获取连接工厂，具体取决于您使用的 R2DBC 实现。以下是如何使用 Spring Boot 集成 R2DBC 连接到 MySQL 数据库的示例：

import io.r2dbc.spi.ConnectionFactory;
import org.springframework.boot.autoconfigure.r2dbc.R2dbcProperties;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class R2dbcConfiguration {

    @Bean
    public ConnectionFactory connectionFactory(R2dbcProperties properties) {
        return R2dbcConnectionFactories.get(properties);
    }
}

执行查询

一旦建立了连接，就可以开始执行查询。R2DBC 使用 Flux 和 Mono 类型来表示响应式数据流。Flux 用于表示多行结果，而 Mono 用于表示单个结果。以下是如何使用 R2DBC 执行简单查询的示例：

import io.r2dbc.spi.ConnectionFactory;
import io.r2dbc.spi.Result;
import reactor.core.publisher.Flux;

public class QueryExample {

    public static void main(String[] args) {
        ConnectionFactory connectionFactory = ...;

        Flux<Result> results = connectionFactory.create()
            .flatMapMany(connection -> connection.createStatement("SELECT * FROM users")
                .execute())
            .flatMapSequential(result -> result.map((row, rowMetadata) ->
                String.format("%s, %s", row.get("id", Integer.class), row.get("name", String.class))));

        results.subscribe(System.out::println);
    }
}

事务管理

R2DBC 也支持事务管理。事务允许您将多个数据库操作组合成一个逻辑单元，以便要么全部成功，要么全部失败。以下是如何使用 R2DBC 开始和提交事务的示例：

import io.r2dbc.spi.ConnectionFactory;
import io.r2dbc.spi.Result;
import reactor.core.publisher.Mono;

public class TransactionExample {

    public static void main(String[] args) {
        ConnectionFactory connectionFactory = ...;

        Mono<Void> result = connectionFactory.create()
            .flatMap(connection -> connection.beginTransaction()
                .flatMap(transaction -> {
                    Mono<Void> update1 = transaction.createStatement("UPDATE users SET name = 'John' WHERE id = 1")
                        .execute()
                        .then();
                    Mono<Void> update2 = transaction.createStatement("UPDATE users SET name = 'Mary' WHERE id = 2")
                        .execute()
                        .then();
                    return Mono.when(update1, update2)
                        .then(transaction.commit());
                }));

        result.subscribe();
    }
}