io.micronaut.data.jdbc.operations

Class DefaultJdbcRepositoryOperations

java.lang.Object

io.micronaut.data.jdbc.operations.AbstractSqlRepositoryOperations<java.sql.ResultSet,java.sql.PreparedStatement>

io.micronaut.data.jdbc.operations.DefaultJdbcRepositoryOperations

All Implemented Interfaces:

JdbcRepositoryOperations, JdbcOperations, AsyncCapableRepository, ReactiveCapableRepository, RepositoryOperations, java.lang.AutoCloseable

@EachBean(value=javax.sql.DataSource.class)
public class DefaultJdbcRepositoryOperations
extends AbstractSqlRepositoryOperations<java.sql.ResultSet,java.sql.PreparedStatement>
implements JdbcRepositoryOperations, AsyncCapableRepository, ReactiveCapableRepository, java.lang.AutoCloseable

Implementation of JdbcRepositoryOperations.

Since:

1.0.0

Author:

graemerocher

Nested Class Summary

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

AbstractSqlRepositoryOperations.StatementSupplier<PS>, AbstractSqlRepositoryOperations.StoredInsert<T>

Field Summary

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

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

Constructor Summary

Constructors

Modifier

Constructor and Description

protected

DefaultJdbcRepositoryOperations(java.lang.String dataSourceName, javax.sql.DataSource dataSource, TransactionOperations<java.sql.Connection> transactionOperations, java.util.concurrent.ExecutorService executorService, io.micronaut.context.BeanContext beanContext, java.util.List<io.micronaut.http.codec.MediaTypeCodec> codecs, DateTimeProvider dateTimeProvider, RuntimeEntityRegistry entityRegistry) Default constructor.

Method Summary

Modifier and Type	Method and Description
ExecutorAsyncOperations	async()
void	close()
<T> long	count(PagedQuery<T> pagedQuery) Counts all results for the given query.
<T> int	delete(DeleteOperation<T> operation) Deletes the entity.
<T> java.util.Optional<java.lang.Number>	deleteAll(DeleteBatchOperation<T> operation) Deletes all the entities of the given type.
<T> java.util.stream.Stream<T>	entityStream(java.sql.ResultSet resultSet, java.lang.Class<T> rootEntity) Map a result set to a stream of the given type.
<T> java.util.stream.Stream<T>	entityStream(java.sql.ResultSet resultSet, java.lang.String prefix, java.lang.Class<T> rootEntity) Map a result set to a stream of the given type.
<R> R	execute(ConnectionCallback<R> callback) Execute the given operation with the given callback.
java.util.Optional<java.lang.Number>	executeUpdate(PreparedQuery<?,java.lang.Number> preparedQuery) Executes an update for the given query and parameter values.
<T> boolean	exists(PreparedQuery<T,java.lang.Boolean> preparedQuery) Execute a query that checks for existence.
<T> java.lang.Iterable<T>	findAll(PagedQuery<T> query) Finds all results for the given query.
<T,R> java.lang.Iterable<R>	findAll(PreparedQuery<T,R> preparedQuery) Finds all results for the given query.
<T> T	findOne(java.lang.Class<T> type, java.io.Serializable id) Find one by ID.
<T,R> R	findOne(PreparedQuery<T,R> preparedQuery) Find one by Query.
<R> Page<R>	findPage(PagedQuery<R> query) Find a page for the given entity and pageable.
<T> java.util.stream.Stream<T>	findStream(PagedQuery<T> query) Finds a stream for the given arguments.
<T,R> java.util.stream.Stream<R>	findStream(PreparedQuery<T,R> preparedQuery) Finds all results for the given query.
java.sql.Connection	getConnection() This method will return the currently active connection for the current transaction or throw an exception if no transaction is present.
javax.sql.DataSource	getDataSource()
<T> T	persist(InsertOperation<T> operation) Persist the operation returning a possibly new entity.
<T> java.lang.Iterable<T>	persistAll(InsertBatchOperation<T> operation) Persist all the given entities.
<R> R	prepareStatement(java.lang.String sql, PreparedStatementCallback<R> callback) Execute the given operation with the given callback.
ReactiveRepositoryOperations	reactive()
<E,D> D	readDTO(java.lang.String prefix, java.sql.ResultSet resultSet, java.lang.Class<E> rootEntity, java.lang.Class<D> dtoType) Read an entity using the given prefix to be passes to result set lookups.
<E> E	readEntity(java.lang.String prefix, java.sql.ResultSet resultSet, java.lang.Class<E> type) Read an entity using the given prefix to be passes to result set lookups.
<T> T	update(UpdateOperation<T> operation) Updates the entity for the given operation.

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

getEntity, getIdReader, isSqlServerWithoutOrderBy, prepareStatement, resolveAssociationInsert, resolveEntityInsert, resolveEntityUpdate, resolveInsert, setInsertParameters, setStatementParameter, shiftIndex, sizeOf, sortById, triggerPostLoad, triggerPostPersist, triggerPostRemove, triggerPostUpdate, triggerPrePersist, triggerPreRemove, triggerPreUpdate

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.jdbc.runtime.JdbcOperations

readDTO, readEntity

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

executeDelete, getEntity, getQueryHints

Constructor Detail

DefaultJdbcRepositoryOperations

@Internal
protected DefaultJdbcRepositoryOperations(@Parameter
                                                    java.lang.String dataSourceName,
                                                    javax.sql.DataSource dataSource,
                                                    @Parameter
                                                    TransactionOperations<java.sql.Connection> transactionOperations,
                                                    @Named(value="io") @Nullable
                                                    java.util.concurrent.ExecutorService executorService,
                                                    io.micronaut.context.BeanContext beanContext,
                                                    java.util.List<io.micronaut.http.codec.MediaTypeCodec> codecs,
                                                    @NonNull
                                                    DateTimeProvider dateTimeProvider,
                                                    RuntimeEntityRegistry entityRegistry)

Default constructor.

Parameters:

dataSourceName - The data source name

dataSource - The datasource

transactionOperations - The JDBC operations for the data source

executorService - The executor service

beanContext - The bean context

codecs - The codecs

dateTimeProvider - The dateTimeProvider

entityRegistry - The entity registry

Method Detail

async

@NonNull
public ExecutorAsyncOperations async()

Specified by:

async in interface AsyncCapableRepository

Returns:

The async operations.

reactive

@NonNull
public ReactiveRepositoryOperations reactive()

Specified by:

reactive in interface ReactiveCapableRepository

Returns:

The reactive operations instance.

findOne

@Nullable
public <T,R> R findOne(@NonNull
                                 PreparedQuery<T,R> preparedQuery)

Description copied from interface: RepositoryOperations

Find one by Query.

Specified by:

findOne in interface RepositoryOperations

Type Parameters:

T - The generic resultType

R - The result type

Parameters:

preparedQuery - The prepared query

Returns:

A result or null

exists

public <T> boolean exists(@NonNull
                          PreparedQuery<T,java.lang.Boolean> preparedQuery)

Description copied from interface: RepositoryOperations

Execute a query that checks for existence.

Specified by:

exists in interface RepositoryOperations

Type Parameters:

T - The generic resultType

Parameters:

preparedQuery - The prepared query

Returns:

A result or null

findStream

@NonNull
public <T,R> java.util.stream.Stream<R> findStream(@NonNull
                                                            PreparedQuery<T,R> preparedQuery)

Description copied from interface: RepositoryOperations

Finds all results for the given query.

Specified by:

findStream in interface RepositoryOperations

Type Parameters:

T - The entity type

R - The result type

Parameters:

preparedQuery - The prepared query

Returns:

An iterable result

findAll

@NonNull
public <T,R> java.lang.Iterable<R> findAll(@NonNull
                                                    PreparedQuery<T,R> preparedQuery)

Description copied from interface: RepositoryOperations

Finds all results for the given query.

Specified by:

findAll in interface RepositoryOperations

Type Parameters:

T - The entity type

R - The result type

Parameters:

preparedQuery - The prepared query

Returns:

An iterable result

executeUpdate

@NonNull
public java.util.Optional<java.lang.Number> executeUpdate(@NonNull
                                                                   PreparedQuery<?,java.lang.Number> preparedQuery)

Description copied from interface: RepositoryOperations

Executes an update for the given query and parameter values. If it is possible to return the number of objects updated, then do so.

Specified by:

executeUpdate in interface RepositoryOperations

Parameters:

preparedQuery - The prepared query

Returns:

An optional number with the count of the number of records updated

deleteAll

public <T> java.util.Optional<java.lang.Number> deleteAll(@NonNull
                                                          DeleteBatchOperation<T> operation)

Description copied from interface: RepositoryOperations

Deletes all the entities of the given type.

Specified by:

deleteAll in interface RepositoryOperations

Type Parameters:

T - The generic type

Parameters:

operation - The operation

Returns:

The number of entities deleted

delete

public <T> int delete(@NonNull
                      DeleteOperation<T> operation)

Description copied from interface: RepositoryOperations

Deletes the entity.

Specified by:

delete in interface RepositoryOperations

Type Parameters:

T - The generic type

Parameters:

operation - The operation

Returns:

The number of entities deleted

update

@NonNull
public <T> T update(@NonNull
                             UpdateOperation<T> operation)

Description copied from interface: RepositoryOperations

Updates the entity for the given operation.

Specified by:

update in interface RepositoryOperations

Type Parameters:

T - The generic type

Parameters:

operation - The operation

Returns:

The operation

persist

@NonNull
public <T> T persist(@NonNull
                              InsertOperation<T> operation)

Description copied from interface: RepositoryOperations

Persist the operation returning a possibly new entity.

Specified by:

persist in interface RepositoryOperations

Type Parameters:

T - The generic type

Parameters:

operation - The operation

Returns:

The operation

findOne

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

Description copied from interface: RepositoryOperations

Find one by ID.

Specified by:

findOne in interface RepositoryOperations

Type Parameters:

T - The generic type

Parameters:

type - The type

id - The id

Returns:

A result or null

findAll

@NonNull
public <T> java.lang.Iterable<T> findAll(@NonNull
                                                  PagedQuery<T> query)

Description copied from interface: RepositoryOperations

Finds all results for the given query.

Specified by:

findAll in interface RepositoryOperations

Type Parameters:

T - The generic type

Parameters:

query - The root entity

Returns:

An iterable result

count

public <T> long count(PagedQuery<T> pagedQuery)

Description copied from interface: RepositoryOperations

Counts all results for the given query.

Specified by:

count in interface RepositoryOperations

Type Parameters:

T - The generic type

Parameters:

pagedQuery - The paged query

Returns:

An iterable result

findStream

@NonNull
public <T> java.util.stream.Stream<T> findStream(@NonNull
                                                          PagedQuery<T> query)

Description copied from interface: RepositoryOperations

Finds a stream for the given arguments.

Specified by:

findStream in interface RepositoryOperations

Type Parameters:

T - The generic type

Parameters:

query - The query

Returns:

The stream

findPage

public <R> Page<R> findPage(@NonNull
                            PagedQuery<R> query)

Description copied from interface: RepositoryOperations

Find a page for the given entity and pageable.

Specified by:

findPage in interface RepositoryOperations

Type Parameters:

R - The entity generic type

Parameters:

query - The query

Returns:

The page type

persistAll

@NonNull
public <T> java.lang.Iterable<T> persistAll(@NonNull
                                                     InsertBatchOperation<T> operation)

Description copied from interface: RepositoryOperations

Persist all the given entities.

Specified by:

persistAll in interface RepositoryOperations

Type Parameters:

T - The generic type

Parameters:

operation - The operation

Returns:

The entities, possibly mutated

close

@PreDestroy
public void close()

Specified by:

close in interface java.lang.AutoCloseable

getDataSource

@NonNull
public javax.sql.DataSource getDataSource()

Specified by:

getDataSource in interface JdbcOperations

Returns:

The backing data source.

getConnection

@NonNull
public java.sql.Connection getConnection()

Description copied from interface: JdbcOperations

This method will return the currently active connection for the current transaction or throw an exception if no transaction is present.

Specified by:

getConnection in interface JdbcOperations

Returns:

The current connection for the active transaction.

execute

@NonNull
public <R> R execute(@NonNull
                              ConnectionCallback<R> callback)

Description copied from interface: JdbcOperations

Execute the given operation with the given callback.

Specified by:

execute in interface JdbcOperations

Type Parameters:

R - The result type

Parameters:

callback - The callback

Returns:

The result

prepareStatement

@NonNull
public <R> R prepareStatement(@NonNull
                                       java.lang.String sql,
                                       @NonNull
                                       PreparedStatementCallback<R> callback)

Description copied from interface: JdbcOperations

Execute the given operation with the given callback.

Specified by:

prepareStatement in interface JdbcOperations

Type Parameters:

R - The result type

Parameters:

sql - The SQL

callback - The callback

Returns:

The result

entityStream

@NonNull
public <T> java.util.stream.Stream<T> entityStream(@NonNull
                                                            java.sql.ResultSet resultSet,
                                                            @NonNull
                                                            java.lang.Class<T> rootEntity)

Description copied from interface: JdbcOperations

Map a result set to a stream of the given type.

Specified by:

entityStream in interface JdbcOperations

Type Parameters:

T - The generic type

Parameters:

resultSet - The result set

rootEntity - The entity type

Returns:

The stream

readEntity

@NonNull
public <E> E readEntity(@NonNull
                                 java.lang.String prefix,
                                 @NonNull
                                 java.sql.ResultSet resultSet,
                                 @NonNull
                                 java.lang.Class<E> type)
                          throws DataAccessException

Description copied from interface: JdbcOperations

Read an entity using the given prefix to be passes to result set lookups.

Specified by:

readEntity in interface JdbcOperations

Type Parameters:

E - The entity generic type

Parameters:

prefix - The prefix

resultSet - The result set

type - The entity type

Returns:

The entity result

Throws:

DataAccessException - if it is not possible read the result from the result set.

readDTO

@NonNull
public <E,D> D readDTO(@NonNull
                                java.lang.String prefix,
                                @NonNull
                                java.sql.ResultSet resultSet,
                                @NonNull
                                java.lang.Class<E> rootEntity,
                                @NonNull
                                java.lang.Class<D> dtoType)
                         throws DataAccessException

Description copied from interface: JdbcOperations

Read an entity using the given prefix to be passes to result set lookups.

Specified by:

readDTO in interface JdbcOperations

Type Parameters:

E - The entity generic type

D - The DTO generic type

Parameters:

prefix - The prefix

resultSet - The result set

rootEntity - The entity type

dtoType - The DTO type. Must be annotated with Introspected

Returns:

The entity result

Throws:

DataAccessException - if it is not possible read the result from the result set.

entityStream

@NonNull
public <T> java.util.stream.Stream<T> entityStream(@NonNull
                                                            java.sql.ResultSet resultSet,
                                                            @Nullable
                                                            java.lang.String prefix,
                                                            @NonNull
                                                            java.lang.Class<T> rootEntity)

Description copied from interface: JdbcOperations

Map a result set to a stream of the given type.

Specified by:

entityStream in interface JdbcOperations

Type Parameters:

T - The generic type

Parameters:

resultSet - The result set

prefix - The prefix to use for each column name that is mapped

rootEntity - The entity type

Returns:

The stream