@FunctionalInterface public interface StatementFilterFunction
execute function.
The filter is executed when a Subscriber subscribes
to the Publisher returned by the DatabaseClient.
StatementFilterFunctions are typically used to specify additional details on
the Statement objects such as fetchSize or key generation.
ExecuteFunction| Modifier and Type | Field and Description |
|---|---|
static StatementFilterFunction |
EMPTY_FILTER
An empty
StatementFilterFunction that delegates to ExecuteFunction. |
| Modifier and Type | Method and Description |
|---|---|
default StatementFilterFunction |
andThen(StatementFilterFunction afterFilter)
Return a composed filter function that first applies this filter, and then
applies the given
"after" filter. |
org.reactivestreams.Publisher<? extends io.r2dbc.spi.Result> |
filter(io.r2dbc.spi.Statement statement,
ExecuteFunction next)
Apply this filter to the given
Statement and ExecuteFunction. |
static final StatementFilterFunction EMPTY_FILTER
StatementFilterFunction that delegates to ExecuteFunction.org.reactivestreams.Publisher<? extends io.r2dbc.spi.Result> filter(io.r2dbc.spi.Statement statement,
ExecuteFunction next)
Statement and ExecuteFunction.
The given ExecuteFunction represents the next entity in the chain,
to be invoked via ExecuteFunction.execute(Statement) invoked} in
order to proceed with the execution, or not invoked to shortcut the chain.
statement - the current Statementnext - the next execute function in the chainResults.default StatementFilterFunction andThen(StatementFilterFunction afterFilter)
"after" filter.afterFilter - the filter to apply after this filter