public interface R2dbcOperations
extends io.micronaut.transaction.reactive.ReactiveTransactionOperations<io.r2dbc.spi.Connection>
Modifier and Type | Method and Description |
---|---|
io.r2dbc.spi.ConnectionFactory |
connectionFactory()
Obtains the connection factory.
|
<T> org.reactivestreams.Publisher<T> |
withConnection(java.util.function.Function<io.r2dbc.spi.Connection,org.reactivestreams.Publisher<T>> handler)
Execute the given handler with a new connection.
|
<T> org.reactivestreams.Publisher<T> |
withTransaction(io.micronaut.transaction.reactive.ReactiveTransactionStatus<io.r2dbc.spi.Connection> status,
io.micronaut.transaction.reactive.ReactiveTransactionOperations.TransactionalCallback<io.r2dbc.spi.Connection,T> handler)
Execute the given handler with an existing transaction status.
|
@NonNull io.r2dbc.spi.ConnectionFactory connectionFactory()
@NonNull <T> org.reactivestreams.Publisher<T> withTransaction(@NonNull io.micronaut.transaction.reactive.ReactiveTransactionStatus<io.r2dbc.spi.Connection> status, @NonNull io.micronaut.transaction.reactive.ReactiveTransactionOperations.TransactionalCallback<io.r2dbc.spi.Connection,T> handler)
T
- The emitted typestatus
- An existing in progress transaction statushandler
- The handler@NonNull <T> org.reactivestreams.Publisher<T> withConnection(@NonNull java.util.function.Function<io.r2dbc.spi.Connection,org.reactivestreams.Publisher<T>> handler)
T
- The emitted typehandler
- The handler