如何在 postgresql r2dbc 中获取 select 查询的结果？

Question

我可以很好地执行此查询，但我不知道如何提取 select 语句返回的信息。

Flux<PostgresqlResult> checkTableQuery = connectionMono.flatMapMany(connection -> connection
    .createStatement("select exists(\n" +
                " select table_name from information_schema.tables\n" +
                " where table_name='sequence1'\n" +
                ");")
        .execute());
checkTableQuery.subscribe();

Answer 1

Flux<PostgresqlResult> checkTableQuery = connectionMono.flatMapMany(connection -> connection
.createStatement("select exists(\n" +
            " select table_name from information_schema.tables\n" +
            " where table_name='sequence1'\n" +
            ");")
    .execute()).flatmap(result->result.map(Row,RowMetadata)->Row.get("exists",Boolean.class)));
checkTableQuery.subscribe();