io.micronaut.data.runtime.operations.internal

Interface ReactiveCascadeOperations.ReactiveCascadeOperationsHelper<Ctx extends OperationContext>

Type Parameters:

Ctx - The operation context.

All Known Implementing Classes:

DefaultReactiveMongoRepositoryOperations

Enclosing class:

ReactiveCascadeOperations<Ctx extends OperationContext>

public static interface ReactiveCascadeOperations.ReactiveCascadeOperationsHelper<Ctx extends OperationContext>

The cascade operations helper.

Method Summary

Modifier and Type	Method and Description
default boolean	isSupportsBatchDelete(Ctx ctx, RuntimePersistentEntity<?> persistentEntity) Is supports batch delete.
default boolean	isSupportsBatchInsert(Ctx ctx, RuntimePersistentEntity<?> persistentEntity) Is supports batch insert.
default boolean	isSupportsBatchUpdate(Ctx ctx, RuntimePersistentEntity<?> persistentEntity) Is supports batch update.
<T> reactor.core.publisher.Flux<T>	persistBatch(Ctx ctx, java.lang.Iterable<T> entityValues, RuntimePersistentEntity<T> persistentEntity, java.util.function.Predicate<T> predicate) Persist multiple entities in batch during cascade.
reactor.core.publisher.Mono<java.lang.Void>	persistManyAssociation(Ctx ctx, RuntimeAssociation runtimeAssociation, java.lang.Object parentEntityValue, RuntimePersistentEntity<java.lang.Object> parentPersistentEntity, java.lang.Object childEntityValue, RuntimePersistentEntity<java.lang.Object> childPersistentEntity) Persist JOIN table relationship.
reactor.core.publisher.Mono<java.lang.Void>	persistManyAssociationBatch(Ctx ctx, RuntimeAssociation runtimeAssociation, java.lang.Object parentEntityValue, RuntimePersistentEntity<java.lang.Object> parentPersistentEntity, java.lang.Iterable<java.lang.Object> childEntityValues, RuntimePersistentEntity<java.lang.Object> childPersistentEntity, java.util.function.Predicate<java.lang.Object> veto) Persist JOIN table relationships in batch.
<T> reactor.core.publisher.Mono<T>	persistOne(Ctx ctx, T entityValue, RuntimePersistentEntity<T> persistentEntity) Persist one entity during cascade.
<T> reactor.core.publisher.Mono<T>	updateOne(Ctx ctx, T entityValue, RuntimePersistentEntity<T> persistentEntity) Update one entity during cascade.

Method Detail

isSupportsBatchInsert

default boolean isSupportsBatchInsert(Ctx ctx,
                                      RuntimePersistentEntity<?> persistentEntity)

Is supports batch insert.

Parameters:

ctx - The context

persistentEntity - The persistent entity

Returns:

True if supports

isSupportsBatchUpdate

default boolean isSupportsBatchUpdate(Ctx ctx,
                                      RuntimePersistentEntity<?> persistentEntity)

Is supports batch update.

Parameters:

ctx - The context

persistentEntity - The persistent entity

Returns:

True if supports

isSupportsBatchDelete

default boolean isSupportsBatchDelete(Ctx ctx,
                                      RuntimePersistentEntity<?> persistentEntity)

Is supports batch delete.

Parameters:

ctx - The context

persistentEntity - The persistent entity

Returns:

True if supports

persistOne

<T> reactor.core.publisher.Mono<T> persistOne(Ctx ctx,
                                              T entityValue,
                                              RuntimePersistentEntity<T> persistentEntity)

Persist one entity during cascade.

Type Parameters:

T - The entity type

Parameters:

ctx - The context

entityValue - The entity value

persistentEntity - The persistent entity

Returns:

The entity value

persistBatch

<T> reactor.core.publisher.Flux<T> persistBatch(Ctx ctx,
                                                java.lang.Iterable<T> entityValues,
                                                RuntimePersistentEntity<T> persistentEntity,
                                                java.util.function.Predicate<T> predicate)

Persist multiple entities in batch during cascade.

Type Parameters:

T - The entity type

Parameters:

ctx - The context

entityValues - The entity values

persistentEntity - The persistent entity

predicate - The veto predicate

Returns:

The entity values

updateOne

<T> reactor.core.publisher.Mono<T> updateOne(Ctx ctx,
                                             T entityValue,
                                             RuntimePersistentEntity<T> persistentEntity)

Update one entity during cascade.

Type Parameters:

T - The entity type

Parameters:

ctx - The context

entityValue - The entity value

persistentEntity - The persistent entity

Returns:

The entity value

persistManyAssociation

reactor.core.publisher.Mono<java.lang.Void> persistManyAssociation(Ctx ctx,
                                                                   RuntimeAssociation runtimeAssociation,
                                                                   java.lang.Object parentEntityValue,
                                                                   RuntimePersistentEntity<java.lang.Object> parentPersistentEntity,
                                                                   java.lang.Object childEntityValue,
                                                                   RuntimePersistentEntity<java.lang.Object> childPersistentEntity)

Persist JOIN table relationship.

Parameters:

ctx - The context

runtimeAssociation - The association

parentEntityValue - The parent entity value

parentPersistentEntity - The parent persistent entity

childEntityValue - The child entity value

childPersistentEntity - The child persistent entity

Returns:

The empty mono

persistManyAssociationBatch

reactor.core.publisher.Mono<java.lang.Void> persistManyAssociationBatch(Ctx ctx,
                                                                        RuntimeAssociation runtimeAssociation,
                                                                        java.lang.Object parentEntityValue,
                                                                        RuntimePersistentEntity<java.lang.Object> parentPersistentEntity,
                                                                        java.lang.Iterable<java.lang.Object> childEntityValues,
                                                                        RuntimePersistentEntity<java.lang.Object> childPersistentEntity,
                                                                        java.util.function.Predicate<java.lang.Object> veto)

Persist JOIN table relationships in batch.

Parameters:

ctx - The context

runtimeAssociation - The association

parentEntityValue - The parent entity value

parentPersistentEntity - The parent persistent entity

childEntityValues - The child entity values

childPersistentEntity - The child persistent entity

veto - The veto predicate

Returns:

The empty mono