io.micronaut.data.r2dbc.operations

Class DefaultR2dbcRepositoryOperations

java.lang.Object

io.micronaut.data.runtime.operations.internal.AbstractSqlRepositoryOperations<io.r2dbc.spi.Connection,io.r2dbc.spi.Row,io.r2dbc.spi.Statement,java.lang.RuntimeException>

io.micronaut.data.r2dbc.operations.DefaultR2dbcRepositoryOperations

All Implemented Interfaces:

AsyncCapableRepository, ReactiveCapableRepository, RepositoryOperations, BlockingReactorRepositoryOperations, R2dbcOperations, R2dbcRepositoryOperations, ReactorReactiveCapableRepository, ReactiveTransactionOperations<io.r2dbc.spi.Connection>

@EachBean(value=io.r2dbc.spi.ConnectionFactory.class)
 @Internal
public class DefaultR2dbcRepositoryOperations
extends AbstractSqlRepositoryOperations<io.r2dbc.spi.Connection,io.r2dbc.spi.Row,io.r2dbc.spi.Statement,java.lang.RuntimeException>
implements BlockingReactorRepositoryOperations, R2dbcRepositoryOperations, R2dbcOperations, ReactiveTransactionOperations<io.r2dbc.spi.Connection>

Defines an implementation of Micronaut Data's core interfaces for R2DBC.

Since:

1.0.0

Author:

graemerocher, Denis Stepanov

Nested Class Summary

Nested classes/interfaces inherited from class io.micronaut.data.runtime.operations.internal.AbstractSqlRepositoryOperations

AbstractSqlRepositoryOperations.BaseOperations<T>, AbstractSqlRepositoryOperations.CascadeContext, AbstractSqlRepositoryOperations.CascadeManyOp, AbstractSqlRepositoryOperations.CascadeOneOp, AbstractSqlRepositoryOperations.CascadeOp, AbstractSqlRepositoryOperations.DBOperation1<In,Exc extends java.lang.Exception>, AbstractSqlRepositoryOperations.DBOperation2<In1,In2,Exc extends java.lang.Exception>, AbstractSqlRepositoryOperations.EntitiesOperations<T>, AbstractSqlRepositoryOperations.EntityOperations<T>, AbstractSqlRepositoryOperations.SqlOperation, AbstractSqlRepositoryOperations.StatementSupplier<PS>, AbstractSqlRepositoryOperations.StoredAnnotationMetadataSqlOperation, AbstractSqlRepositoryOperations.StoredSqlOperation

Nested classes/interfaces inherited from interface io.micronaut.transaction.reactive.ReactiveTransactionOperations

ReactiveTransactionOperations.TransactionalCallback<C,T>

Field Summary

Fields inherited from class io.micronaut.data.runtime.operations.internal.AbstractSqlRepositoryOperations

columnIndexResultSetReader, columnNameResultSetReader, dateTimeProvider, DEFAULT_SQL_BUILDER, entityEventRegistry, jsonCodec, preparedStatementWriter, QUERY_LOG, queryBuilders, runtimeEntityRegistry

Constructor Summary

Constructors

Modifier

Constructor and Description

protected

DefaultR2dbcRepositoryOperations(java.lang.String dataSourceName, io.r2dbc.spi.ConnectionFactory connectionFactory, java.util.List<io.micronaut.http.codec.MediaTypeCodec> mediaTypeCodecList, DateTimeProvider<java.lang.Object> dateTimeProvider, RuntimeEntityRegistry runtimeEntityRegistry, io.micronaut.context.ApplicationContext applicationContext, java.util.concurrent.ExecutorService executorService) Default constructor.

Method Summary

Modifier and Type	Method and Description
AsyncRepositoryOperations	async()
io.r2dbc.spi.ConnectionFactory	connectionFactory() Obtains the connection factory.
protected void	prepareStatement(io.r2dbc.spi.Connection connection, Dialect dialect, PersistentProperty identity, boolean hasGeneratedID, java.lang.String insertSql, AbstractSqlRepositoryOperations.DBOperation1<io.r2dbc.spi.Statement,java.lang.RuntimeException> fn) Prepare a statement and run a function.
protected void	prepareStatement(io.r2dbc.spi.Connection connection, java.lang.String query, AbstractSqlRepositoryOperations.DBOperation1<io.r2dbc.spi.Statement,java.lang.RuntimeException> fn) Prepare a statement and run a function.
ReactorReactiveRepositoryOperations	reactive()
protected int	shiftIndex(int i) Used to define the index whether it is 1 based (JDBC) or 0 based (R2DBC).
<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(ReactiveTransactionStatus<io.r2dbc.spi.Connection> status, ReactiveTransactionOperations.TransactionalCallback<io.r2dbc.spi.Connection,T> handler) Execute the given handler with an existing transaction status.
<T> reactor.core.publisher.Flux<T>	withTransaction(TransactionDefinition definition, ReactiveTransactionOperations.TransactionalCallback<io.r2dbc.spi.Connection,T> handler) Execute the given handler with a new transaction.

Methods inherited from class io.micronaut.data.runtime.operations.internal.AbstractSqlRepositoryOperations

afterCascadedMany, afterCascadedOne, cascade, checkOptimisticLocking, deleteInBatch, deleteOne, getEntity, getIdReader, isOnlySingleEndedJoins, isSqlServerWithoutOrderBy, isSupportsBatchDelete, isSupportsBatchInsert, isSupportsBatchUpdate, persistInBatch, persistJoinTableAssociation, persistOne, prepareStatement, resolveAssociationInsert, resolveEntityInsert, resolveEntityUpdate, setStatementParameter, sizeOf, sortById, triggerPostLoad, updateInBatch, updateOne

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface io.micronaut.data.r2dbc.operations.BlockingReactorRepositoryOperations

count, delete, deleteAll, executeUpdate, exists, findAll, findAll, findOne, findOne, findPage, findStream, findStream, persist, persistAll, update

Methods inherited from interface io.micronaut.data.operations.RepositoryOperations

executeDelete, getEntity, getQueryHints, updateAll

Methods inherited from interface io.micronaut.transaction.reactive.ReactiveTransactionOperations

withTransaction

Constructor Detail

DefaultR2dbcRepositoryOperations

@Internal
protected DefaultR2dbcRepositoryOperations(@Parameter
                                                     java.lang.String dataSourceName,
                                                     io.r2dbc.spi.ConnectionFactory connectionFactory,
                                                     java.util.List<io.micronaut.http.codec.MediaTypeCodec> mediaTypeCodecList,
                                                     @NonNull
                                                     DateTimeProvider<java.lang.Object> dateTimeProvider,
                                                     RuntimeEntityRegistry runtimeEntityRegistry,
                                                     io.micronaut.context.ApplicationContext applicationContext,
                                                     @Nullable @Named(value="io")
                                                     java.util.concurrent.ExecutorService executorService)

Default constructor.

Parameters:

dataSourceName - The data source name

connectionFactory - The associated connection factory

mediaTypeCodecList - The media type codec list

dateTimeProvider - The date time provider

runtimeEntityRegistry - The runtime entity registry

applicationContext - The bean context

executorService - The executor

Method Detail

prepareStatement

protected void prepareStatement(io.r2dbc.spi.Connection connection,
                                java.lang.String query,
                                AbstractSqlRepositoryOperations.DBOperation1<io.r2dbc.spi.Statement,java.lang.RuntimeException> fn)

Description copied from class: AbstractSqlRepositoryOperations

Prepare a statement and run a function.

Specified by:

prepareStatement in class AbstractSqlRepositoryOperations<io.r2dbc.spi.Connection,io.r2dbc.spi.Row,io.r2dbc.spi.Statement,java.lang.RuntimeException>

Parameters:

connection - The connection.

query - The query

fn - The function to be run with a statement

prepareStatement

protected void prepareStatement(io.r2dbc.spi.Connection connection,
                                Dialect dialect,
                                PersistentProperty identity,
                                boolean hasGeneratedID,
                                java.lang.String insertSql,
                                AbstractSqlRepositoryOperations.DBOperation1<io.r2dbc.spi.Statement,java.lang.RuntimeException> fn)

Description copied from class: AbstractSqlRepositoryOperations

Prepare a statement and run a function.

Specified by:

prepareStatement in class AbstractSqlRepositoryOperations<io.r2dbc.spi.Connection,io.r2dbc.spi.Row,io.r2dbc.spi.Statement,java.lang.RuntimeException>

Parameters:

connection - The connection

dialect - The dialect

identity - The identity property

hasGeneratedID - Is genereted idenntity

insertSql - Te query

fn - The function to be run with a statement

shiftIndex

protected int shiftIndex(int i)

Description copied from class: AbstractSqlRepositoryOperations

Used to define the index whether it is 1 based (JDBC) or 0 based (R2DBC).

Overrides:

shiftIndex in class AbstractSqlRepositoryOperations<io.r2dbc.spi.Connection,io.r2dbc.spi.Row,io.r2dbc.spi.Statement,java.lang.RuntimeException>

Parameters:

i - The index to shift

Returns:

the index

reactive

@NonNull
public ReactorReactiveRepositoryOperations reactive()

Specified by:

reactive in interface ReactiveCapableRepository

Specified by:

reactive in interface ReactorReactiveCapableRepository

Returns:

The reactive operations instance.

async

@NonNull
public AsyncRepositoryOperations async()

Specified by:

async in interface AsyncCapableRepository

Returns:

The async operations.

connectionFactory

@NonNull
public io.r2dbc.spi.ConnectionFactory connectionFactory()

Description copied from interface: R2dbcOperations

Obtains the connection factory.

Specified by:

connectionFactory in interface R2dbcOperations

Returns:

The connection factory

withConnection

@NonNull
public <T> org.reactivestreams.Publisher<T> withConnection(@NonNull
                                                                    java.util.function.Function<io.r2dbc.spi.Connection,org.reactivestreams.Publisher<T>> handler)

Description copied from interface: R2dbcOperations

Execute the given handler with a new connection.

Specified by:

withConnection in interface R2dbcOperations

Type Parameters:

T - The emitted type

Parameters:

handler - The handler

Returns:

A publisher that emits the result type

withTransaction

@NonNull
public <T> org.reactivestreams.Publisher<T> withTransaction(@NonNull
                                                                     ReactiveTransactionStatus<io.r2dbc.spi.Connection> status,
                                                                     @NonNull
                                                                     ReactiveTransactionOperations.TransactionalCallback<io.r2dbc.spi.Connection,T> handler)

Description copied from interface: R2dbcOperations

Execute the given handler with an existing transaction status.

Specified by:

withTransaction in interface R2dbcOperations

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
public <T> reactor.core.publisher.Flux<T> withTransaction(@NonNull
                                                                   TransactionDefinition definition,
                                                                   @NonNull
                                                                   ReactiveTransactionOperations.TransactionalCallback<io.r2dbc.spi.Connection,T> handler)

Description copied from interface: ReactiveTransactionOperations

Execute the given handler with a new transaction.

Specified by:

withTransaction in interface ReactiveTransactionOperations<io.r2dbc.spi.Connection>

Type Parameters:

T - The emitted type

Parameters:

definition - The definition

handler - The handler

Returns:

A publisher that emits the result type