Package org.hibernate.reactive.persister.collection.impl

Class ReactiveOneToManyPersister

java.lang.Object
org.hibernate.persister.collection.AbstractCollectionPersister
org.hibernate.persister.collection.OneToManyPersister
org.hibernate.reactive.persister.collection.impl.ReactiveOneToManyPersister
All Implemented Interfaces:
org.hibernate.engine.profile.internal.FetchProfileAffectee, org.hibernate.metamodel.mapping.FilterRestrictable, org.hibernate.metamodel.mapping.internal.InFlightCollectionMapping, org.hibernate.metamodel.mapping.internal.PluralAttributeMappingImpl.Aware, org.hibernate.metamodel.mapping.Restrictable, org.hibernate.metamodel.mapping.WhereRestrictable, org.hibernate.persister.collection.CollectionPersister, org.hibernate.persister.collection.mutation.CollectionMutationTarget, org.hibernate.persister.entity.Joinable, ReactiveAbstractCollectionPersister, ReactiveCollectionPersister, org.hibernate.sql.model.MutationTarget<org.hibernate.persister.collection.mutation.CollectionTableMapping>
public class ReactiveOneToManyPersister extends org.hibernate.persister.collection.OneToManyPersister implements ReactiveAbstractCollectionPersister
A reactive OneToManyPersister

  • Field Summary

    Fields inherited from class org.hibernate.persister.collection.AbstractCollectionPersister

    batchSize, elementColumnAliases, elementColumnIsGettable, elementColumnIsSettable, elementColumnNames, elementColumnReaders, elementColumnReaderTemplates, elementColumnWriters, elementFormulas, elementFormulaTemplates, elementIsPureFormula, elementType, hasWhere, identifierColumnName, indexColumnAliases, indexColumnIsGettable, indexColumnIsSettable, indexColumnNames, indexContainsFormula, indexFormulas, indexFormulaTemplates, isInverse, keyColumnAliases, keyColumnNames, qualifiedTableName, sqlExceptionHelper, sqlWhereString

  • Constructor Summary

    Constructors
    Constructor
    Description
    ReactiveOneToManyPersister(org.hibernate.mapping.Collection collectionBinding, org.hibernate.cache.spi.access.CollectionDataAccess cacheAccessStrategy, org.hibernate.metamodel.spi.RuntimeModelCreationContext creationContext)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    org.hibernate.loader.ast.spi.CollectionLoader
    createNamedQueryCollectionLoader(org.hibernate.persister.collection.CollectionPersister persister, org.hibernate.query.named.NamedQueryMemento namedQueryMemento)
    See org.hibernate.persister.collection.AbstractCollectionPersister#createNamedQueryCollectionLoader
    org.hibernate.loader.ast.spi.CollectionLoader
    createSingleKeyCollectionLoader(org.hibernate.engine.spi.LoadQueryInfluencers loadQueryInfluencers)
    See org.hibernate.persister.collection.AbstractCollectionPersister#createSingleKeyCollectionLoader
    protected org.hibernate.loader.ast.spi.CollectionLoader
    createSubSelectLoader(org.hibernate.engine.spi.SubselectFetch subselect, org.hibernate.engine.spi.SharedSessionContractImplementor session)
     
    ReactiveDeleteRowsCoordinator
    getDeleteRowsCoordinator()
     
    ReactiveInsertRowsCoordinator
    getInsertRowsCoordinator()
     
    ReactiveRemoveCoordinator
    getRemoveCoordinator()
     
    ReactiveUpdateRowsCoordinator
    getUpdateRowsCoordinator()
     
    boolean
    isRowDeleteEnabled()
     
    boolean
    isRowInsertEnabled()
     
    CompletionStage<Void>
    reactiveDeleteRows(org.hibernate.collection.spi.PersistentCollection<?> collection, Object id, org.hibernate.engine.spi.SharedSessionContractImplementor session)
    Reactive version of CollectionPersister.deleteRows(PersistentCollection, Object, SharedSessionContractImplementor)
    CompletionStage<Void>
    reactiveInitialize(Object key, org.hibernate.engine.spi.SharedSessionContractImplementor session)
    Reactive version of CollectionPersister.initialize(Object, SharedSessionContractImplementor)
    CompletionStage<Void>
    reactiveInsertRows(org.hibernate.collection.spi.PersistentCollection<?> collection, Object id, org.hibernate.engine.spi.SharedSessionContractImplementor session)
    Reactive version of CollectionPersister.insertRows(PersistentCollection, Object, SharedSessionContractImplementor)
    CompletionStage<Void>
    reactiveRecreate(org.hibernate.collection.spi.PersistentCollection<?> collection, Object id, org.hibernate.engine.spi.SharedSessionContractImplementor session)
    Reactive version of CollectionPersister.recreate(PersistentCollection, Object, SharedSessionContractImplementor)
    CompletionStage<Void>
    reactiveRemove(Object id, org.hibernate.engine.spi.SharedSessionContractImplementor session)
    Reactive version of CollectionPersister.remove(Object, SharedSessionContractImplementor)
    CompletionStage<Void>
    reactiveUpdateRows(org.hibernate.collection.spi.PersistentCollection<?> collection, Object id, org.hibernate.engine.spi.SharedSessionContractImplementor session)
    Reactive version of CollectionPersister.updateRows(PersistentCollection, Object, SharedSessionContractImplementor)

    Methods inherited from class org.hibernate.persister.collection.OneToManyPersister

    applyWhereFragments, deleteRows, doProcessQueuedOps, generateDeleteAllAst, generateDeleteRowAst, getFilterAliasGenerator, getFilterAliasGenerator, getRowMutationOperations, getTableName, insertRows, isManyToMany, isOneToMany, recreate, updateRows

    Methods inherited from class org.hibernate.persister.collection.AbstractCollectionPersister

    applyBaseManyToManyRestrictions, applyBaseRestrictions, applyBaseRestrictions, applyFilterRestrictions, applyKeyRestrictions, applyWhereRestrictions, buildDeleteAllOperation, determineLoaderToUse, determineTableName, elementExists, forEachMutableTable, forEachMutableTableReverse, generateDetectRowByElementString, generateDetectRowByIndexString, generateSelectSizeString, getAttributeMapping, getBatchSize, getCacheAccessStrategy, getCacheEntryStructure, getCollectionLoader, getCollectionPropertyColumnAliases, getCollectionSemantics, getCollectionSpaces, getCollectionTableMapping, getCollectionType, getDialect, getElementByIndex, getElementClass, getElementColumnAliases, getElementColumnNames, getElementPersister, getElementPersisterInternal, getElementType, getFactory, getGenerator, getIdentifierColumnAlias, getIdentifierColumnName, getIdentifierGenerator, getIdentifierTableName, getIdentifierType, getIndexColumnAliases, getIndexColumnNames, getIndexType, getKeyColumnAliases, getKeyColumnNames, getKeyType, getManyToManyFilterFragment, getMappedByProperty, getNavigableRole, getOwnerEntityName, getOwnerEntityPersister, getSize, getSortingComparator, getSQLExceptionHelper, getTargetPart, hasCache, hasIndex, hasManyToManyOrdering, hasOrdering, hasOrphanDelete, hasPhysicalIndexColumn, hasWhereRestrictions, incrementIndexByBase, indexExists, initCollectionPropertyMap, initialize, injectAttributeMapping, isAffectedByEnabledFetchProfiles, isAffectedByEnabledFilters, isAffectedByEnabledFilters, isAffectedByEnabledFilters, isAffectedByEnabledFilters, isAffectedByEntityGraph, isArray, isCascadeDeleteEnabled, isExtraLazy, isInverse, isLazy, isMutable, isPrimitiveArray, isSubselectLoadable, isVersioned, logStaticSQL, needsRemove, postInstantiate, prepareMappingModel, processQueuedOps, registerAffectingFetchProfile, remove, selectFragment, toString, useShallowQueryCacheLayout

    Methods inherited from class java.lang.Object

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

    Methods inherited from interface org.hibernate.persister.collection.mutation.CollectionMutationTarget

    getIdentifierTableMapping

    Methods inherited from interface org.hibernate.persister.collection.CollectionPersister

    applyBaseManyToManyRestrictions, elementExists, getAttributeMapping, getBatchSize, getCacheAccessStrategy, getCacheEntryStructure, getCollectionPropertyColumnAliases, getCollectionSemantics, getCollectionSpaces, getCollectionType, getElementByIndex, getElementClass, getElementColumnAliases, getElementPersister, getElementType, getFactory, getGenerator, getIdentifierColumnAlias, getIdentifierColumnName, getIdentifierGenerator, getIdentifierType, getIndexColumnAliases, getIndexType, getKeyColumnAliases, getKeyType, getManyToManyFilterFragment, getMappedByProperty, getNavigableRole, getOwnerEntityPersister, getRole, getSize, getSortingComparator, getTableName, hasCache, hasIndex, hasManyToManyOrdering, hasOrdering, hasOrphanDelete, indexExists, isAffectedByEnabledFetchProfiles, isAffectedByEnabledFilters, isAffectedByEnabledFilters, isAffectedByEnabledFilters, isAffectedByEnabledFilters, isAffectedByEntityGraph, isArray, isBatchLoadable, isCascadeDeleteEnabled, isExtraLazy, isInverse, isLazy, isManyToMany, isMutable, isOneToMany, isPrimitiveArray, isSubselectLoadable, isVersioned, needsRemove, postInstantiate, processQueuedOps, recreate, selectFragment, useShallowQueryCacheLayout

    Methods inherited from interface org.hibernate.metamodel.mapping.FilterRestrictable

    applyFilterRestrictions, applyFilterRestrictions

    Methods inherited from interface org.hibernate.sql.model.MutationTarget

    getRolePath

    Methods inherited from interface org.hibernate.reactive.persister.collection.impl.ReactiveAbstractCollectionPersister

    getReactiveConnection

    Methods inherited from interface org.hibernate.reactive.persister.collection.impl.ReactiveCollectionPersister

    deleteRows, initialize, insertRows, remove, updateRows

    Methods inherited from interface org.hibernate.metamodel.mapping.Restrictable

    applyBaseRestrictions, applyBaseRestrictions

    Methods inherited from interface org.hibernate.metamodel.mapping.WhereRestrictable

    applyWhereRestrictions, hasWhereRestrictions

  • Constructor Details

    • ReactiveOneToManyPersister

      public ReactiveOneToManyPersister(org.hibernate.mapping.Collection collectionBinding, org.hibernate.cache.spi.access.CollectionDataAccess cacheAccessStrategy, org.hibernate.metamodel.spi.RuntimeModelCreationContext creationContext) throws org.hibernate.MappingException, org.hibernate.cache.CacheException
      Throws:
      org.hibernate.MappingException
      org.hibernate.cache.CacheException

  • Method Details

    • createNamedQueryCollectionLoader

      public org.hibernate.loader.ast.spi.CollectionLoader createNamedQueryCollectionLoader(org.hibernate.persister.collection.CollectionPersister persister, org.hibernate.query.named.NamedQueryMemento namedQueryMemento)
      Description copied from interface: ReactiveAbstractCollectionPersister
      See org.hibernate.persister.collection.AbstractCollectionPersister#createNamedQueryCollectionLoader
      Specified by:
      createNamedQueryCollectionLoader in interface ReactiveAbstractCollectionPersister
      Overrides:
      createNamedQueryCollectionLoader in class org.hibernate.persister.collection.AbstractCollectionPersister

    • createSingleKeyCollectionLoader

      public org.hibernate.loader.ast.spi.CollectionLoader createSingleKeyCollectionLoader(org.hibernate.engine.spi.LoadQueryInfluencers loadQueryInfluencers)
      Description copied from interface: ReactiveAbstractCollectionPersister
      See org.hibernate.persister.collection.AbstractCollectionPersister#createSingleKeyCollectionLoader
      Specified by:
      createSingleKeyCollectionLoader in interface ReactiveAbstractCollectionPersister
      Overrides:
      createSingleKeyCollectionLoader in class org.hibernate.persister.collection.AbstractCollectionPersister

    • getInsertRowsCoordinator

      public ReactiveInsertRowsCoordinator getInsertRowsCoordinator()
      Overrides:
      getInsertRowsCoordinator in class org.hibernate.persister.collection.OneToManyPersister

    • getUpdateRowsCoordinator

      public ReactiveUpdateRowsCoordinator getUpdateRowsCoordinator()
      Overrides:
      getUpdateRowsCoordinator in class org.hibernate.persister.collection.OneToManyPersister

    • getDeleteRowsCoordinator

      public ReactiveDeleteRowsCoordinator getDeleteRowsCoordinator()
      Overrides:
      getDeleteRowsCoordinator in class org.hibernate.persister.collection.OneToManyPersister

    • getRemoveCoordinator

      public ReactiveRemoveCoordinator getRemoveCoordinator()
      Overrides:
      getRemoveCoordinator in class org.hibernate.persister.collection.OneToManyPersister

    • createSubSelectLoader

      protected org.hibernate.loader.ast.spi.CollectionLoader createSubSelectLoader(org.hibernate.engine.spi.SubselectFetch subselect, org.hibernate.engine.spi.SharedSessionContractImplementor session)
      Overrides:
      createSubSelectLoader in class org.hibernate.persister.collection.AbstractCollectionPersister

    • reactiveInitialize

      public CompletionStage<Void> reactiveInitialize(Object key, org.hibernate.engine.spi.SharedSessionContractImplementor session)
      Description copied from interface: ReactiveCollectionPersister
      Reactive version of CollectionPersister.initialize(Object, SharedSessionContractImplementor)
      Specified by:
      reactiveInitialize in interface ReactiveCollectionPersister

    • isRowDeleteEnabled

      public boolean isRowDeleteEnabled()
      Specified by:
      isRowDeleteEnabled in interface ReactiveAbstractCollectionPersister
      Overrides:
      isRowDeleteEnabled in class org.hibernate.persister.collection.OneToManyPersister

    • isRowInsertEnabled

      public boolean isRowInsertEnabled()
      Specified by:
      isRowInsertEnabled in interface ReactiveAbstractCollectionPersister
      Overrides:
      isRowInsertEnabled in class org.hibernate.persister.collection.AbstractCollectionPersister

    • reactiveRecreate

      public CompletionStage<Void> reactiveRecreate(org.hibernate.collection.spi.PersistentCollection<?> collection, Object id, org.hibernate.engine.spi.SharedSessionContractImplementor session) throws org.hibernate.HibernateException
      Description copied from interface: ReactiveCollectionPersister
      Reactive version of CollectionPersister.recreate(PersistentCollection, Object, SharedSessionContractImplementor)
      Specified by:
      reactiveRecreate in interface ReactiveAbstractCollectionPersister
      Specified by:
      reactiveRecreate in interface ReactiveCollectionPersister
      Throws:
      org.hibernate.HibernateException
      See Also:
      • OneToManyPersister.recreate(PersistentCollection, Object, SharedSessionContractImplementor)

    • reactiveInsertRows

      public CompletionStage<Void> reactiveInsertRows(org.hibernate.collection.spi.PersistentCollection<?> collection, Object id, org.hibernate.engine.spi.SharedSessionContractImplementor session) throws org.hibernate.HibernateException
      Description copied from interface: ReactiveCollectionPersister
      Reactive version of CollectionPersister.insertRows(PersistentCollection, Object, SharedSessionContractImplementor)
      Specified by:
      reactiveInsertRows in interface ReactiveAbstractCollectionPersister
      Specified by:
      reactiveInsertRows in interface ReactiveCollectionPersister
      Throws:
      org.hibernate.HibernateException
      See Also:
      • OneToManyPersister.insertRows(PersistentCollection, Object, SharedSessionContractImplementor)

    • reactiveUpdateRows

      public CompletionStage<Void> reactiveUpdateRows(org.hibernate.collection.spi.PersistentCollection<?> collection, Object id, org.hibernate.engine.spi.SharedSessionContractImplementor session)
      Description copied from interface: ReactiveCollectionPersister
      Reactive version of CollectionPersister.updateRows(PersistentCollection, Object, SharedSessionContractImplementor)
      Specified by:
      reactiveUpdateRows in interface ReactiveAbstractCollectionPersister
      Specified by:
      reactiveUpdateRows in interface ReactiveCollectionPersister
      See Also:
      • OneToManyPersister.updateRows(PersistentCollection, Object, SharedSessionContractImplementor)

    • reactiveDeleteRows

      public CompletionStage<Void> reactiveDeleteRows(org.hibernate.collection.spi.PersistentCollection<?> collection, Object id, org.hibernate.engine.spi.SharedSessionContractImplementor session)
      Description copied from interface: ReactiveCollectionPersister
      Reactive version of CollectionPersister.deleteRows(PersistentCollection, Object, SharedSessionContractImplementor)
      Specified by:
      reactiveDeleteRows in interface ReactiveAbstractCollectionPersister
      Specified by:
      reactiveDeleteRows in interface ReactiveCollectionPersister
      See Also:
      • OneToManyPersister.deleteRows(PersistentCollection, Object, SharedSessionContractImplementor)

    • reactiveRemove

      public CompletionStage<Void> reactiveRemove(Object id, org.hibernate.engine.spi.SharedSessionContractImplementor session)
      Description copied from interface: ReactiveCollectionPersister
      Reactive version of CollectionPersister.remove(Object, SharedSessionContractImplementor)
      Specified by:
      reactiveRemove in interface ReactiveAbstractCollectionPersister
      Specified by:
      reactiveRemove in interface ReactiveCollectionPersister
      See Also:
      • AbstractCollectionPersister.remove(Object, SharedSessionContractImplementor)