如何在postgresqlr2dbc中获取select查询的结果

Question

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

Flux<PostgresqlResult> checkTableQuery = connectionMono.flatMapMany(connection -> connection
.createStatement("select exists(n" +
" select table_name from information_schema.tablesn" +
" 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.tablesn" +
" where table_name='sequence1'n" +
");")
.execute())
.flatmap(result -> result.map(
(row,rowMetadata) -> row.get("exists",Boolean.class)));
checkTableQuery.subscribe();