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

Class ReactiveBasicCollectionPersister

java.lang.Object
org.hibernate.persister.collection.AbstractCollectionPersister
org.hibernate.persister.collection.BasicCollectionPersister
org.hibernate.reactive.persister.collection.impl.ReactiveBasicCollectionPersister
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 ReactiveBasicCollectionPersister extends org.hibernate.persister.collection.BasicCollectionPersister implements ReactiveAbstractCollectionPersister
A reactive BasicCollectionPersister

  • 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
    ReactiveBasicCollectionPersister(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)
     
    protected ReactiveInsertRowsCoordinator
    getCreateEntryCoordinator()
     
    ReactiveRemoveCoordinator
    getRemoveCoordinator()
     
    protected ReactiveDeleteRowsCoordinator
    getRemoveEntryCoordinator()
     
    protected ReactiveUpdateRowsCoordinator
    getUpdateEntryCoordinator()
     
    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.BasicCollectionPersister

    buildRowMutationOperations, deleteRows, doProcessQueuedOps, generateDeleteAllAst, generateSoftDeleteRowsAst, getFilterAliasGenerator, getFilterAliasGenerator, getRowMutationOperations, insertRows, isManyToMany, isOneToMany, recreate, updateRows

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

    applyBaseManyToManyRestrictions, applyBaseRestrictions, applyBaseRestrictions, applyFilterRestrictions, applyKeyRestrictions, applyWhereFragments, 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, getTableName, 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

    • ReactiveBasicCollectionPersister

      public ReactiveBasicCollectionPersister(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

    • 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

    • 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)

    • reactiveRecreate

      public CompletionStage<Void> reactiveRecreate(org.hibernate.collection.spi.PersistentCollection<?> collection, Object id, org.hibernate.engine.spi.SharedSessionContractImplementor session)
      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
      See Also:
      • BasicCollectionPersister.recreate(PersistentCollection, Object, SharedSessionContractImplementor)

    • reactiveInsertRows

      public CompletionStage<Void> reactiveInsertRows(org.hibernate.collection.spi.PersistentCollection<?> collection, Object id, org.hibernate.engine.spi.SharedSessionContractImplementor session)
      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
      See Also:
      • CollectionPersister.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:
      • CollectionPersister.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:
      • CollectionPersister.deleteRows(PersistentCollection, Object, SharedSessionContractImplementor)

    • isRowDeleteEnabled

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

    • isRowInsertEnabled

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

    • getCreateEntryCoordinator

      protected ReactiveInsertRowsCoordinator getCreateEntryCoordinator()
      Overrides:
      getCreateEntryCoordinator in class org.hibernate.persister.collection.BasicCollectionPersister

    • getUpdateEntryCoordinator

      protected ReactiveUpdateRowsCoordinator getUpdateEntryCoordinator()
      Overrides:
      getUpdateEntryCoordinator in class org.hibernate.persister.collection.BasicCollectionPersister

    • getRemoveCoordinator

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

    • getRemoveEntryCoordinator

      protected ReactiveDeleteRowsCoordinator getRemoveEntryCoordinator()
      Overrides:
      getRemoveEntryCoordinator in class org.hibernate.persister.collection.BasicCollectionPersister