非spring使用r2dbc

在非Spring环境下使用R2DBC，需要手动创建连接和执行SQL语句。以下是一个示例：

 

```java

import io.r2dbc.spi.ConnectionFactory;

import io.r2dbc.spi.ConnectionFactoryOptions;

import io.r2dbc.spi.Result;

import io.r2dbc.spi.Row;

import io.r2dbc.spi.Statement;

import reactor.core.publisher.Flux;

 

public class R2DBCExample {

    public static void main(String[] args) {

        // 创建连接工厂

        ConnectionFactory connectionFactory = ConnectionFactories.get("r2dbc:h2:mem:///test");

 

        // 获取连接

        connectionFactory.create()

                .flatMapMany(connection -> {

                    // 创建SQL语句

                    Statement statement = connection.createStatement("SELECT * FROM users");

 

                    // 执行SQL语句并返回结果

                    return Flux.from(statement.execute())

                            .flatMap(result -> result.map((row, metadata) -> row.get("name", String.class)));

                })

                .subscribe(System.out::println); // 输出查询结果

    }

}

```

 

在这个示例中，我们使用了H2内存数据库作为数据源，并执行了一个简单的查询语句。你可以根据需要修改连接工厂和SQL语句。