如何在 postgresql r2dbc 中获取选择查询的结果？答案

【问题标题】：How to get results of select query in postgresql r2dbc?如何在 postgresql r2dbc 中获取选择查询的结果？
【发布时间】：2021-06-03 07:17:15
【问题描述】：

我可以很好地执行这个查询，但是我不知道如何提取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();

【问题讨论】：

使用 subscribe() 订阅订阅，查看Flux Subscriber java doc

标签： postgresql r2dbc r2dbc-postgresql

【解决方案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();

【讨论】：