使用R2dbc过滤查询

import io.r2dbc.spi.ConnectionFactory;
import io.r2dbc.spi.Row;
import io.r2dbc.spi.RowMetadata;
import io.r2dbc.spi.Statement;
import io.r2dbc.spi.ValidationDepth;
import io.r2dbc.spi.ValidationDepthProvider;
import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;

public class FilterQueryExample {

    private final ConnectionFactory connectionFactory;

    public FilterQueryExample(ConnectionFactory connectionFactory) {
        this.connectionFactory = connectionFactory;
    }

    public Flux<String> getFilteredData(String filterValue) {
        return Mono.from(connectionFactory.create())
                .flatMapMany(connection -> {
                    Statement statement = connection.createStatement("SELECT * FROM table_name WHERE column_name = $1");
                    statement.bind("$1", filterValue);
                    return statement.execute();
                })
                .flatMap(result -> result.map(this::mapRowToString));
    }

    private String mapRowToString(Row row, RowMetadata metadata) {
        // Map the row data to a string representation
        return row.get("column_name", String.class);
    }
}