Package io.micronaut.data.runtime.operations.internal

Class AbstractRepositoryOperations

java.lang.Object

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

All Implemented Interfaces:

io.micronaut.context.ApplicationContextProvider

Direct Known Subclasses:

AbstractSqlRepositoryOperations, DefaultMongoRepositoryOperations, DefaultReactiveCosmosRepositoryOperations, DefaultReactiveMongoRepositoryOperations

@Internal
public abstract class AbstractRepositoryOperations
extends Object
implements io.micronaut.context.ApplicationContextProvider

Abstract repository implementation.

Since:

3.1.0

Author:

Denis Stepanov

Field Summary

Fields

Modifier and Type	Field	Description
protected final AttributeConverterRegistry	attributeConverterRegistry
protected final DataConversionService	conversionService
protected final DateTimeProvider	dateTimeProvider
protected final EntityEventListener<Object>	entityEventRegistry
protected final RuntimeEntityRegistry	runtimeEntityRegistry

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	AbstractRepositoryOperations(DateTimeProvider<Object> dateTimeProvider, RuntimeEntityRegistry runtimeEntityRegistry, DataConversionService conversionService, AttributeConverterRegistry attributeConverterRegistry)	Default constructor.

Method Summary

Modifier and Type	Method	Description
protected void	checkOptimisticLocking(int expected, Number received)	Compare the expected modifications and the received rows count.
io.micronaut.context.ApplicationContext	getApplicationContext()
DataConversionService	getConversionService()
final <T> RuntimePersistentEntity<T>	getEntity(Class<T> type)
protected final RuntimePersistentProperty<Object>	getIdReader(Object o)	Obtain an ID reader for the given object.
protected boolean	isOnlySingleEndedJoins(RuntimePersistentEntity<?> rootPersistentEntity, Set<JoinPath> joinFetchPaths)	Check if joined associated are all single ended (Can produce only one result).
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

Field Details

entityEventRegistry

protected final EntityEventListener<Object> entityEventRegistry

dateTimeProvider

protected final DateTimeProvider dateTimeProvider

runtimeEntityRegistry

protected final RuntimeEntityRegistry runtimeEntityRegistry

conversionService

protected final DataConversionService conversionService

attributeConverterRegistry

protected final AttributeConverterRegistry attributeConverterRegistry

Constructor Details

AbstractRepositoryOperations

protected AbstractRepositoryOperations(DateTimeProvider<Object> dateTimeProvider,
 RuntimeEntityRegistry runtimeEntityRegistry,
 DataConversionService conversionService,
 AttributeConverterRegistry attributeConverterRegistry)

Default constructor.

Parameters:

dateTimeProvider - The date time provider

runtimeEntityRegistry - The entity registry

conversionService - The conversion service

attributeConverterRegistry - The attribute converter registry

Method Details

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
 Class<T> type)

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

getIdReader

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

Obtain an ID reader for the given object.

Parameters:

o - The object

Returns:

The ID reader

checkOptimisticLocking

protected void checkOptimisticLocking(int expected,
 Number 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,
 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