io.micronaut.data.r2dbc.operations

Class DefaultR2dbcRepositoryOperations

java.lang.Object

io.micronaut.data.jdbc.operations.AbstractSqlRepositoryOperations<io.r2dbc.spi.Row,io.r2dbc.spi.Statement>

io.micronaut.data.r2dbc.operations.DefaultR2dbcRepositoryOperations

All Implemented Interfaces:

io.micronaut.data.operations.async.AsyncCapableRepository, io.micronaut.data.operations.reactive.ReactiveCapableRepository, io.micronaut.data.operations.RepositoryOperations, R2dbcOperations, R2dbcRepositoryOperations, io.micronaut.transaction.reactive.ReactiveTransactionOperations<io.r2dbc.spi.Connection>

@EachBean(value=io.r2dbc.spi.ConnectionFactory.class)
public class DefaultR2dbcRepositoryOperations
extends io.micronaut.data.jdbc.operations.AbstractSqlRepositoryOperations<io.r2dbc.spi.Row,io.r2dbc.spi.Statement>
implements R2dbcRepositoryOperations, R2dbcOperations, io.micronaut.transaction.reactive.ReactiveTransactionOperations<io.r2dbc.spi.Connection>

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

Since:

1.0.0

Author:

graemerocher

Nested Class Summary

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

io.micronaut.data.jdbc.operations.AbstractSqlRepositoryOperations.StatementSupplier<PS>, io.micronaut.data.jdbc.operations.AbstractSqlRepositoryOperations.StoredInsert<T>

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

io.micronaut.transaction.reactive.ReactiveTransactionOperations.TransactionalCallback<C,T>

Field Summary

Fields inherited from class io.micronaut.data.jdbc.operations.AbstractSqlRepositoryOperations

columnIndexResultSetReader, columnNameResultSetReader, dateTimeProvider, DEFAULT_SQL_BUILDER, IN_EXPRESSION_PATTERN, jsonCodec, NOT_TRUE_EXPRESSION, preparedStatementWriter, QUERY_LOG, queryBuilders

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, io.micronaut.data.runtime.date.DateTimeProvider<?> dateTimeProvider, io.micronaut.context.ApplicationContext applicationContext) Default constructor.

Method Summary

Modifier and Type	Method and Description
io.micronaut.data.operations.async.AsyncRepositoryOperations	async()
io.r2dbc.spi.ConnectionFactory	connectionFactory() Obtains the connection factory.
<T> long	count(io.micronaut.data.model.runtime.PagedQuery<T> pagedQuery)
<T> java.util.Optional<java.lang.Number>	deleteAll(io.micronaut.data.model.runtime.BatchOperation<T> operation)
java.util.Optional<java.lang.Number>	executeUpdate(io.micronaut.data.model.runtime.PreparedQuery<?,java.lang.Number> preparedQuery)
<T> boolean	exists(io.micronaut.data.model.runtime.PreparedQuery<T,java.lang.Boolean> preparedQuery)
<T> java.lang.Iterable<T>	findAll(io.micronaut.data.model.runtime.PagedQuery<T> query)
<T,R> java.lang.Iterable<R>	findAll(io.micronaut.data.model.runtime.PreparedQuery<T,R> preparedQuery)
<T> T	findOne(java.lang.Class<T> type, java.io.Serializable id)
<T,R> R	findOne(io.micronaut.data.model.runtime.PreparedQuery<T,R> preparedQuery)
<R> io.micronaut.data.model.Page<R>	findPage(io.micronaut.data.model.runtime.PagedQuery<R> query)
<T> java.util.stream.Stream<T>	findStream(io.micronaut.data.model.runtime.PagedQuery<T> query)
<T,R> java.util.stream.Stream<R>	findStream(io.micronaut.data.model.runtime.PreparedQuery<T,R> preparedQuery)
<T> T	persist(io.micronaut.data.model.runtime.InsertOperation<T> operation)
<T> java.lang.Iterable<T>	persistAll(io.micronaut.data.model.runtime.BatchOperation<T> operation)
io.micronaut.data.operations.reactive.ReactiveRepositoryOperations	reactive()
protected int	shiftIndex(int i)
<T> T	update(io.micronaut.data.model.runtime.UpdateOperation<T> operation)
<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.
<T> reactor.core.publisher.Flux<T>	withTransaction(io.micronaut.transaction.TransactionDefinition definition, io.micronaut.transaction.reactive.ReactiveTransactionOperations.TransactionalCallback<io.r2dbc.spi.Connection,T> handler)

Methods inherited from class io.micronaut.data.jdbc.operations.AbstractSqlRepositoryOperations

getEntity, getIdReader, isSqlServerWithoutOrderBy, prepareStatement, resolveAssociationInsert, resolveEntityInsert, resolveEntityUpdate, resolveInsert, setInsertParameters, setStatementParameter, sizeOf, sortById

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.operations.RepositoryOperations

executeDelete, getEntity, getQueryHints

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
                                                     io.micronaut.data.runtime.date.DateTimeProvider<?> dateTimeProvider,
                                                     io.micronaut.context.ApplicationContext applicationContext)

Default constructor.

Parameters:

dataSourceName - The data source name

connectionFactory - The associated connection factory

mediaTypeCodecList - The media type codec list

dateTimeProvider - The date time provider

applicationContext - The bean context

Method Detail

shiftIndex

protected int shiftIndex(int i)

Overrides:

shiftIndex in class io.micronaut.data.jdbc.operations.AbstractSqlRepositoryOperations<io.r2dbc.spi.Row,io.r2dbc.spi.Statement>

reactive

@NonNull
public io.micronaut.data.operations.reactive.ReactiveRepositoryOperations reactive()

Specified by:

reactive in interface io.micronaut.data.operations.reactive.ReactiveCapableRepository

findOne

@Nullable
public <T,R> R findOne(@NonNull
                                 io.micronaut.data.model.runtime.PreparedQuery<T,R> preparedQuery)

Specified by:

findOne in interface io.micronaut.data.operations.RepositoryOperations

findAll

@NonNull
public <T,R> java.lang.Iterable<R> findAll(@NonNull
                                                    io.micronaut.data.model.runtime.PreparedQuery<T,R> preparedQuery)

Specified by:

findAll in interface io.micronaut.data.operations.RepositoryOperations

findStream

@NonNull
public <T,R> java.util.stream.Stream<R> findStream(@NonNull
                                                            io.micronaut.data.model.runtime.PreparedQuery<T,R> preparedQuery)

Specified by:

findStream in interface io.micronaut.data.operations.RepositoryOperations

persist

@NonNull
public <T> T persist(@NonNull
                              io.micronaut.data.model.runtime.InsertOperation<T> operation)

Specified by:

persist in interface io.micronaut.data.operations.RepositoryOperations

update

@NonNull
public <T> T update(@NonNull
                             io.micronaut.data.model.runtime.UpdateOperation<T> operation)

Specified by:

update in interface io.micronaut.data.operations.RepositoryOperations

persistAll

@NonNull
public <T> java.lang.Iterable<T> persistAll(@NonNull
                                                     io.micronaut.data.model.runtime.BatchOperation<T> operation)

Specified by:

persistAll in interface io.micronaut.data.operations.RepositoryOperations

executeUpdate

@NonNull
public java.util.Optional<java.lang.Number> executeUpdate(@NonNull
                                                                   io.micronaut.data.model.runtime.PreparedQuery<?,java.lang.Number> preparedQuery)

Specified by:

executeUpdate in interface io.micronaut.data.operations.RepositoryOperations

deleteAll

public <T> java.util.Optional<java.lang.Number> deleteAll(@NonNull
                                                          io.micronaut.data.model.runtime.BatchOperation<T> operation)

Specified by:

deleteAll in interface io.micronaut.data.operations.RepositoryOperations

exists

public <T> boolean exists(@NonNull
                          io.micronaut.data.model.runtime.PreparedQuery<T,java.lang.Boolean> preparedQuery)

Specified by:

exists in interface io.micronaut.data.operations.RepositoryOperations

findPage

public <R> io.micronaut.data.model.Page<R> findPage(@NonNull
                                                    io.micronaut.data.model.runtime.PagedQuery<R> query)

Specified by:

findPage in interface io.micronaut.data.operations.RepositoryOperations

findOne

@Nullable
public <T> T findOne(@NonNull
                               java.lang.Class<T> type,
                               @NonNull
                               java.io.Serializable id)

Specified by:

findOne in interface io.micronaut.data.operations.RepositoryOperations

findAll

@NonNull
public <T> java.lang.Iterable<T> findAll(@NonNull
                                                  io.micronaut.data.model.runtime.PagedQuery<T> query)

Specified by:

findAll in interface io.micronaut.data.operations.RepositoryOperations

count

public <T> long count(io.micronaut.data.model.runtime.PagedQuery<T> pagedQuery)

Specified by:

count in interface io.micronaut.data.operations.RepositoryOperations

findStream

@NonNull
public <T> java.util.stream.Stream<T> findStream(@NonNull
                                                          io.micronaut.data.model.runtime.PagedQuery<T> query)

Specified by:

findStream in interface io.micronaut.data.operations.RepositoryOperations

async

@NonNull
public io.micronaut.data.operations.async.AsyncRepositoryOperations async()

Specified by:

async in interface io.micronaut.data.operations.async.AsyncCapableRepository

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
                                                                     io.micronaut.transaction.reactive.ReactiveTransactionStatus<io.r2dbc.spi.Connection> status,
                                                                     @NonNull
                                                                     io.micronaut.transaction.reactive.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
                                                                   io.micronaut.transaction.TransactionDefinition definition,
                                                                   @NonNull
                                                                   io.micronaut.transaction.reactive.ReactiveTransactionOperations.TransactionalCallback<io.r2dbc.spi.Connection,T> handler)

Specified by:

withTransaction in interface io.micronaut.transaction.reactive.ReactiveTransactionOperations<io.r2dbc.spi.Connection>