public interface RxStatement
extends io.r2dbc.spi.Statement
Modifier and Type | Method and Description |
---|---|
RxStatement |
add() |
RxStatement |
bind(int index,
java.lang.Object value) |
RxStatement |
bind(java.lang.String name,
java.lang.Object value) |
RxStatement |
bindNull(int index,
java.lang.Class<?> type) |
RxStatement |
bindNull(java.lang.String name,
java.lang.Class<?> type) |
io.reactivex.Flowable<? extends RxResult> |
execute()
Executes one or more SQL statements and returns the
RxResult s. |
RxStatement |
fetchSize(int rows) |
RxStatement |
returnGeneratedValues(java.lang.String... columns) |
io.reactivex.Flowable<? extends RxResult> execute()
RxResult
s.
RxResult
objects must be fully consumed to ensure full execution of the RxStatement
.execute
in interface io.r2dbc.spi.Statement
RxResult
s, returned by each statementjava.lang.IllegalStateException
- if the statement is parametrized and not all parameter values are providedRxStatement returnGeneratedValues(java.lang.String... columns)
returnGeneratedValues
in interface io.r2dbc.spi.Statement
RxStatement add()
add
in interface io.r2dbc.spi.Statement
RxStatement bind(int index, java.lang.Object value)
bind
in interface io.r2dbc.spi.Statement
RxStatement bind(java.lang.String name, java.lang.Object value)
bind
in interface io.r2dbc.spi.Statement
RxStatement bindNull(int index, java.lang.Class<?> type)
bindNull
in interface io.r2dbc.spi.Statement
RxStatement bindNull(java.lang.String name, java.lang.Class<?> type)
bindNull
in interface io.r2dbc.spi.Statement
RxStatement fetchSize(int rows)
fetchSize
in interface io.r2dbc.spi.Statement