使用r2dbc驱动程序的Jooq反应式抓取

import org.jooq.DSLContext;
import org.springframework.r2dbc.core.DatabaseClient;
import reactor.core.publisher.Flux;

public class ReactiveFetchExample {

    private final DSLContext dsl;
    private final DatabaseClient client;

    public ReactiveFetchExample(DSLContext dsl, DatabaseClient client) {
        this.dsl = dsl;
        this.client = client;
    }

    public Flux<User> fetchUsers() {
        return client.sql("SELECT * FROM users")
                     .map(row -> new User(
                         row.get("id", Integer.class),
                         row.get("name", String.class)
                     ))
                     .all();
    }

    // User类定义
    public static class User {
        private final int id;
        private final String name;

        public User(int id, String name) {
            this.id = id;
            this.name = name;
        }

        // Getters...
    }
}