@FunctionalInterface public interface ExecuteFunction
Statement
for a (delayed)
Result
stream.
Note that discarded Result
objects must be consumed according
to the R2DBC spec via either Result.getRowsUpdated()
or
Result.map(BiFunction)
.
Typically, implementations invoke the Statement.execute()
method
to initiate execution of the statement object.
For example:
DatabaseClient.builder() .executeFunction(statement -> statement.execute()) .build();
Statement.execute()
Modifier and Type | Method and Description |
---|---|
org.reactivestreams.Publisher<? extends io.r2dbc.spi.Result> |
execute(io.r2dbc.spi.Statement statement)
Execute the given
Statement for a stream of Result objects. |