io.micronaut.data.runtime.operations.internal

Class AbstractRepositoryOperations<Cnt,PS>

java.lang.Object

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

Type Parameters:

Cnt - The connection type

PS - The prepared statement

All Implemented Interfaces:

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

Direct Known Subclasses:

AbstractSqlRepositoryOperations, DefaultMongoRepositoryOperations, DefaultReactiveMongoRepositoryOperations

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

Abstract SQL repository implementation not specifically bound to JDBC.

Since:

3.1.0

Author:

Denis Stepanov

Field Summary

Fields

Modifier and Type	Field and Description
protected AttributeConverterRegistry	attributeConverterRegistry
protected DataConversionService<?>	conversionService
protected DateTimeProvider	dateTimeProvider
protected EntityEventListener<java.lang.Object>	entityEventRegistry
protected io.micronaut.http.codec.MediaTypeCodec	jsonCodec
protected RuntimeEntityRegistry	runtimeEntityRegistry

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractRepositoryOperations(java.util.List<io.micronaut.http.codec.MediaTypeCodec> codecs, DateTimeProvider<java.lang.Object> dateTimeProvider, RuntimeEntityRegistry runtimeEntityRegistry, DataConversionService<?> conversionService, AttributeConverterRegistry attributeConverterRegistry) Default constructor.

Method Summary

Modifier and Type	Method and Description
protected void	checkOptimisticLocking(int expected, int received) Compare the expected modifications and the received rows count.
java.lang.Object	convert(java.lang.Class<?> converterClass, Cnt connection, java.lang.Object value, io.micronaut.core.type.Argument<?> argument) Convert the property value if needed.
java.lang.Object	convert(Cnt connection, java.lang.Object value, RuntimePersistentProperty<?> property) Convert the property value if needed.
protected abstract io.micronaut.core.convert.ConversionContext	createTypeConversionContext(Cnt connection, RuntimePersistentProperty<?> property, io.micronaut.core.type.Argument<?> argument) Creates implementation specific conversion context.
io.micronaut.context.ApplicationContext	getApplicationContext()
DataConversionService<?>	getConversionService()
<T> RuntimePersistentEntity<T>	getEntity(java.lang.Class<T> type) Get persistent entity by type.
protected RuntimePersistentProperty<java.lang.Object>	getIdReader(java.lang.Object o) Obtain an ID reader for the given object.
RuntimeEntityRegistry	getRuntimeEntityRegistry() Get runtime entity registry.
protected boolean	isOnlySingleEndedJoins(RuntimePersistentEntity<?> rootPersistentEntity, java.util.Set<JoinPath> joinFetchPaths) Check if joined associated are all single ended (Can produce only one result).
int	shiftIndex(int i) Used to define the index whether it is 1 based (JDBC) or 0 based (R2DBC).
protected <T> T	triggerPostLoad(T entity, RuntimePersistentEntity<T> pe, io.micronaut.core.annotation.AnnotationMetadata annotationMetadata) Trigger the post load event.

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.runtime.operations.internal.OpContext

setStatementParameter

Field Detail

jsonCodec

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

entityEventRegistry

protected final EntityEventListener<java.lang.Object> entityEventRegistry

dateTimeProvider

protected final DateTimeProvider dateTimeProvider

runtimeEntityRegistry

protected final RuntimeEntityRegistry runtimeEntityRegistry

conversionService

protected final DataConversionService<?> conversionService

attributeConverterRegistry

protected final AttributeConverterRegistry attributeConverterRegistry

Constructor Detail

AbstractRepositoryOperations

protected AbstractRepositoryOperations(java.util.List<io.micronaut.http.codec.MediaTypeCodec> codecs,
                                       DateTimeProvider<java.lang.Object> dateTimeProvider,
                                       RuntimeEntityRegistry runtimeEntityRegistry,
                                       DataConversionService<?> conversionService,
                                       AttributeConverterRegistry attributeConverterRegistry)

Default constructor.

Parameters:

codecs - The media type codecs

dateTimeProvider - The date time provider

runtimeEntityRegistry - The entity registry

conversionService - The conversion service

attributeConverterRegistry - The attribute converter registry

Method Detail

getConversionService

public DataConversionService<?> getConversionService()

Returns:

the conversion service

getApplicationContext

public io.micronaut.context.ApplicationContext getApplicationContext()

Specified by:

getApplicationContext in interface io.micronaut.context.ApplicationContextProvider

getEntity

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

Description copied from interface: OpContext

Get persistent entity by type.

Specified by:

getEntity in interface OpContext<Cnt,PS>

Type Parameters:

T - The type

Parameters:

type - The type class

Returns:

persistent entity

getRuntimeEntityRegistry

public RuntimeEntityRegistry getRuntimeEntityRegistry()

Description copied from interface: OpContext

Get runtime entity registry.

Specified by:

getRuntimeEntityRegistry in interface OpContext<Cnt,PS>

Returns:

the registry

triggerPostLoad

protected <T> T triggerPostLoad(@NonNull
                                T entity,
                                RuntimePersistentEntity<T> pe,
                                io.micronaut.core.annotation.AnnotationMetadata annotationMetadata)

Trigger the post load event.

Type Parameters:

T - The generic type

Parameters:

entity - The entity

pe - The persistent entity

annotationMetadata - The annotation metadata

Returns:

The entity, possibly modified

shiftIndex

public int shiftIndex(int i)

Used to define the index whether it is 1 based (JDBC) or 0 based (R2DBC).

Specified by:

shiftIndex in interface OpContext<Cnt,PS>

Parameters:

i - The index to shift

Returns:

the index

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

checkOptimisticLocking

protected void checkOptimisticLocking(int expected,
                                      int received)

Compare the expected modifications and the received rows count. If not equals throw OptimisticLockException.

Parameters:

expected - The expected value

received - THe received value

isOnlySingleEndedJoins

protected boolean isOnlySingleEndedJoins(RuntimePersistentEntity<?> rootPersistentEntity,
                                         java.util.Set<JoinPath> joinFetchPaths)

Check if joined associated are all single ended (Can produce only one result).

Parameters:

rootPersistentEntity - The root entity

joinFetchPaths - The join paths

Returns:

true if there are no "many" joins

convert

public java.lang.Object convert(Cnt connection,
                                java.lang.Object value,
                                RuntimePersistentProperty<?> property)

Description copied from interface: OpContext

Convert the property value if needed.

Specified by:

convert in interface OpContext<Cnt,PS>

Parameters:

connection - the connection

Returns:

converter value

convert

public java.lang.Object convert(java.lang.Class<?> converterClass,
                                Cnt connection,
                                java.lang.Object value,
                                @Nullable
                                io.micronaut.core.type.Argument<?> argument)

Description copied from interface: OpContext

Convert the property value if needed.

Specified by:

convert in interface OpContext<Cnt,PS>

Parameters:

converterClass - the converter class

connection - the connection

value - the value

argument - the argument

Returns:

converter value

createTypeConversionContext

protected abstract io.micronaut.core.convert.ConversionContext createTypeConversionContext(Cnt connection,
                                                                                           @Nullable
                                                                                           RuntimePersistentProperty<?> property,
                                                                                           @Nullable
                                                                                           io.micronaut.core.type.Argument<?> argument)

Creates implementation specific conversion context.

Parameters:

connection - The connection

property - The property

argument - The argument

Returns:

new ConversionContext