io.micronaut.r2dbc.rxjava2

Interface RxStatement

All Superinterfaces:

io.r2dbc.spi.Statement

public interface RxStatement
extends io.r2dbc.spi.Statement

Specialization of Statement for RxJava.

Since:

1.0.0

Author:

graemerocher

Method Summary

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 RxResults.
RxStatement	fetchSize(int rows)
RxStatement	returnGeneratedValues(java.lang.String... columns)

Method Detail

execute

io.reactivex.Flowable<? extends RxResult> execute()

Executes one or more SQL statements and returns the RxResults. RxResult objects must be fully consumed to ensure full execution of the RxStatement.

Specified by:

execute in interface io.r2dbc.spi.Statement

Returns:

the RxResults, returned by each statement

Throws:

java.lang.IllegalStateException - if the statement is parametrized and not all parameter values are provided

returnGeneratedValues

RxStatement returnGeneratedValues(java.lang.String... columns)

Specified by:

returnGeneratedValues in interface io.r2dbc.spi.Statement

add

RxStatement add()

Specified by:

add in interface io.r2dbc.spi.Statement

bind

RxStatement bind(int index,
                 java.lang.Object value)

Specified by:

bind in interface io.r2dbc.spi.Statement

bind

RxStatement bind(java.lang.String name,
                 java.lang.Object value)

Specified by:

bind in interface io.r2dbc.spi.Statement

bindNull

RxStatement bindNull(int index,
                     java.lang.Class<?> type)

Specified by:

bindNull in interface io.r2dbc.spi.Statement

bindNull

RxStatement bindNull(java.lang.String name,
                     java.lang.Class<?> type)

Specified by:

bindNull in interface io.r2dbc.spi.Statement

fetchSize

RxStatement fetchSize(int rows)

Specified by:

fetchSize in interface io.r2dbc.spi.Statement