io.micronaut.r2dbc.rxjava2

Interface RxBatch

All Superinterfaces:

io.r2dbc.spi.Batch

public interface RxBatch
extends io.r2dbc.spi.Batch

Specialization of Batch for RxJava.

Since:

1.0.0

Author:

graemerocher

Method Summary

Modifier and Type	Method and Description
RxBatch	add(java.lang.String sql)
io.reactivex.Flowable<? extends RxResult>	execute() Executes one or more SQL statements and returns the RxResults.

Method Detail

execute

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

Executes one or more SQL statements and returns the RxResults.

Specified by:

execute in interface io.r2dbc.spi.Batch

Returns:

the RxResults, returned by each statement

add

@NonNull
RxBatch add(@NonNull
                     java.lang.String sql)

Specified by:

add in interface io.r2dbc.spi.Batch