java 非srping 使用r2dbc操作mysql 增删改查代码

要在Java中使用R2DBC操作MySQL，首先需要添加相关依赖。在Maven项目中，可以在pom.xml文件中添加以下依赖：

<dependency><groupId>dev.miku</groupId><artifactId>r2dbc-mysql</artifactId><version>0.8.2.RELEASE</version>
</dependency>

接下来，可以创建一个R2DBC连接池，并使用它来执行数据库操作。以下是一个简单的示例：

import io.r2dbc.spi.ConnectionFactory;
import io.r2dbc.spi.ConnectionFactoryOptions;
import io.r2dbc.spi.ConnectionFactories;
import io.r2dbc.spi.Result;
import io.r2dbc.spi.Row;
import io.r2dbc.spi.RowMetadata;
import reactor.core.publisher.Flux;public class R2DBCExample {public static void main(String[] args) {// 创建连接工厂ConnectionFactory connectionFactory = ConnectionFactories.get("r2dbc:mysql://localhost:3306/testdb?user=root&password=123456");// 创建连接池ConnectionFactoryOptions options = ConnectionFactoryOptions.builder().initialSize(5).maxSize(10).build();ConnectionFactory pooledConnectionFactory = ConnectionFactories.get(connectionFactory, options);// 插入数据pooledConnectionFactory.create().flatMapMany(connection -> connection.createStatement("INSERT INTO users (name, age) VALUES ('张三', 25)").execute()).flatMap(result -> result.getRowsUpdated()).subscribe(System.out::println);// 查询数据pooledConnectionFactory.create().flatMapMany(connection -> connection.createStatement("SELECT * FROM users").execute()).flatMap(result -> result.map((row, metadata) -> row.get("name", String.class))).subscribe(System.out::println);// 更新数据pooledConnectionFactory.create().flatMapMany(connection -> connection.createStatement("UPDATE users SET age = 26 WHERE name = '张三'").execute()).flatMap(result -> result.getRowsUpdated()).subscribe(System.out::println);// 删除数据pooledConnectionFactory.create().flatMapMany(connection -> connection.createStatement("DELETE FROM users WHERE name = '张三'").execute()).flatMap(result -> result.getRowsUpdated()).subscribe(System.out::println);}
}

在这个示例中，我们首先创建了一个MySQL数据库的连接工厂，然后创建了一个连接池。接着，我们使用连接池执行了插入、查询、更新和删除操作。