io.micronaut.data.runtime.operations.internal

Class AbstractReactiveEntitiesOperations<Ctx extends OperationContext,T,Exc extends java.lang.Exception>

java.lang.Object

io.micronaut.data.runtime.operations.internal.ReactiveEntitiesOperations<T,Exc>

io.micronaut.data.runtime.operations.internal.AbstractReactiveEntitiesOperations<Ctx,T,Exc>

Type Parameters:

Ctx - The operation context

T - The entity type

Exc - The exception

@Internal
public abstract class AbstractReactiveEntitiesOperations<Ctx extends OperationContext,T,Exc extends java.lang.Exception>
extends ReactiveEntitiesOperations<T,Exc>

Abstract reactive entities operations.

Since:

3.3

Author:

Denis Stepanov

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	AbstractReactiveEntitiesOperations.Data Internal entity data holder.

Field Summary

Fields

Modifier and Type	Field and Description
protected ReactiveCascadeOperations<Ctx>	cascadeOperations
protected io.micronaut.core.convert.ConversionService<?>	conversionService
protected Ctx	ctx
protected reactor.core.publisher.Flux<AbstractReactiveEntitiesOperations.Data>	entities
protected EntityEventListener<java.lang.Object>	entityEventListener
protected boolean	hasGeneratedId
protected boolean	insert
protected RuntimePersistentEntity<T>	persistentEntity
protected reactor.core.publisher.Mono<java.lang.Long>	rowsUpdated

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractReactiveEntitiesOperations(Ctx ctx, ReactiveCascadeOperations<Ctx> cascadeOperations, io.micronaut.core.convert.ConversionService<?> conversionService, EntityEventListener<java.lang.Object> entityEventListener, RuntimePersistentEntity<T> persistentEntity, java.lang.Iterable<T> entities, boolean insert) Default constructor.

Method Summary

Modifier and Type	Method and Description
protected void	cascadePost(Relation.Cascade cascadeType) Cascade post operation.
protected void	cascadePre(Relation.Cascade cascadeType) Cascade pre operation.
protected void	checkOptimisticLocking(long expected, long received) Compare the expected modifications and the received rows count.
protected abstract void	collectAutoPopulatedPreviousValues() Collect auto-populated values before pre-triggers modifies them.
void	delete() Delete one operation.
protected abstract void	execute() Execute update.
protected void	failed(java.lang.Exception e, java.lang.String operation)
reactor.core.publisher.Flux<T>	getEntities()
reactor.core.publisher.Mono<java.lang.Long>	getRowsUpdated()
protected boolean	notVetoed(AbstractReactiveEntitiesOperations.Data data) Check if data not vetoed.
void	persist() Persist one operation.
protected 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 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.
void	update() Update one operation.
protected T	updateEntityId(io.micronaut.core.beans.BeanProperty<T,java.lang.Object> identity, T entity, java.lang.Object id) Update entity id.
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

ctx

protected final Ctx extends OperationContext ctx

cascadeOperations

protected final ReactiveCascadeOperations<Ctx extends OperationContext> cascadeOperations

insert

protected final boolean insert

hasGeneratedId

protected final boolean hasGeneratedId

entities

protected reactor.core.publisher.Flux<AbstractReactiveEntitiesOperations.Data> entities

rowsUpdated

protected reactor.core.publisher.Mono<java.lang.Long> rowsUpdated

entityEventListener

protected final EntityEventListener<java.lang.Object> entityEventListener

persistentEntity

protected final RuntimePersistentEntity<T> persistentEntity

conversionService

protected final io.micronaut.core.convert.ConversionService<?> conversionService

Constructor Detail

AbstractReactiveEntitiesOperations

protected AbstractReactiveEntitiesOperations(Ctx ctx,
                                             ReactiveCascadeOperations<Ctx> cascadeOperations,
                                             io.micronaut.core.convert.ConversionService<?> conversionService,
                                             EntityEventListener<java.lang.Object> entityEventListener,
                                             RuntimePersistentEntity<T> persistentEntity,
                                             java.lang.Iterable<T> entities,
                                             boolean insert)

Default constructor.

Parameters:

ctx - The context

cascadeOperations - The cascade operations

conversionService - The conversion service

entityEventListener - The entity event listener

persistentEntity - The persistent entity

entities - The entities

insert - The insert

Method Detail

cascadePre

protected void cascadePre(Relation.Cascade cascadeType)

Cascade pre operation.

Parameters:

cascadeType - The cascade type

cascadePost

protected void cascadePost(Relation.Cascade cascadeType)

Cascade post operation.

Parameters:

cascadeType - The cascade type

veto

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

Veto an entity.

Parameters:

predicate - The veto predicate

triggerPre

protected 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 void triggerPost(java.util.function.Consumer<EntityEventContext<java.lang.Object>> fn)

Trigger post-actions on EntityEventContext.

Parameters:

fn - The entity context function

notVetoed

protected boolean notVetoed(AbstractReactiveEntitiesOperations.Data data)

Check if data not vetoed.

Parameters:

data - The data

Returns:

true if data is not vetoed

getEntities

public reactor.core.publisher.Flux<T> getEntities()

Specified by:

getEntities in class ReactiveEntitiesOperations<T,Exc extends java.lang.Exception>

Returns:

The entities

getRowsUpdated

public reactor.core.publisher.Mono<java.lang.Long> getRowsUpdated()

Returns:

Rows updated.

checkOptimisticLocking

protected void checkOptimisticLocking(long expected,
                                      long received)

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

Parameters:

expected - The expected value

received - THe received value

persist

public void persist()

Persist one operation.

delete

public void delete()

Delete one operation.

update

public void update()

Update one operation.

failed

protected void failed(java.lang.Exception e,
                      java.lang.String operation)
               throws DataAccessException

Throws:

DataAccessException

collectAutoPopulatedPreviousValues

protected abstract void collectAutoPopulatedPreviousValues()

Collect auto-populated values before pre-triggers modifies them.

execute

protected abstract void execute()
                         throws Exc extends java.lang.Exception

Execute update.

Throws:

Exc - The exception

Exc extends java.lang.Exception

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.