io.micronaut.data.jdbc.operations

Class AbstractSqlRepositoryOperations<RS,PS>

java.lang.Object

io.micronaut.data.jdbc.operations.AbstractSqlRepositoryOperations<RS,PS>

Type Parameters:

RS - The result set type

PS - The prepared statement type

All Implemented Interfaces:

RepositoryOperations

Direct Known Subclasses:

DefaultJdbcRepositoryOperations

public abstract class AbstractSqlRepositoryOperations<RS,PS>
extends java.lang.Object
implements RepositoryOperations

Abstract SQL repository implementation not specifically bound to JDBC.

Since:

1.0.0

Author:

graemerocher

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	AbstractSqlRepositoryOperations.StoredInsert<T> A stored insert 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 DateTimeProvider	dateTimeProvider
protected static SqlQueryBuilder	DEFAULT_SQL_BUILDER
protected java.util.Map<java.lang.Class,Dialect>	dialects
protected static java.util.regex.Pattern	IN_EXPRESSION_PATTERN
protected io.micronaut.http.codec.MediaTypeCodec	jsonCodec
protected static java.lang.String	NOT_TRUE_EXPRESSION
protected QueryStatement<PS,java.lang.Integer>	preparedStatementWriter
protected static org.slf4j.Logger	QUERY_LOG
protected java.util.Map<Dialect,SqlQueryBuilder>	queryBuilders

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractSqlRepositoryOperations(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 dateTimeProvider) Default constructor.

Method Summary

Modifier and Type	Method and Description
<T> RuntimePersistentEntity<T>	getEntity(java.lang.Class<T> type) Retrieves the entity for the given type.
protected RuntimePersistentProperty<java.lang.Object>	getIdReader(java.lang.Object o) Obtain an ID reader for the given object.
protected boolean	isSqlServerWithoutOrderBy(java.lang.String query, Dialect dialect) In the dialect SQL server and is order by required.
protected <T> java.lang.String	resolveAssociationInsert(java.lang.Class repositoryType, RuntimePersistentEntity<T> persistentEntity, RuntimeAssociation<T> association) Builds a join table insert.
protected <T> AbstractSqlRepositoryOperations.StoredInsert<T>	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 <T> AbstractSqlRepositoryOperations.StoredInsert<T>	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> AbstractSqlRepositoryOperations.StoredInsert	resolveInsert(EntityOperation<T> operation) Resolve the INSERT for the given EntityOperation.
protected <T> void	setInsertParameters(AbstractSqlRepositoryOperations.StoredInsert<T> insert, T entity, PS stmt) Sets the insert parameters for the given insert, entity and statement.
protected void	setStatementParameter(PS preparedStatement, int index, DataType dataType, java.lang.Object value) Set the parameter value on the given statement.
protected int	sizeOf(java.lang.Object value) Compute the size of the given object.
protected <T> Sort	sortById(RuntimePersistentEntity<T> persistentEntity) Build a sort for ID for the given entity.

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

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

Field Detail

QUERY_LOG

protected static final org.slf4j.Logger QUERY_LOG

DEFAULT_SQL_BUILDER

protected static final SqlQueryBuilder DEFAULT_SQL_BUILDER

IN_EXPRESSION_PATTERN

protected static final java.util.regex.Pattern IN_EXPRESSION_PATTERN

NOT_TRUE_EXPRESSION

protected static final java.lang.String NOT_TRUE_EXPRESSION

See Also:

Constant Field Values

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

dialects

protected final java.util.Map<java.lang.Class,Dialect> dialects

queryBuilders

protected final java.util.Map<Dialect,SqlQueryBuilder> queryBuilders

jsonCodec

protected final io.micronaut.http.codec.MediaTypeCodec jsonCodec

dateTimeProvider

protected final DateTimeProvider dateTimeProvider

Constructor Detail

AbstractSqlRepositoryOperations

protected AbstractSqlRepositoryOperations(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,
                                          @NonNull
                                          DateTimeProvider dateTimeProvider)

Default constructor.

Parameters:

columnNameResultSetReader - The column name result reader

columnIndexResultSetReader - The column index result reader

preparedStatementWriter - The prepared statement writer

codecs - The media type codecs

dateTimeProvider - The injected dateTimeProvider instance

Method Detail

getEntity

@NonNull
public final <T> RuntimePersistentEntity<T> getEntity(@NonNull
                                                               java.lang.Class<T> type)

Description copied from interface: RepositoryOperations

Retrieves the entity for the given type.

Specified by:

getEntity in interface RepositoryOperations

Type Parameters:

T - The generic Type

Parameters:

type - The type

Returns:

The entity

setInsertParameters

protected final <T> void setInsertParameters(@NonNull
                                             AbstractSqlRepositoryOperations.StoredInsert<T> insert,
                                             @NonNull
                                             T entity,
                                             @NonNull
                                             PS stmt)

Sets the insert parameters for the given insert, entity and statement.

Type Parameters:

T - The entity type

Parameters:

insert - The insert

entity - The entity

stmt - The statement

resolveInsert

@NonNull
protected final <T> AbstractSqlRepositoryOperations.StoredInsert resolveInsert(@NonNull
                                                                                        EntityOperation<T> operation)

Resolve the INSERT for the given EntityOperation.

Type Parameters:

T - The entity type

Parameters:

operation - The operation

Returns:

The insert

getIdReader

@NonNull
protected final RuntimePersistentProperty<java.lang.Object> getIdReader(@NonNull
                                                                                 java.lang.Object o)

Obtain an ID reader for the given object.

Parameters:

o - The object

Returns:

The ID reader

sortById

@NonNull
protected final <T> Sort sortById(RuntimePersistentEntity<T> persistentEntity)

Build a sort for ID for the given entity.

Type Parameters:

T - The entity type

Parameters:

persistentEntity - The entity

Returns:

The sort

isSqlServerWithoutOrderBy

protected final boolean isSqlServerWithoutOrderBy(java.lang.String query,
                                                  Dialect dialect)

In the dialect SQL server and is order by required.

Parameters:

query - The query

dialect - The dialect

Returns:

True if it is

sizeOf

protected final int sizeOf(java.lang.Object value)

Compute the size of the given object.

Parameters:

value - The value

Returns:

The size

setStatementParameter

protected final void setStatementParameter(PS preparedStatement,
                                           int index,
                                           DataType dataType,
                                           java.lang.Object value)

Set the parameter value on the given statement.

Parameters:

preparedStatement - The prepared statement

index - The index

dataType - The data type

value - The value

resolveEntityInsert

@NonNull
protected <T> AbstractSqlRepositoryOperations.StoredInsert<T> 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.

Type Parameters:

T - The generic type

Parameters:

annotationMetadata - The repository annotation metadata

repositoryType - The repository type

rootEntity - The root entity

persistentEntity - The persistent entity

Returns:

The insert

resolveEntityUpdate

@NonNull
protected <T> AbstractSqlRepositoryOperations.StoredInsert<T> 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.

Type Parameters:

T - The generic type

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