io.micronaut.data.runtime.operations.internal

Class AbstractSqlRepositoryOperations.BaseOperations<T>

java.lang.Object

io.micronaut.data.runtime.operations.internal.AbstractSqlRepositoryOperations.BaseOperations<T>

Type Parameters:

T - The entity type

Direct Known Subclasses:

AbstractSqlRepositoryOperations.EntitiesOperations, AbstractSqlRepositoryOperations.EntityOperations

Enclosing class:

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

protected abstract class AbstractSqlRepositoryOperations.BaseOperations<T>
extends java.lang.Object

The base entity operations class.

Field Summary

Fields

Modifier and Type	Field and Description
protected RuntimePersistentEntity<T>	persistentEntity

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	BaseOperations(RuntimePersistentEntity<T> persistentEntity)

Method Summary

Modifier and Type	Method and Description
protected abstract void	cascadePost(Relation.Cascade cascadeType, Cnt cnt, Dialect dialect, io.micronaut.core.annotation.AnnotationMetadata annotationMetadata, java.lang.Class<?> repositoryType, java.util.List<Association> associations, java.util.Set<java.lang.Object> persisted) Cascade post operation.
protected abstract void	cascadePre(Relation.Cascade cascadeType, Cnt cnt, Dialect dialect, io.micronaut.core.annotation.AnnotationMetadata annotationMetadata, java.lang.Class<?> repositoryType, java.util.List<Association> associations, java.util.Set<java.lang.Object> persisted) Cascade pre operation.
protected void	checkForParameterToBeExpanded(AbstractSqlRepositoryOperations.SqlOperation sqlOperation, SqlQueryBuilder queryBuilder) Delegate to SQL operation to check if query needs to be changed to allow for expanded parameters.
protected abstract void	collectAutoPopulatedPreviousValues(AbstractSqlRepositoryOperations.SqlOperation sqlOperation) Collect auto populated values before pre-triggers modifies them.
protected abstract void	executeUpdate(PS stmt) Execute update.
protected abstract void	executeUpdate(PS stmt, AbstractSqlRepositoryOperations.DBOperation2<java.lang.Integer,java.lang.Integer,Exc> fn) Execute update and process entities modified and rows executed.
protected abstract void	executeUpdateSetGeneratedId(PS stmt) Execute update and update generated id.
protected abstract void	setParameters(PS stmt, AbstractSqlRepositoryOperations.SqlOperation sqlOperation) Set sql parameters.
protected abstract void	triggerPost(java.util.function.Consumer<EntityEventContext<java.lang.Object>> fn) Trigger post-actions on EntityEventContext.
protected void	triggerPostPersist() Trigger the post persist event.
protected void	triggerPostRemove() Trigger the post remove event.
protected void	triggerPostUpdate() Trigger the post update event.
protected abstract boolean	triggerPre(java.util.function.Function<EntityEventContext<java.lang.Object>,java.lang.Boolean> fn) Trigger pre-actions on EntityEventContext.
protected boolean	triggerPrePersist() Trigger the pre persist event.
protected boolean	triggerPreRemove() Trigger the pre remove event.
protected boolean	triggerPreUpdate() Trigger the pre update event.
protected T	updateEntityId(io.micronaut.core.beans.BeanProperty<T,java.lang.Object> identity, T entity, java.lang.Object id) Update entity id.
protected abstract void	veto(java.util.function.Predicate<T> predicate) Veto an entity.

Methods inherited from class java.lang.Object

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

Field Detail

persistentEntity

protected final RuntimePersistentEntity<T> persistentEntity

Constructor Detail

BaseOperations

protected BaseOperations(RuntimePersistentEntity<T> persistentEntity)

Method Detail

cascadePre

protected abstract void cascadePre(Relation.Cascade cascadeType,
                                   Cnt cnt,
                                   Dialect dialect,
                                   io.micronaut.core.annotation.AnnotationMetadata annotationMetadata,
                                   java.lang.Class<?> repositoryType,
                                   java.util.List<Association> associations,
                                   java.util.Set<java.lang.Object> persisted)

Cascade pre operation.

Parameters:

cascadeType - The cascade type

cnt - The connection

dialect - The dialect

annotationMetadata - The annotation metadata

repositoryType - The repository type

associations - The associations leading to the entity

persisted - The set containing previously processed values

cascadePost

protected abstract void cascadePost(Relation.Cascade cascadeType,
                                    Cnt cnt,
                                    Dialect dialect,
                                    io.micronaut.core.annotation.AnnotationMetadata annotationMetadata,
                                    java.lang.Class<?> repositoryType,
                                    java.util.List<Association> associations,
                                    java.util.Set<java.lang.Object> persisted)

Cascade post operation.

Parameters:

cascadeType - The cascade type

cnt - The connection

dialect - The dialect

annotationMetadata - The annotation metadata

repositoryType - The repository type

associations - The associations leading to the entity

persisted - The set containing previously processed values

collectAutoPopulatedPreviousValues

protected abstract void collectAutoPopulatedPreviousValues(AbstractSqlRepositoryOperations.SqlOperation sqlOperation)

Collect auto populated values before pre-triggers modifies them.

Parameters:

sqlOperation - The sql operation

checkForParameterToBeExpanded

protected void checkForParameterToBeExpanded(AbstractSqlRepositoryOperations.SqlOperation sqlOperation,
                                             SqlQueryBuilder queryBuilder)

Delegate to SQL operation to check if query needs to be changed to allow for expanded parameters.

Parameters:

sqlOperation - The sqlOperation

queryBuilder - The queryBuilder

setParameters

protected abstract void setParameters(PS stmt,
                                      AbstractSqlRepositoryOperations.SqlOperation sqlOperation)
                               throws Exc extends java.lang.Exception

Set sql parameters.

Parameters:

stmt - The statement

sqlOperation - The sql operation

Throws:

Exc - The exception type

Exc extends java.lang.Exception

executeUpdate

protected abstract void executeUpdate(PS stmt,
                                      AbstractSqlRepositoryOperations.DBOperation2<java.lang.Integer,java.lang.Integer,Exc> fn)
                               throws Exc extends java.lang.Exception

Execute update and process entities modified and rows executed.

Parameters:

stmt - The statement

fn - The function

Throws:

Exc - The exception type

Exc extends java.lang.Exception

executeUpdate

protected abstract void executeUpdate(PS stmt)
                               throws Exc extends java.lang.Exception

Execute update.

Parameters:

stmt - The statement

Throws:

Exc - The exception type

Exc extends java.lang.Exception

executeUpdateSetGeneratedId

protected abstract void executeUpdateSetGeneratedId(PS stmt)
                                             throws Exc extends java.lang.Exception

Execute update and update generated id.

Parameters:

stmt - The statement

Throws:

Exc - The exception type

Exc extends java.lang.Exception

veto

protected abstract void veto(java.util.function.Predicate<T> predicate)

Veto an entity.

Parameters:

predicate - The veto predicate

updateEntityId

protected T updateEntityId(io.micronaut.core.beans.BeanProperty<T,java.lang.Object> identity,
                           T entity,
                           java.lang.Object id)

Update entity id.

Parameters:

identity - The identity property.

entity - The entity instance

id - The id instance

Returns:

The entity instance

triggerPrePersist

protected boolean triggerPrePersist()

Trigger the pre persist event.

Returns:

true if operation was vetoed

triggerPreUpdate

protected boolean triggerPreUpdate()

Trigger the pre update event.

Returns:

true if operation was vetoed

triggerPreRemove

protected boolean triggerPreRemove()

Trigger the pre remove event.

Returns:

true if operation was vetoed

triggerPostUpdate

protected void triggerPostUpdate()

Trigger the post update event.

triggerPostRemove

protected void triggerPostRemove()

Trigger the post remove event.

triggerPostPersist

protected void triggerPostPersist()

Trigger the post persist event.

triggerPre

protected abstract boolean triggerPre(java.util.function.Function<EntityEventContext<java.lang.Object>,java.lang.Boolean> fn)

Trigger pre-actions on EntityEventContext.

Parameters:

fn - The entity context function

Returns:

true if operation was vetoed

triggerPost

protected abstract void triggerPost(java.util.function.Consumer<EntityEventContext<java.lang.Object>> fn)

Trigger post-actions on EntityEventContext.

Parameters:

fn - The entity context function