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 TypeMethodDescriptiondefault 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, Iterable<T> entityValues, RuntimePersistentEntity<T> persistentEntity, Predicate<T> predicate) Persist multiple entities in batch during cascade.reactor.core.publisher.Mono<Void>
persistManyAssociation
(Ctx ctx, RuntimeAssociation runtimeAssociation, Object parentEntityValue, RuntimePersistentEntity<Object> parentPersistentEntity, Object childEntityValue, RuntimePersistentEntity<Object> childPersistentEntity) Persist JOIN table relationship.reactor.core.publisher.Mono<Void>
persistManyAssociationBatch
(Ctx ctx, RuntimeAssociation runtimeAssociation, Object parentEntityValue, RuntimePersistentEntity<Object> parentPersistentEntity, Iterable<Object> childEntityValues, RuntimePersistentEntity<Object> childPersistentEntity, Predicate<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 Details
-
isSupportsBatchInsert
Is supports batch insert.- Parameters:
ctx
- The contextpersistentEntity
- The persistent entity- Returns:
- True if supports
-
isSupportsBatchUpdate
Is supports batch update.- Parameters:
ctx
- The contextpersistentEntity
- The persistent entity- Returns:
- True if supports
-
isSupportsBatchDelete
Is supports batch delete.- Parameters:
ctx
- The contextpersistentEntity
- 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 contextentityValue
- The entity valuepersistentEntity
- The persistent entity- Returns:
- The entity value
-
persistBatch
<T> reactor.core.publisher.Flux<T> persistBatch(Ctx ctx, Iterable<T> entityValues, RuntimePersistentEntity<T> persistentEntity, Predicate<T> predicate) Persist multiple entities in batch during cascade.- Type Parameters:
T
- The entity type- Parameters:
ctx
- The contextentityValues
- The entity valuespersistentEntity
- The persistent entitypredicate
- 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 contextentityValue
- The entity valuepersistentEntity
- The persistent entity- Returns:
- The entity value
-
persistManyAssociation
reactor.core.publisher.Mono<Void> persistManyAssociation(Ctx ctx, RuntimeAssociation runtimeAssociation, Object parentEntityValue, RuntimePersistentEntity<Object> parentPersistentEntity, Object childEntityValue, RuntimePersistentEntity<Object> childPersistentEntity) Persist JOIN table relationship.- Parameters:
ctx
- The contextruntimeAssociation
- The associationparentEntityValue
- The parent entity valueparentPersistentEntity
- The parent persistent entitychildEntityValue
- The child entity valuechildPersistentEntity
- The child persistent entity- Returns:
- The empty mono
-
persistManyAssociationBatch
reactor.core.publisher.Mono<Void> persistManyAssociationBatch(Ctx ctx, RuntimeAssociation runtimeAssociation, Object parentEntityValue, RuntimePersistentEntity<Object> parentPersistentEntity, Iterable<Object> childEntityValues, RuntimePersistentEntity<Object> childPersistentEntity, Predicate<Object> veto) Persist JOIN table relationships in batch.- Parameters:
ctx
- The contextruntimeAssociation
- The associationparentEntityValue
- The parent entity valueparentPersistentEntity
- The parent persistent entitychildEntityValues
- The child entity valueschildPersistentEntity
- The child persistent entityveto
- The veto predicate- Returns:
- The empty mono
-