Package 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 Details

    • 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, 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 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<Void> persistManyAssociation(Ctx ctx, RuntimeAssociation runtimeAssociation, Object parentEntityValue, RuntimePersistentEntity<Object> parentPersistentEntity, Object childEntityValue, RuntimePersistentEntity<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<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 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