Package io.micronaut.data.r2dbc.operations

Interface R2dbcOperations

public interface R2dbcOperations
Operations for R2DBC.
Since:
1.0.0
Author:
graemerocher

  • Method Details

    • connectionFactory

      @NonNull @NonNull io.r2dbc.spi.ConnectionFactory connectionFactory()
      Obtains the connection factory.
      Returns:
      The connection factory

    • withTransaction

      @NonNull <T> @NonNull org.reactivestreams.Publisher<T> withTransaction(@NonNull @NonNull ReactiveTransactionStatus<io.r2dbc.spi.Connection> status, @NonNull ReactiveTransactionOperations.TransactionalCallback<io.r2dbc.spi.Connection,T> handler)
      Execute the given handler with an existing transaction status.
      Type Parameters:
      T - The emitted type
      Parameters:
      status - An existing in progress transaction status
      handler - The handler
      Returns:
      A publisher that emits the result type

    • withTransaction

      @NonNull <T> @NonNull org.reactivestreams.Publisher<T> withTransaction(@NonNull ReactiveTransactionOperations.TransactionalCallback<io.r2dbc.spi.Connection,T> handler)
      Execute the given handler with an existing transaction status.
      Type Parameters:
      T - The emitted type
      Parameters:
      handler - The handler
      Returns:
      A publisher that emits the result type

    • withConnection

      @NonNull <T> @NonNull org.reactivestreams.Publisher<T> withConnection(@NonNull @NonNull Function<io.r2dbc.spi.Connection,org.reactivestreams.Publisher<? extends T>> handler)
      Execute the given handler with a new connection.
      Type Parameters:
      T - The emitted type
      Parameters:
      handler - The handler
      Returns:
      A publisher that emits the result type