io.micronaut.data.runtime.operations.internal

Class AbstractSqlRepositoryOperations<Cnt,RS,PS,Exc extends java.lang.Exception>

java.lang.Object

io.micronaut.data.runtime.operations.internal.AbstractRepositoryOperations<Cnt,PS>

io.micronaut.data.runtime.operations.internal.AbstractSqlRepositoryOperations<Cnt,RS,PS,Exc>

Type Parameters:

Cnt - The connection type

RS - The result set type

PS - The prepared statement type

Exc - The exception type

All Implemented Interfaces:

io.micronaut.context.ApplicationContextProvider, OpContext<Cnt,PS>

Direct Known Subclasses:

DefaultJdbcRepositoryOperations

@Internal
public abstract class AbstractSqlRepositoryOperations<Cnt,RS,PS,Exc extends java.lang.Exception>
extends AbstractRepositoryOperations<Cnt,PS>
implements io.micronaut.context.ApplicationContextProvider, OpContext<Cnt,PS>

Abstract SQL repository implementation not specifically bound to JDBC.

Since:

1.0.0

Author:

graemerocher, Denis Stepanov

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static interface	AbstractSqlRepositoryOperations.StatementSupplier<PS> Functional interface used to supply a statement.

Field Summary

Fields

Modifier and Type	Field and Description
protected ResultReader<RS,java.lang.Integer>	columnIndexResultSetReader
protected ResultReader<RS,java.lang.String>	columnNameResultSetReader
protected static SqlQueryBuilder	DEFAULT_SQL_BUILDER
protected QueryStatement<PS,java.lang.Integer>	preparedStatementWriter
protected static org.slf4j.Logger	QUERY_LOG
protected java.util.Map<java.lang.Class,SqlQueryBuilder>	queryBuilders

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

attributeConverterRegistry, conversionService, dateTimeProvider, entityEventRegistry, jsonCodec, runtimeEntityRegistry

Constructor Summary

Constructors

Modifier

Constructor and Description

protected

AbstractSqlRepositoryOperations(java.lang.String dataSourceName, ResultReader<RS,java.lang.String> columnNameResultSetReader, ResultReader<RS,java.lang.Integer> columnIndexResultSetReader, QueryStatement<PS,java.lang.Integer> preparedStatementWriter, java.util.List<io.micronaut.http.codec.MediaTypeCodec> codecs, DateTimeProvider<java.lang.Object> dateTimeProvider, RuntimeEntityRegistry runtimeEntityRegistry, io.micronaut.context.BeanContext beanContext, DataConversionService<?> conversionService, AttributeConverterRegistry attributeConverterRegistry) Default constructor.

Method Summary

Modifier and Type	Method and Description
protected boolean	isSupportsBatchDelete(PersistentEntity persistentEntity, Dialect dialect) Does supports batch for delete queries.
protected boolean	isSupportsBatchInsert(PersistentEntity persistentEntity, Dialect dialect) Does supports batch for update queries.
protected boolean	isSupportsBatchUpdate(PersistentEntity persistentEntity, Dialect dialect) Does supports batch for update queries.
protected <T,R> PS	prepareStatement(Cnt connection, AbstractSqlRepositoryOperations.StatementSupplier<PS> statementFunction, PreparedQuery<T,R> preparedQuery, boolean isUpdate, boolean isSingleResult) Prepare a statement for execution.
protected <T> java.lang.String	resolveAssociationInsert(java.lang.Class repositoryType, RuntimePersistentEntity<T> persistentEntity, RuntimeAssociation<T> association) Builds a join table insert.
protected DBOperation	resolveEntityInsert(io.micronaut.core.annotation.AnnotationMetadata annotationMetadata, java.lang.Class<?> repositoryType, java.lang.Class<?> rootEntity, RuntimePersistentEntity<?> persistentEntity) Resolves a stored insert for the given entity.
protected DBOperation	resolveEntityUpdate(io.micronaut.core.annotation.AnnotationMetadata annotationMetadata, java.lang.Class<?> repositoryType, java.lang.Class<?> rootEntity, RuntimePersistentEntity<?> persistentEntity) Resolves a stored update for the given entity.
protected <T> DBOperation	resolveSqlInsertAssociation(java.lang.Class<?> repositoryType, Dialect dialect, RuntimeAssociation<T> association, RuntimePersistentEntity<T> persistentEntity, T entity) Resolve SQL insert association operation.
void	setStatementParameter(PS preparedStatement, int index, DataType dataType, java.lang.Object value, Dialect dialect) Set the parameter value on the given statement.

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

checkOptimisticLocking, convert, convert, createTypeConversionContext, getApplicationContext, getEntity, getIdReader, getRuntimeEntityRegistry, isOnlySingleEndedJoins, shiftIndex, 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.data.runtime.operations.internal.OpContext

convert, convert, getEntity, getRuntimeEntityRegistry, shiftIndex

Field Detail

QUERY_LOG

protected static final org.slf4j.Logger QUERY_LOG

DEFAULT_SQL_BUILDER

protected static final SqlQueryBuilder DEFAULT_SQL_BUILDER

columnNameResultSetReader

protected final ResultReader<RS,java.lang.String> columnNameResultSetReader

columnIndexResultSetReader

protected final ResultReader<RS,java.lang.Integer> columnIndexResultSetReader

preparedStatementWriter

protected final QueryStatement<PS,java.lang.Integer> preparedStatementWriter

queryBuilders

protected final java.util.Map<java.lang.Class,SqlQueryBuilder> queryBuilders

Constructor Detail

AbstractSqlRepositoryOperations

protected AbstractSqlRepositoryOperations(java.lang.String dataSourceName,
                                          ResultReader<RS,java.lang.String> columnNameResultSetReader,
                                          ResultReader<RS,java.lang.Integer> columnIndexResultSetReader,
                                          QueryStatement<PS,java.lang.Integer> preparedStatementWriter,
                                          java.util.List<io.micronaut.http.codec.MediaTypeCodec> codecs,
                                          DateTimeProvider<java.lang.Object> dateTimeProvider,
                                          RuntimeEntityRegistry runtimeEntityRegistry,
                                          io.micronaut.context.BeanContext beanContext,
                                          DataConversionService<?> conversionService,
                                          AttributeConverterRegistry attributeConverterRegistry)

Default constructor.

Parameters:

dataSourceName - The datasource name

columnNameResultSetReader - The column name result reader

columnIndexResultSetReader - The column index result reader

preparedStatementWriter - The prepared statement writer

codecs - The media type codecs

dateTimeProvider - The date time provider

runtimeEntityRegistry - The entity registry

beanContext - The bean context

conversionService - The conversion service

attributeConverterRegistry - The attribute converter registry

Method Detail

prepareStatement

protected <T,R> PS prepareStatement(Cnt connection,
                                    AbstractSqlRepositoryOperations.StatementSupplier<PS> statementFunction,
                                    @NonNull
                                    PreparedQuery<T,R> preparedQuery,
                                    boolean isUpdate,
                                    boolean isSingleResult)
                             throws Exc extends java.lang.Exception

Prepare a statement for execution.

Type Parameters:

T - The query declaring type

R - The query result type

Parameters:

connection - The connection

statementFunction - The statement function

preparedQuery - The prepared query

isUpdate - Is this an update

isSingleResult - Is it a single result

Returns:

The prepared statement

Throws:

Exc extends java.lang.Exception

setStatementParameter

public void setStatementParameter(PS preparedStatement,
                                  int index,
                                  DataType dataType,
                                  java.lang.Object value,
                                  Dialect dialect)

Set the parameter value on the given statement.

Specified by:

setStatementParameter in interface OpContext<Cnt,PS>

Parameters:

preparedStatement - The prepared statement

index - The index

dataType - The data type

value - The value

dialect - The dialect

resolveEntityInsert

@NonNull
protected DBOperation resolveEntityInsert(io.micronaut.core.annotation.AnnotationMetadata annotationMetadata,
                                                   java.lang.Class<?> repositoryType,
                                                   @NonNull
                                                   java.lang.Class<?> rootEntity,
                                                   @NonNull
                                                   RuntimePersistentEntity<?> persistentEntity)

Resolves a stored insert for the given entity.

Parameters:

annotationMetadata - The repository annotation metadata

repositoryType - The repository type

rootEntity - The root entity

persistentEntity - The persistent entity

Returns:

The insert

resolveAssociationInsert

protected <T> java.lang.String resolveAssociationInsert(java.lang.Class repositoryType,
                                                        RuntimePersistentEntity<T> persistentEntity,
                                                        RuntimeAssociation<T> association)

Builds a join table insert.

Type Parameters:

T - The entity generic type

Parameters:

repositoryType - The repository type

persistentEntity - The entity

association - The association

Returns:

The insert statement

resolveEntityUpdate

@NonNull
protected DBOperation resolveEntityUpdate(io.micronaut.core.annotation.AnnotationMetadata annotationMetadata,
                                                   java.lang.Class<?> repositoryType,
                                                   @NonNull
                                                   java.lang.Class<?> rootEntity,
                                                   @NonNull
                                                   RuntimePersistentEntity<?> persistentEntity)

Resolves a stored update for the given entity.

Parameters:

annotationMetadata - The repository annotation metadata

repositoryType - The repository type

rootEntity - The root entity

persistentEntity - The persistent entity

Returns:

The insert

resolveSqlInsertAssociation

protected <T> DBOperation resolveSqlInsertAssociation(java.lang.Class<?> repositoryType,
                                                      Dialect dialect,
                                                      RuntimeAssociation<T> association,
                                                      RuntimePersistentEntity<T> persistentEntity,
                                                      T entity)

Resolve SQL insert association operation.

Type Parameters:

T - The entity type

Parameters:

repositoryType - The repository type

dialect - The dialect

association - The association

persistentEntity - The persistent entity

entity - The entity

Returns:

The operation

isSupportsBatchInsert

protected boolean isSupportsBatchInsert(PersistentEntity persistentEntity,
                                        Dialect dialect)

Does supports batch for update queries.

Parameters:

persistentEntity - The persistent entity

dialect - The dialect

Returns:

true if supported

isSupportsBatchUpdate

protected boolean isSupportsBatchUpdate(PersistentEntity persistentEntity,
                                        Dialect dialect)

Does supports batch for update queries.

Parameters:

persistentEntity - The persistent entity

dialect - The dialect

Returns:

true if supported

isSupportsBatchDelete

protected boolean isSupportsBatchDelete(PersistentEntity persistentEntity,
                                        Dialect dialect)

Does supports batch for delete queries.

Parameters:

persistentEntity - The persistent entity

dialect - The dialect

Returns:

true if supported