Package io.micronaut.data.jdbc.operations

Class DefaultJdbcRepositoryOperations

java.lang.Object

io.micronaut.data.runtime.operations.internal.AbstractRepositoryOperations

io.micronaut.data.runtime.operations.internal.sql.AbstractSqlRepositoryOperations<ResultSet,PreparedStatement,SQLException>

io.micronaut.data.jdbc.operations.DefaultJdbcRepositoryOperations

All Implemented Interfaces:

io.micronaut.context.ApplicationContextProvider, io.micronaut.core.convert.ConversionServiceProvider, JdbcRepositoryOperations, JdbcOperations, AsyncCapableRepository, HintsCapableRepository, ReactiveCapableRepository, RepositoryOperations, SyncCascadeOperations.SyncCascadeOperationsHelper<DefaultJdbcRepositoryOperations.JdbcOperationContext>, MethodContextAwareStoredQueryDecorator, PreparedQueryDecorator, AutoCloseable

@EachBean(javax.sql.DataSource.class)
@Internal
public final class DefaultJdbcRepositoryOperations
extends AbstractSqlRepositoryOperations<ResultSet,PreparedStatement,SQLException>
implements JdbcRepositoryOperations, AsyncCapableRepository, ReactiveCapableRepository, AutoCloseable, SyncCascadeOperations.SyncCascadeOperationsHelper<DefaultJdbcRepositoryOperations.JdbcOperationContext>

Implementation of JdbcRepositoryOperations.

Since:

1.0.0

Author:

graemerocher, Denis Stepanov

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static class	DefaultJdbcRepositoryOperations.JdbcOperationContext

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

AbstractSqlRepositoryOperations.StatementSupplier<PS>

Field Summary

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

columnIndexResultSetReader, columnNameResultSetReader, dataSourceName, jsonMapper, preparedStatementWriter, QUERY_LOG, queryBuilders, repositoriesWithHardcodedDataSource, sqlJsonColumnMapperProvider

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

attributeConverterRegistry, conversionService, dateTimeProvider, entityEventRegistry, runtimeEntityRegistry

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	DefaultJdbcRepositoryOperations(String dataSourceName, DataJdbcConfiguration jdbcConfiguration, DataSource dataSource, TransactionOperations<Connection> transactionOperations, ExecutorService executorService, io.micronaut.context.BeanContext beanContext, DateTimeProvider dateTimeProvider, RuntimeEntityRegistry entityRegistry, DataConversionService conversionService, AttributeConverterRegistry attributeConverterRegistry, SchemaTenantResolver schemaTenantResolver, JdbcSchemaHandler schemaHandler, io.micronaut.json.JsonMapper jsonMapper, SqlJsonColumnMapperProvider<ResultSet> sqlJsonColumnMapperProvider)	Default constructor.

Method Summary

Modifier and Type	Method	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> Optional<Number>	deleteAll(DeleteBatchOperation<T> operation)	Deletes all the entities of the given type.
<T> Stream<T>	entityStream(ResultSet resultSet, Class<T> rootEntity)	Map a result set to a stream of the given type.
<T> Stream<T>	entityStream(ResultSet resultSet, String prefix, 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.
Optional<Number>	executeUpdate(PreparedQuery<?,Number> pq)	Executes an update for the given query and parameter values.
<T> boolean	exists(PreparedQuery<T,Boolean> pq)	Execute a query that checks for existence.
<T> Iterable<T>	findAll(PagedQuery<T> query)	Finds all results for the given query.
<T, R> Iterable<R>	findAll(PreparedQuery<T,R> preparedQuery)	Finds all results for the given query.
<T, R> R	findOne(PreparedQuery<T,R> pq)	Find one by Query.
<T> T	findOne(Class<T> type, Serializable id)	Find one by ID.
<R> Page<R>	findPage(PagedQuery<R> query)	Find a page for the given entity and pageable.
<T> Stream<T>	findStream(PagedQuery<T> query)	Finds a stream for the given arguments.
<T, R> Stream<R>	findStream(PreparedQuery<T,R> preparedQuery)	Finds all results for the given query.
Connection	getConnection()	This method will return the currently active connection for the current transaction or throw an exception if no transaction is present.
DataSource	getDataSource()
boolean	isSupportsBatchInsert(DefaultJdbcRepositoryOperations.JdbcOperationContext jdbcOperationContext, RuntimePersistentEntity<?> persistentEntity)	Is supports batch insert.
<T> T	persist(InsertOperation<T> operation)	Persist the operation returning a possibly new entity.
<T> Iterable<T>	persistAll(InsertBatchOperation<T> operation)	Persist all the given entities.
<T> List<T>	persistBatch(DefaultJdbcRepositoryOperations.JdbcOperationContext ctx, Iterable<T> values, RuntimePersistentEntity<T> childPersistentEntity, Predicate<T> predicate)	Persist multiple entities in batch during cascade.
void	persistManyAssociation(DefaultJdbcRepositoryOperations.JdbcOperationContext ctx, RuntimeAssociation runtimeAssociation, Object value, RuntimePersistentEntity<Object> persistentEntity, Object child, RuntimePersistentEntity<Object> childPersistentEntity)	Persist JOIN table relationship.
void	persistManyAssociationBatch(DefaultJdbcRepositoryOperations.JdbcOperationContext ctx, RuntimeAssociation runtimeAssociation, Object value, RuntimePersistentEntity<Object> persistentEntity, Iterable<Object> child, RuntimePersistentEntity<Object> childPersistentEntity)	Persist JOIN table relationships in batch.
<T> T	persistOne(DefaultJdbcRepositoryOperations.JdbcOperationContext ctx, T value, RuntimePersistentEntity<T> persistentEntity)	Persist one entity during cascade.
<R> R	prepareStatement(String sql, PreparedStatementCallback<R> callback)	Execute the given operation with the given callback.
ReactiveRepositoryOperations	reactive()
<E, D> D	readDTO(String prefix, ResultSet resultSet, Class<E> rootEntity, Class<D> dtoType)	Read an entity using the given prefix to be passes to result set lookups.
<E> E	readEntity(String prefix, ResultSet resultSet, 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.
<T> Iterable<T>	updateAll(UpdateBatchOperation<T> operation)	Updates the entities for the given operation.
<T> T	updateOne(DefaultJdbcRepositoryOperations.JdbcOperationContext ctx, T value, RuntimePersistentEntity<T> persistentEntity)	Update one entity during cascade.

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

createQueryResultMapper, decorate, decorate, getJsonColumn, getJsonDataType, getSqlPreparedQuery, getSqlStoredQuery, handleSqlException, isJsonEntityGeneratedId, isJsonResult, isSupportsBatchDelete, isSupportsBatchInsert, isSupportsBatchUpdate, mapQueryColumnResult, prepareStatement, resolveAssociationInsert, resolveEntityInsert, resolveEntityUpdate, resolveSqlInsertAssociation, setStatementParameter

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

checkOptimisticLocking, getApplicationContext, getConversionService, getEntity, getIdReader, isOnlySingleEndedJoins, triggerPostLoad

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.micronaut.context.ApplicationContextProvider

getApplicationContext

Methods inherited from interface io.micronaut.core.convert.ConversionServiceProvider

getConversionService

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

getQueryHints

Methods inherited from interface io.micronaut.data.jdbc.runtime.JdbcOperations

readDTO, readEntity

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

executeDelete, getEntity

Methods inherited from interface io.micronaut.data.runtime.operations.internal.SyncCascadeOperations.SyncCascadeOperationsHelper

isSupportsBatchDelete, isSupportsBatchUpdate

Constructor Details

DefaultJdbcRepositoryOperations

@Internal
protected DefaultJdbcRepositoryOperations(@Parameter
 String dataSourceName,
 @Parameter
 DataJdbcConfiguration jdbcConfiguration,
 DataSource dataSource,
 @Parameter
 TransactionOperations<Connection> transactionOperations,
 @Named("io") @Nullable
 ExecutorService executorService,
 io.micronaut.context.BeanContext beanContext,
 @NonNull
 DateTimeProvider dateTimeProvider,
 RuntimeEntityRegistry entityRegistry,
 DataConversionService conversionService,
 AttributeConverterRegistry attributeConverterRegistry,
 @Nullable
 SchemaTenantResolver schemaTenantResolver,
 JdbcSchemaHandler schemaHandler,
 @Nullable
 io.micronaut.json.JsonMapper jsonMapper,
 SqlJsonColumnMapperProvider<ResultSet> sqlJsonColumnMapperProvider)

Default constructor.

Parameters:

dataSourceName - The data source name

jdbcConfiguration - The jdbcConfiguration

dataSource - The datasource

transactionOperations - The JDBC operations for the data source

executorService - The executor service

beanContext - The bean context

dateTimeProvider - The dateTimeProvider

entityRegistry - The entity registry

conversionService - The conversion service

attributeConverterRegistry - The attribute converter registry

schemaTenantResolver - The schema tenant resolver

schemaHandler - The schema handler

jsonMapper - The JSON mapper

sqlJsonColumnMapperProvider - The SQL JSON column mapper provider

Method Details

persistOne

public <T> T persistOne(DefaultJdbcRepositoryOperations.JdbcOperationContext ctx,
 T value,
 RuntimePersistentEntity<T> persistentEntity)

Description copied from interface: SyncCascadeOperations.SyncCascadeOperationsHelper

Persist one entity during cascade.

Specified by:

persistOne in interface SyncCascadeOperations.SyncCascadeOperationsHelper<DefaultJdbcRepositoryOperations.JdbcOperationContext>

Type Parameters:

T - The entity type

Parameters:

ctx - The context

value - The entity value

persistentEntity - The persistent entity

Returns:

The entity value

persistBatch

public <T> List<T> persistBatch(DefaultJdbcRepositoryOperations.JdbcOperationContext ctx,
 Iterable<T> values,
 RuntimePersistentEntity<T> childPersistentEntity,
 Predicate<T> predicate)

Description copied from interface: SyncCascadeOperations.SyncCascadeOperationsHelper

Persist multiple entities in batch during cascade.

Specified by:

persistBatch in interface SyncCascadeOperations.SyncCascadeOperationsHelper<DefaultJdbcRepositoryOperations.JdbcOperationContext>

Type Parameters:

T - The entity type

Parameters:

ctx - The context

values - The entity values

childPersistentEntity - The persistent entity

predicate - The veto predicate

Returns:

The entity values

updateOne

public <T> T updateOne(DefaultJdbcRepositoryOperations.JdbcOperationContext ctx,
 T value,
 RuntimePersistentEntity<T> persistentEntity)

Description copied from interface: SyncCascadeOperations.SyncCascadeOperationsHelper

Update one entity during cascade.

Specified by:

updateOne in interface SyncCascadeOperations.SyncCascadeOperationsHelper<DefaultJdbcRepositoryOperations.JdbcOperationContext>

Type Parameters:

T - The entity type

Parameters:

ctx - The context

value - The entity value

persistentEntity - The persistent entity

Returns:

The entity value

persistManyAssociation

public void persistManyAssociation(DefaultJdbcRepositoryOperations.JdbcOperationContext ctx,
 RuntimeAssociation runtimeAssociation,
 Object value,
 RuntimePersistentEntity<Object> persistentEntity,
 Object child,
 RuntimePersistentEntity<Object> childPersistentEntity)

Description copied from interface: SyncCascadeOperations.SyncCascadeOperationsHelper

Persist JOIN table relationship.

Specified by:

persistManyAssociation in interface SyncCascadeOperations.SyncCascadeOperationsHelper<DefaultJdbcRepositoryOperations.JdbcOperationContext>

Parameters:

ctx - The context

runtimeAssociation - The association

value - The parent entity value

persistentEntity - The parent persistent entity

child - The child entity value

childPersistentEntity - The child persistent entity

persistManyAssociationBatch

public void persistManyAssociationBatch(DefaultJdbcRepositoryOperations.JdbcOperationContext ctx,
 RuntimeAssociation runtimeAssociation,
 Object value,
 RuntimePersistentEntity<Object> persistentEntity,
 Iterable<Object> child,
 RuntimePersistentEntity<Object> childPersistentEntity)

Description copied from interface: SyncCascadeOperations.SyncCascadeOperationsHelper

Persist JOIN table relationships in batch.

Specified by:

persistManyAssociationBatch in interface SyncCascadeOperations.SyncCascadeOperationsHelper<DefaultJdbcRepositoryOperations.JdbcOperationContext>

Parameters:

ctx - The context

runtimeAssociation - The association

value - The parent entity value

persistentEntity - The parent persistent entity

child - The child entity values

childPersistentEntity - The child persistent entity

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> pq)

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:

pq - The prepared query

Returns:

A result or null

exists

public <T> boolean exists(@NonNull
 PreparedQuery<T,Boolean> pq)

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:

pq - The prepared query

Returns:

A result or null

findStream

@NonNull
public <T,
R> 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> 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 Optional<Number> executeUpdate(@NonNull
 PreparedQuery<?,Number> pq)

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:

pq - The prepared query

Returns:

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

deleteAll

public <T> Optional<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

updateAll

@NonNull
public <T> Iterable<T> updateAll(@NonNull
 UpdateBatchOperation<T> operation)

Description copied from interface: RepositoryOperations

Updates the entities for the given operation.

Specified by:

updateAll in interface RepositoryOperations

Type Parameters:

T - The generic type

Parameters:

operation - The operation

Returns:

The updated entities

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
 Class<T> type,
 @NonNull
 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> 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> 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> 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 AutoCloseable

getDataSource

@NonNull
public DataSource getDataSource()

Specified by:

getDataSource in interface JdbcOperations

Returns:

The backing data source.

getConnection

@NonNull
public 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
 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> Stream<T> entityStream(@NonNull
 ResultSet resultSet,
 @NonNull
 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
 String prefix,
 @NonNull
 ResultSet resultSet,
 @NonNull
 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
 String prefix,
 @NonNull
 ResultSet resultSet,
 @NonNull
 Class<E> rootEntity,
 @NonNull
 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> Stream<T> entityStream(@NonNull
 ResultSet resultSet,
 @Nullable
 String prefix,
 @NonNull
 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

isSupportsBatchInsert

public boolean isSupportsBatchInsert(DefaultJdbcRepositoryOperations.JdbcOperationContext jdbcOperationContext,
 RuntimePersistentEntity<?> persistentEntity)

Description copied from interface: SyncCascadeOperations.SyncCascadeOperationsHelper

Is supports batch insert.

Specified by:

isSupportsBatchInsert in interface SyncCascadeOperations.SyncCascadeOperationsHelper<DefaultJdbcRepositoryOperations.JdbcOperationContext>

Parameters:

jdbcOperationContext - The context

persistentEntity - The persistent entity

Returns:

True if supports