Package org.apache.openjpa.kernel
Class DelegatingBroker
- java.lang.Object
-
- org.apache.openjpa.kernel.DelegatingBroker
-
- All Implemented Interfaces:
jakarta.transaction.Synchronization,CallbackModes,AutoClear,AutoDetach,Broker,ConnectionRetainModes,DetachState,LockLevels,RestoreState,StoreContext,Closeable
public class DelegatingBroker extends Object implements Broker
Delegating broker that can also perform exception translation for use in facades.- Since:
- 0.4.0
- Author:
- Abe White
-
-
Field Summary
-
Fields inherited from interface org.apache.openjpa.kernel.AutoClear
CLEAR_ALL, CLEAR_DATASTORE
-
Fields inherited from interface org.apache.openjpa.kernel.AutoDetach
DETACH_CLOSE, DETACH_COMMIT, DETACH_NONE, DETACH_NONTXREAD, DETACH_ROLLBACK, names, values
-
Fields inherited from interface org.apache.openjpa.event.CallbackModes
CALLBACK_FAIL_FAST, CALLBACK_IGNORE, CALLBACK_LOG, CALLBACK_RETHROW, CALLBACK_ROLLBACK
-
Fields inherited from interface org.apache.openjpa.kernel.ConnectionRetainModes
CONN_RETAIN_ALWAYS, CONN_RETAIN_DEMAND, CONN_RETAIN_TRANS
-
Fields inherited from interface org.apache.openjpa.kernel.DetachState
DETACH_ALL, DETACH_FETCH_GROUPS, DETACH_FGS, DETACH_LOADED
-
Fields inherited from interface org.apache.openjpa.kernel.LockLevels
LOCK_NONE, LOCK_READ, LOCK_WRITE
-
Fields inherited from interface org.apache.openjpa.kernel.RestoreState
RESTORE_ALL, RESTORE_IMMUTABLE, RESTORE_NONE
-
Fields inherited from interface org.apache.openjpa.kernel.StoreContext
EXCLUDE_ALL, OID_ALLOW_NEW, OID_COPY, OID_NODELETED, OID_NOVALIDATE
-
-
Constructor Summary
Constructors Constructor Description DelegatingBroker(Broker broker)Constructor; supply delegate.DelegatingBroker(Broker broker, RuntimeExceptionTranslator trans)Constructor; supply delegate and exception translator.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidaddLifecycleListener(Object listener, Class[] classes)Register a listener for lifecycle-related events on the specified classes.voidaddTransactionListener(Object listener)Register a listener for transaction-related events.voidafterCompletion(int status)voidassertActiveTransaction()Throw an exception if there is no active transaction.voidassertNontransactionalRead()Throw an exception if there is no transaction active and nontransactional reading is not enabled.voidassertOpen()Throw an exception if this broker has been closed.voidassertWriteOperation()Throw an exception if a write operation is not permitted (there is no active transaction and nontransactional writing is not enabled).Objectattach(Object obj, boolean copyNew, OpCallbacks call)Import the specified detached object into the broker.Object[]attachAll(Collection objs, boolean copyNew, OpCallbacks call)Import the specified objects into the broker.voidbeforeCompletion()voidbegin()Begin a transaction.booleanbeginOperation(boolean read)Begin a logical operation.voidbeginStore()Begin a data store transaction.booleancancelAll()Cancel all pending data store statements.voidclose()Close the broker.voidcommit()Commit the current transaction.voidcommitAndResume()Issue a commit and then start a new transaction.voiddelete(Object obj, OpCallbacks call)Delete the given object.voiddeleteAll(Collection objs, OpCallbacks call)Delete the given objects.Objectdetach(Object obj, OpCallbacks call)Detach the specified object from the broker.Object[]detachAll(Collection objs, OpCallbacks call)Detach the specified objects from the broker.voiddetachAll(OpCallbacks call)Detach all objects in place.voiddetachAll(OpCallbacks call, boolean flush)Detach all objects in place, with the option of performing a flush before doing the detachment.voiddirtyType(Class cls)Mark the given class as dirty within the current transaction.OpenJPAStateManagerembed(Object obj, Object id, OpenJPAStateManager owner, ValueMetaData ownerMeta)Make the given instance embedded.booleanendOperation()End a logical operation.booleanequals(Object other)voidevict(Object obj, OpCallbacks call)Evict the given object.voidevictAll(Collection objs, OpCallbacks call)Evict the given objects.voidevictAll(Extent extent, OpCallbacks call)Evict all persistent-clean and persistent-nontransactional instances in the givenExtent.voidevictAll(OpCallbacks call)Evict all clean objects.IteratorextentIterator(Class cls, boolean subs, FetchConfiguration fetch, boolean ignoreChanges)Return an iterator over all instances of the given type.Objectfind(Object oid, boolean validate, FindCallbacks call)Find the persistence object with the given oid.Objectfind(Object oid, FetchConfiguration fetch, BitSet exclude, Object edata, int flags)Return the object with the given oid.Object[]findAll(Collection oids, boolean validate, FindCallbacks call)Return the objects with the given oids.Object[]findAll(Collection oids, FetchConfiguration fetch, BitSet exclude, Object edata, int flags)Return the objects with the given oids.ObjectfindCached(Object oid, FindCallbacks call)Return the instance for the given oid/object , or null if not found in the L1 cache.voidflush()Flush all transactional instances to the data store.booleangetAllowReferenceToSiblingContext()Affirms if this context will allow its managed instances to refer instances that are managed by other contexts.intgetAutoClear()Whether objects clear when entering transactions.intgetAutoDetach()Bit flags marked inAutoDetachwhich indicate when persistent managed objects should be automatically detached in-place.BrokergetBroker()Return the broker for this context, if possible.BrokerFactorygetBrokerFactory()Return the factory that produced this broker.booleangetCachePreparedQuery()Affirms if this receiver is caching prepared queries.ClassLoadergetClassLoader()Return the current thread's class loader at the time this context was obtained.OpenJPAConfigurationgetConfiguration()Return the configuration associated with this context.ObjectgetConnection()Return the connection in use by the context, or a new connection if none.ObjectgetConnectionFactory()Return the 'JTA' ConnectionFactory, looking it up from JNDI if needed.ObjectgetConnectionFactory2()Return the 'NonJTA' ConnectionFactory, looking it up from JNDI if needed.StringgetConnectionFactory2Name()Return the 'NonJTA' ConnectionFactoryName.StringgetConnectionFactoryName()Return the 'JTA' connectionFactoryNameStringgetConnectionPassword()Return the connection password.intgetConnectionRetainMode()Return the connection retain mode for this broker.StringgetConnectionUserName()Return the connection user name.BrokergetDelegate()Return the direct delegate.CollectiongetDeletedTypes()Return the set of classes that have been deleted in the current transaction.intgetDetachState()Detach mode constant to determine which fields are part of the detached graph.CollectiongetDirtyObjects()Return a list of current dirty instances.booleangetEvictFromDataCache()Whether to also evict an object from the store cache when it is evicted through this broker.FetchConfigurationgetFetchConfiguration()Return the (mutable) fetch configuration for loading objects from this context.SeqgetIdentitySequence(ClassMetaData meta)Returns aSeqfor the datastore identity values of the specified persistent class, or null if the class' identity cannot be represented as a sequence.booleangetIgnoreChanges()Whether to take into account changes in the transaction when executing a query or iterating an extent.BrokergetInnermostDelegate()Return the native delegate.InverseManagergetInverseManager()Return the inverse manager in use.LifecycleEventManagergetLifecycleEventManager()Return the lifecycle event manager associated with the broker.intgetLifecycleListenerCallbackMode()The callback mode for handling exceptions from lifecycle event listeners.intgetLockLevel(Object obj)Return the lock level of the specified object.LockManagergetLockManager()Return the lock manager in use.CollectiongetManagedObjects()Return a list of all managed instances.ManagedRuntimegetManagedRuntime()Return the managed runtime in use.booleangetMultithreaded()Whether the broker or its managed instances are used in a multithreaded environment.booleangetNontransactionalRead()Whether to allow nontransactional access to persistent state.booleangetNontransactionalWrite()Whether to allow nontransactional changes to persistent state.ObjectgetObjectId(Object obj)Return the oid of the given instance.ClassgetObjectIdType(Class cls)Return the application or datastore identity class the given persistent class uses for object ids.booleangetOptimistic()Whether to use optimistic transactional semantics.booleangetOrderDirtyObjects()Whether to maintain the order in which objects are dirtied forStoreContext.getDirtyObjects().CollectiongetPendingTransactionalObjects()Return a list of instances which will become transactional upon the next transaction.CollectiongetPersistedTypes()Return the set of classes that have been made persistent in the current transaction.booleangetPopulateDataCache()Whether objects accessed during this transaction will be added to the store cache.booleangetPostLoadOnMerge()Force sending a @PostLoad lifecycle event while merging.Map<String,Object>getProperties()Retrieve the current properties for this broker Some of these properties may have been changed from the original configuration.intgetRestoreState()Whether to restore an object's original state on rollback.booleangetRetainState()Whether objects retain their persistent state on transaction commit.ThrowablegetRollbackCause()Returns the Throwable that caused the transaction to be marked for rollback.booleangetRollbackOnly()Return whether the current transaction has been marked for rollback.OpenJPAStateManagergetStateManager(Object obj)Return the state manager for the given instance.DelegatingStoreManagergetStoreManager()Return the store manager in use.Set<String>getSupportedProperties()Return the supported properties for this broker as property keys.booleangetSyncWithManagedTransactions()Whether to check for a global transaction upon every managed, non-transactional operation.CollectiongetTransactionalObjects()Return a list of current transaction instances.intgetTransactionListenerCallbackMode()The callback mode for handling exceptions from transaction event listeners.Collection<Object>getTransactionListeners()Gets an umodifiable collection of currently registered lsteners.CollectiongetUpdatedTypes()Return the set of classes for objects that have been modified in the current transaction.ObjectgetUserObject(Object key)Get the value for the specified key from the map of user objects.SeqgetValueSequence(FieldMetaData fmd)Returns aSeqfor the generated values of the specified field, or null if the field is not generated.ObjectgetVersion(Object obj)Returns the current version indicator foro.booleanhasConnection()Whether the broker has a dedicated connection based on the configured connection retain mode and transaction status.inthashCode()booleanisActive()Whether a logical transaction is active.booleanisCached(List<Object> oid)Indicate whether the oid can be found in the StoreContext's L1 cache or in the StoreManager cache.booleanisClosed()Whether the broker is closed.booleanisCloseInvoked()WhetherBroker.close()has been invoked, though the broker might remain open until the current managed transaction completes.booleanisDeleted(Object obj)Return whether the given object is deleted.booleanisDetached(Object obj)Returnstrueifobjis a detached object (one that can be reattached to aBrokervia a call toBroker.attach(java.lang.Object, boolean, org.apache.openjpa.kernel.OpCallbacks)); otherwise returnsfalse.booleanisDetachedNew()Whether to treat relations to detached instances during persist operations as new or as pseudo-hollow instances.booleanisDirty(Object obj)Return whether the given object is dirty.booleanisManaged()Whether this context is using managed transactions.booleanisNew(Object obj)Return whether the given object is a newly-created instance registered withbroker.booleanisPersistent(Object obj)Return whether the given object is persistent.booleanisStoreActive()Whether a data store transaction is active.booleanisTrackChangesByType()Whether memory usage is reduced during this transaction at the expense of tracking changes at the type level instead of the instance level, resulting in more aggressive cache invalidation.booleanisTransactional(Object obj)Return whether the given object is transactional.voidlock()Synchronizes on an internal lock if theMultithreadedflag is set to true.voidlock(Object obj, int level, int timeout, OpCallbacks call)Ensure that the given instance is locked at the given lock level.voidlock(Object obj, OpCallbacks call)Ensure that the given instance is locked at the current lock level, as set in theFetchConfigurationfor the broker.voidlockAll(Collection objs, int level, int timeout, OpCallbacks call)Ensure that the given instances are locked at the given lock level.voidlockAll(Collection objs, OpCallbacks call)Ensure that the given instances are locked at the current lock level, as set in theFetchConfigurationfor the broker.ExtentnewExtent(Class cls, boolean subs)Return an extent of the given class, optionally including subclasses.ObjectnewInstance(Class cls)Create a new instance of typecls.ObjectnewObjectId(Class cls, Object val)Create a new object id instance from the given value.QuerynewQuery(String language, Class cls, Object query)Create a new query from the given data, with the given candidate class and language.QuerynewQuery(String language, Object query)Create a new query in the given language.voidnontransactional(Object pc, OpCallbacks call)Make the given object non-transactional.voidnontransactionalAll(Collection objs, OpCallbacks call)Make the given objects nontransactional.OpenJPAStateManagerpersist(Object obj, Object id, OpCallbacks call)Make the given instance persistent.voidpersist(Object obj, OpCallbacks call)Persist the given object.voidpersistAll(Collection objs, OpCallbacks call)Persist the given objects.voidpopFetchConfiguration()Pops the fetch configuration from the top of the stack, making the next one down the active one.voidpreFlush()Run pre-flush actions on transactional objects, including persistence-by-reachability, inverse relationship management, deletion of dependent instances, and instance callbacks.FetchConfigurationpushFetchConfiguration()Pushes a new fetch configuration that inherits from the current fetch configuration onto a stack, and makes the new configuration the active one.FetchConfigurationpushFetchConfiguration(FetchConfiguration fc)Pushes the fetch configuration argument onto a stack, and makes the new configuration the active one.ObjectputUserObject(Object key, Object val)Put the specified key-value pair into the map of user objects.voidrefresh(Object obj, OpCallbacks call)Refresh the state of the given object.voidrefreshAll(Collection objs, OpCallbacks call)Refresh the state of the given objects.voidrelease(Object obj, OpCallbacks call)Release the given object from management.voidreleaseAll(Collection objs, OpCallbacks call)Release the given objects from management.voidreleaseSavepoint()Release the last set savepoint and any resources associated with it.voidreleaseSavepoint(String name)Release the savepoint and any resources associated with it.voidremoveLifecycleListener(Object listener)Remove a listener for lifecycle-related events.voidremoveTransactionListener(Object listener)Remove a listener for transaction-related events.voidretrieve(Object obj, boolean fgOnly, OpCallbacks call)Immediately load the given object's persistent fields.voidretrieveAll(Collection objs, boolean fgOnly, OpCallbacks call)Retrieve the given objects' persistent state.voidrollback()Rollback the current transaction.voidrollbackAndResume()Issue a rollback and then start a new transaction.voidrollbackToSavepoint()Rollback the current transaction to the last savepoint.voidrollbackToSavepoint(String name)Rollback the current transaction to the given savepoint name.voidsetAllowReferenceToSiblingContext(boolean allow)Affirms if this context will allow its managed instances to refer instances that are managed by other contexts.voidsetAutoClear(int clear)Whether objects clear when entering transactions.voidsetAutoDetach(int flags)Bit flags marked inAutoDetachwhich indicate when persistent managed objects should be automatically detached in-place.voidsetAutoDetach(int flag, boolean on)Bit flags marked inAutoDetachwhich indicate when persistent managed objects should be automatically detached in-place.voidsetCachePreparedQuery(boolean flag)Sets whether this receiver will cache prepared queries during its lifetime.voidsetConnectionFactory2Name(String connectionFactory2Name)Set the 'NonJTA' ConnectionFactoryName.voidsetConnectionFactoryName(String connectionFactoryName)Set the 'JTA' ConnectionFactoryName.voidsetDetachedNew(boolean isNew)Whether to treat relations to detached instances as new.voidsetDetachState(int mode)Detach mode constant to determine which fields are part of the detached graph.voidsetEvictFromDataCache(boolean evict)Whether to also evict an object from the store cache when it is evicted through this broker.voidsetIgnoreChanges(boolean ignore)Whether to take into account changes in the transaction when executing a query or iterating an extent.voidsetImplicitBehavior(OpCallbacks call, RuntimeExceptionTranslator ex)Set the broker's behavior for implicit actions such as flushing, automatic detachment, and exceptions thrown by managed instances outside a broker operation.voidsetLifecycleListenerCallbackMode(int mode)The callback mode for handling exceptions from lifecycle event listeners.voidsetMultithreaded(boolean multi)Whether the broker or its managed instances are used in a multithreaded environment.voidsetNontransactionalRead(boolean read)Whether to allow nontransactional access to persistent state.voidsetNontransactionalWrite(boolean write)Whether to allow nontransactional changes to persistent state.voidsetOptimistic(boolean opt)Whether to use optimistic transactional semantics.voidsetOrderDirtyObjects(boolean order)Whether to maintain the order in which objects are dirtied forStoreContext.getDirtyObjects().voidsetPopulateDataCache(boolean cache)Whether to populate the store cache with objects used by this transaction.voidsetPostLoadOnMerge(boolean allow)Set totrueif the merge operation should trigger a @PostLoad lifecycle event.voidsetRestoreState(int restore)Whether to restore an object's original state on rollback.voidsetRetainState(boolean retain)Whether objects retain their persistent state on transaction commit.voidsetRollbackOnly()Mark the current transaction for rollback.voidsetRollbackOnly(Throwable cause)Mark the current transaction for rollback with the specified cause of the rollback.voidsetSavepoint(String name)Set a transactional savepoint where operations after this savepoint will be rolled back.voidsetSyncWithManagedTransactions(boolean sync)Whether to check for a global transaction upon every managed, non-transactional operation.voidsetTrackChangesByType(boolean largeTransaction)If a large number of objects will be created, modified, or deleted during this transaction setting this option to true will reduce memory usage if you perform periodic flushes by tracking changes at the type level instead of the instance level, resulting in more aggressive cache invalidation.voidsetTransactionListenerCallbackMode(int mode)The callback mode for handling exceptions from transaction event listeners.booleansyncWithManagedTransaction()Attempt to synchronize with a current managed transaction, returning true if successful, false if no managed transaction is active.voidtransactional(Object pc, boolean updateVersion, OpCallbacks call)Make the given object transactional.voidtransactionalAll(Collection objs, boolean updateVersion, OpCallbacks call)Make the given objects transactional.protected RuntimeExceptiontranslate(RuntimeException re)Translate the OpenJPA exception.protected RuntimeExceptiontranslate(RuntimeException re, Object failed)Translate the exception with the failed object.voidunlock()Releases the internal lock.voidvalidateChanges()Validate the changes made in this transaction, reporting any optimistic violations, constraint violations, etc.
-
-
-
Constructor Detail
-
DelegatingBroker
public DelegatingBroker(Broker broker)
Constructor; supply delegate.
-
DelegatingBroker
public DelegatingBroker(Broker broker, RuntimeExceptionTranslator trans)
Constructor; supply delegate and exception translator.
-
-
Method Detail
-
getDelegate
public Broker getDelegate()
Return the direct delegate.
-
getInnermostDelegate
public Broker getInnermostDelegate()
Return the native delegate.
-
translate
protected RuntimeException translate(RuntimeException re)
Translate the OpenJPA exception.
-
translate
protected RuntimeException translate(RuntimeException re, Object failed)
Translate the exception with the failed object.- Parameters:
re- exception raised by the delegate.failed- the context that failed.- Returns:
- the translated exception. If the given input exception had not set the failed instance, then sets the given instance as the failed context.
-
getBroker
public Broker getBroker()
Description copied from interface:StoreContextReturn the broker for this context, if possible. Note that a broker will be unavailable in remote contexts, and this method may return null.- Specified by:
getBrokerin interfaceStoreContext
-
getConfiguration
public OpenJPAConfiguration getConfiguration()
Description copied from interface:StoreContextReturn the configuration associated with this context.- Specified by:
getConfigurationin interfaceStoreContext
-
getFetchConfiguration
public FetchConfiguration getFetchConfiguration()
Description copied from interface:StoreContextReturn the (mutable) fetch configuration for loading objects from this context.- Specified by:
getFetchConfigurationin interfaceStoreContext
-
pushFetchConfiguration
public FetchConfiguration pushFetchConfiguration()
Description copied from interface:StoreContextPushes a new fetch configuration that inherits from the current fetch configuration onto a stack, and makes the new configuration the active one.- Specified by:
pushFetchConfigurationin interfaceStoreContext- Returns:
- the new fetch configuration
-
pushFetchConfiguration
public FetchConfiguration pushFetchConfiguration(FetchConfiguration fc)
Description copied from interface:StoreContextPushes the fetch configuration argument onto a stack, and makes the new configuration the active one.- Specified by:
pushFetchConfigurationin interfaceStoreContext- Returns:
- the new fetch configuration
-
popFetchConfiguration
public void popFetchConfiguration()
Description copied from interface:StoreContextPops the fetch configuration from the top of the stack, making the next one down the active one. This returns void to avoid confusion, since fetch configurations tend to be used in method-chaining patterns often.- Specified by:
popFetchConfigurationin interfaceStoreContext
-
getClassLoader
public ClassLoader getClassLoader()
Description copied from interface:StoreContextReturn the current thread's class loader at the time this context was obtained.- Specified by:
getClassLoaderin interfaceStoreContext
-
getLockManager
public LockManager getLockManager()
Description copied from interface:StoreContextReturn the lock manager in use.- Specified by:
getLockManagerin interfaceStoreContext
-
getStoreManager
public DelegatingStoreManager getStoreManager()
Description copied from interface:StoreContextReturn the store manager in use. This will be a wrapper around the native store manager, which you can retrieve viaDelegatingStoreManager.getInnermostDelegate().- Specified by:
getStoreManagerin interfaceStoreContext
-
getConnectionUserName
public String getConnectionUserName()
Description copied from interface:StoreContextReturn the connection user name.- Specified by:
getConnectionUserNamein interfaceStoreContext
-
getConnectionPassword
public String getConnectionPassword()
Description copied from interface:StoreContextReturn the connection password.- Specified by:
getConnectionPasswordin interfaceStoreContext
-
getProperties
public Map<String,Object> getProperties()
Description copied from interface:BrokerRetrieve the current properties for this broker Some of these properties may have been changed from the original configuration.- Specified by:
getPropertiesin interfaceBroker- Returns:
- the changed properties
-
getSupportedProperties
public Set<String> getSupportedProperties()
Description copied from interface:BrokerReturn the supported properties for this broker as property keys. If a property has multiple keys, all keys will be returned.- Specified by:
getSupportedPropertiesin interfaceBroker
-
find
public Object find(Object oid, boolean validate, FindCallbacks call)
Description copied from interface:StoreContextFind the persistence object with the given oid. Ifvalidateis true, the broker will check the store for the object, and return null if it does not exist. Ifvalidateis false, this method never returns null. The broker will either return its cached instance, attempt to create a hollow instance, or throw anObjectNotFoundExceptionif unable to return a hollow instance.- Specified by:
findin interfaceStoreContextvalidate- if true, validate that the instance exists in the store and load fetch group fields, otherwise return any cached or hollow instance
-
findAll
public Object[] findAll(Collection oids, boolean validate, FindCallbacks call)
Description copied from interface:StoreContextReturn the objects with the given oids.- Specified by:
findAllin interfaceStoreContext- Parameters:
oids- the oids of the objects to return- Returns:
- the objects that were looked up, in the same order as the oids parameter
- See Also:
StoreContext.find(Object,boolean,FindCallbacks)
-
findCached
public Object findCached(Object oid, FindCallbacks call)
Description copied from interface:StoreContextReturn the instance for the given oid/object , or null if not found in the L1 cache.- Specified by:
findCachedin interfaceStoreContext- Parameters:
oid- the object's id- Returns:
- the cached object, or null if not cached
-
find
public Object find(Object oid, FetchConfiguration fetch, BitSet exclude, Object edata, int flags)
Description copied from interface:StoreContextReturn the object with the given oid. If present, the cached instance will be returned. Otherwise, the instance will be initialized through the store as usual; however, in this case the store will be passed the given execution data, and the system will load the object according to the given fetch configuration (or the context's configuration, if the given one is null). Fields can optionally be excluded from required loading using theexcludemask. By default this method does not find new unflushed instances, validates, and does not throw an exception if a cached instance has been deleted concurrently. These options are controllable through the givenOID_XXXflags.- Specified by:
findin interfaceStoreContext
-
findAll
public Object[] findAll(Collection oids, FetchConfiguration fetch, BitSet exclude, Object edata, int flags)
Description copied from interface:StoreContextReturn the objects with the given oids.- Specified by:
findAllin interfaceStoreContext- See Also:
StoreContext.find(Object,FetchConfiguration,BitSet,Object,int)
-
extentIterator
public Iterator extentIterator(Class cls, boolean subs, FetchConfiguration fetch, boolean ignoreChanges)
Description copied from interface:StoreContextReturn an iterator over all instances of the given type. The iterator should be closed withImplHelper.close(java.lang.Object)when no longer needed. This method delegates toStoreManager.executeExtent(org.apache.openjpa.meta.ClassMetaData, boolean, org.apache.openjpa.kernel.FetchConfiguration).- Specified by:
extentIteratorin interfaceStoreContext
-
retrieve
public void retrieve(Object obj, boolean fgOnly, OpCallbacks call)
Description copied from interface:StoreContextImmediately load the given object's persistent fields. One might use this action to make sure that an instance's fields are loaded before transitioning it to transient. Note that this action is not recursive. Any related objects that are loaded will not necessarily have their fields loaded. Unmanaged target is ignored.- Specified by:
retrievein interfaceStoreContextfgOnly- indicator as to whether to retrieve only fields in the current fetch groups, or all fields- See Also:
StoreContext.retrieve(java.lang.Object, boolean, org.apache.openjpa.kernel.OpCallbacks)
-
retrieveAll
public void retrieveAll(Collection objs, boolean fgOnly, OpCallbacks call)
Description copied from interface:StoreContextRetrieve the given objects' persistent state. Unmanaged targets are ignored.- Specified by:
retrieveAllin interfaceStoreContextfgOnly- indicator as to whether to retrieve only fields- See Also:
StoreContext.retrieve(java.lang.Object, boolean, org.apache.openjpa.kernel.OpCallbacks)
-
embed
public OpenJPAStateManager embed(Object obj, Object id, OpenJPAStateManager owner, ValueMetaData ownerMeta)
Description copied from interface:StoreContextMake the given instance embedded.- Specified by:
embedin interfaceStoreContext- Parameters:
obj- the instance to embed; may be null to create a new instanceid- the id to give the embedded state manager; may be null for defaultowner- the owning state managerownerMeta- the value in which the object is embedded- Returns:
- the state manager for the embedded instance
-
getObjectIdType
public Class getObjectIdType(Class cls)
Description copied from interface:StoreContextReturn the application or datastore identity class the given persistent class uses for object ids.- Specified by:
getObjectIdTypein interfaceStoreContext
-
newObjectId
public Object newObjectId(Class cls, Object val)
Description copied from interface:StoreContextCreate a new object id instance from the given value.- Specified by:
newObjectIdin interfaceStoreContext- Parameters:
cls- the persistent class that uses this identity valueval- an object id instance, stringified object id, or primary key value
-
getManagedObjects
public Collection getManagedObjects()
Description copied from interface:StoreContextReturn a list of all managed instances.- Specified by:
getManagedObjectsin interfaceStoreContext
-
getTransactionalObjects
public Collection getTransactionalObjects()
Description copied from interface:StoreContextReturn a list of current transaction instances.- Specified by:
getTransactionalObjectsin interfaceStoreContext
-
getPendingTransactionalObjects
public Collection getPendingTransactionalObjects()
Description copied from interface:StoreContextReturn a list of instances which will become transactional upon the next transaction.- Specified by:
getPendingTransactionalObjectsin interfaceStoreContext
-
getDirtyObjects
public Collection getDirtyObjects()
Description copied from interface:StoreContextReturn a list of current dirty instances.- Specified by:
getDirtyObjectsin interfaceStoreContext
-
getOrderDirtyObjects
public boolean getOrderDirtyObjects()
Description copied from interface:StoreContextWhether to maintain the order in which objects are dirtied forStoreContext.getDirtyObjects(). Default is the store manager's decision.- Specified by:
getOrderDirtyObjectsin interfaceStoreContext
-
setOrderDirtyObjects
public void setOrderDirtyObjects(boolean order)
Description copied from interface:StoreContextWhether to maintain the order in which objects are dirtied forStoreContext.getDirtyObjects(). Default is the store manager's decision.- Specified by:
setOrderDirtyObjectsin interfaceStoreContext
-
getPersistedTypes
public Collection getPersistedTypes()
Description copied from interface:StoreContextReturn the set of classes that have been made persistent in the current transaction.- Specified by:
getPersistedTypesin interfaceStoreContext
-
getUpdatedTypes
public Collection getUpdatedTypes()
Description copied from interface:StoreContextReturn the set of classes for objects that have been modified in the current transaction.- Specified by:
getUpdatedTypesin interfaceStoreContext
-
getDeletedTypes
public Collection getDeletedTypes()
Description copied from interface:StoreContextReturn the set of classes that have been deleted in the current transaction.- Specified by:
getDeletedTypesin interfaceStoreContext
-
getStateManager
public OpenJPAStateManager getStateManager(Object obj)
Description copied from interface:StoreContextReturn the state manager for the given instance. Includes objects made persistent in the current transaction. Ifobjis not a managed type or is managed by another context, throw an exception.- Specified by:
getStateManagerin interfaceStoreContext
-
getLockLevel
public int getLockLevel(Object obj)
Description copied from interface:StoreContextReturn the lock level of the specified object.- Specified by:
getLockLevelin interfaceStoreContext
-
getVersion
public Object getVersion(Object obj)
Description copied from interface:StoreContextReturns the current version indicator foro.- Specified by:
getVersionin interfaceStoreContext
-
isDirty
public boolean isDirty(Object obj)
Description copied from interface:StoreContextReturn whether the given object is dirty.- Specified by:
isDirtyin interfaceStoreContext
-
isTransactional
public boolean isTransactional(Object obj)
Description copied from interface:StoreContextReturn whether the given object is transactional.- Specified by:
isTransactionalin interfaceStoreContext
-
isPersistent
public boolean isPersistent(Object obj)
Description copied from interface:StoreContextReturn whether the given object is persistent.- Specified by:
isPersistentin interfaceStoreContext
-
isNew
public boolean isNew(Object obj)
Description copied from interface:StoreContextReturn whether the given object is a newly-created instance registered withbroker.- Specified by:
isNewin interfaceStoreContext
-
isDeleted
public boolean isDeleted(Object obj)
Description copied from interface:StoreContextReturn whether the given object is deleted.- Specified by:
isDeletedin interfaceStoreContext
-
getObjectId
public Object getObjectId(Object obj)
Description copied from interface:StoreContextReturn the oid of the given instance.- Specified by:
getObjectIdin interfaceStoreContext
-
isManaged
public boolean isManaged()
Description copied from interface:StoreContextWhether this context is using managed transactions.- Specified by:
isManagedin interfaceStoreContext
-
isActive
public boolean isActive()
Description copied from interface:StoreContextWhether a logical transaction is active.- Specified by:
isActivein interfaceStoreContext
-
isStoreActive
public boolean isStoreActive()
Description copied from interface:StoreContextWhether a data store transaction is active.- Specified by:
isStoreActivein interfaceStoreContext
-
hasConnection
public boolean hasConnection()
Description copied from interface:StoreContextWhether the broker has a dedicated connection based on the configured connection retain mode and transaction status.- Specified by:
hasConnectionin interfaceStoreContext
-
getConnection
public Object getConnection()
Description copied from interface:StoreContextReturn the connection in use by the context, or a new connection if none.- Specified by:
getConnectionin interfaceStoreContext
-
lock
public void lock()
Description copied from interface:StoreContextSynchronizes on an internal lock if theMultithreadedflag is set to true. Make sure to callStoreContext.unlock()in a finally clause of the same method.- Specified by:
lockin interfaceStoreContext
-
unlock
public void unlock()
Description copied from interface:StoreContextReleases the internal lock.- Specified by:
unlockin interfaceStoreContext
-
beginOperation
public boolean beginOperation(boolean read)
Description copied from interface:BrokerBegin a logical operation. This indicates to the broker the granularity of an operation which may require pre/post operation side-effects, such as non-tx detach. Will lock the broker until theBroker.endOperation()is called.- Specified by:
beginOperationin interfaceBroker- Parameters:
read- whether instances may be loaded/modified during this operation requiring a re-check of global tx- Returns:
- whether this is the outermost operation on the stack
-
endOperation
public boolean endOperation()
Description copied from interface:BrokerEnd a logical operation. This indicates to the broker the granularity of an operation which may require pre/post operation side-effects, such as non-tx detach. Unlocks the given broker.- Specified by:
endOperationin interfaceBroker- Returns:
- whether this is the outermost operation on the stack
-
setImplicitBehavior
public void setImplicitBehavior(OpCallbacks call, RuntimeExceptionTranslator ex)
Description copied from interface:BrokerSet the broker's behavior for implicit actions such as flushing, automatic detachment, and exceptions thrown by managed instances outside a broker operation. A broker's implicit behavior can only be set once; after the first invocation with non-null arguments, subsequent invocations of this method are ignored.- Specified by:
setImplicitBehaviorin interfaceBroker
-
getBrokerFactory
public BrokerFactory getBrokerFactory()
Description copied from interface:BrokerReturn the factory that produced this broker.- Specified by:
getBrokerFactoryin interfaceBroker
-
getConnectionRetainMode
public int getConnectionRetainMode()
Description copied from interface:BrokerReturn the connection retain mode for this broker.- Specified by:
getConnectionRetainModein interfaceBroker
-
getManagedRuntime
public ManagedRuntime getManagedRuntime()
Description copied from interface:BrokerReturn the managed runtime in use.- Specified by:
getManagedRuntimein interfaceBroker
-
getInverseManager
public InverseManager getInverseManager()
Description copied from interface:BrokerReturn the inverse manager in use.- Specified by:
getInverseManagerin interfaceBroker
-
getMultithreaded
public boolean getMultithreaded()
Description copied from interface:BrokerWhether the broker or its managed instances are used in a multithreaded environment.- Specified by:
getMultithreadedin interfaceBroker
-
setMultithreaded
public void setMultithreaded(boolean multi)
Description copied from interface:BrokerWhether the broker or its managed instances are used in a multithreaded environment.- Specified by:
setMultithreadedin interfaceBroker
-
getIgnoreChanges
public boolean getIgnoreChanges()
Description copied from interface:BrokerWhether to take into account changes in the transaction when executing a query or iterating an extent.- Specified by:
getIgnoreChangesin interfaceBroker
-
setIgnoreChanges
public void setIgnoreChanges(boolean ignore)
Description copied from interface:BrokerWhether to take into account changes in the transaction when executing a query or iterating an extent.- Specified by:
setIgnoreChangesin interfaceBroker
-
getNontransactionalRead
public boolean getNontransactionalRead()
Description copied from interface:BrokerWhether to allow nontransactional access to persistent state.- Specified by:
getNontransactionalReadin interfaceBroker
-
setNontransactionalRead
public void setNontransactionalRead(boolean read)
Description copied from interface:BrokerWhether to allow nontransactional access to persistent state.- Specified by:
setNontransactionalReadin interfaceBroker
-
getNontransactionalWrite
public boolean getNontransactionalWrite()
Description copied from interface:BrokerWhether to allow nontransactional changes to persistent state.- Specified by:
getNontransactionalWritein interfaceBroker
-
setNontransactionalWrite
public void setNontransactionalWrite(boolean write)
Description copied from interface:BrokerWhether to allow nontransactional changes to persistent state.- Specified by:
setNontransactionalWritein interfaceBroker
-
getRestoreState
public int getRestoreState()
Description copied from interface:BrokerWhether to restore an object's original state on rollback.- Specified by:
getRestoreStatein interfaceBroker
-
setRestoreState
public void setRestoreState(int restore)
Description copied from interface:BrokerWhether to restore an object's original state on rollback.- Specified by:
setRestoreStatein interfaceBroker
-
getOptimistic
public boolean getOptimistic()
Description copied from interface:BrokerWhether to use optimistic transactional semantics.- Specified by:
getOptimisticin interfaceBroker
-
setOptimistic
public void setOptimistic(boolean opt)
Description copied from interface:BrokerWhether to use optimistic transactional semantics.- Specified by:
setOptimisticin interfaceBroker
-
getRetainState
public boolean getRetainState()
Description copied from interface:BrokerWhether objects retain their persistent state on transaction commit.- Specified by:
getRetainStatein interfaceBroker
-
setRetainState
public void setRetainState(boolean retain)
Description copied from interface:BrokerWhether objects retain their persistent state on transaction commit.- Specified by:
setRetainStatein interfaceBroker
-
getAutoClear
public int getAutoClear()
Description copied from interface:BrokerWhether objects clear when entering transactions.- Specified by:
getAutoClearin interfaceBroker
-
setAutoClear
public void setAutoClear(int clear)
Description copied from interface:BrokerWhether objects clear when entering transactions.- Specified by:
setAutoClearin interfaceBroker
-
getAutoDetach
public int getAutoDetach()
Description copied from interface:BrokerBit flags marked inAutoDetachwhich indicate when persistent managed objects should be automatically detached in-place.- Specified by:
getAutoDetachin interfaceBroker
-
setAutoDetach
public void setAutoDetach(int flags)
Description copied from interface:BrokerBit flags marked inAutoDetachwhich indicate when persistent managed objects should be automatically detached in-place.- Specified by:
setAutoDetachin interfaceBroker
-
setAutoDetach
public void setAutoDetach(int flag, boolean on)Description copied from interface:BrokerBit flags marked inAutoDetachwhich indicate when persistent managed objects should be automatically detached in-place.- Specified by:
setAutoDetachin interfaceBroker
-
getDetachState
public int getDetachState()
Description copied from interface:StoreContextDetach mode constant to determine which fields are part of the detached graph. Defaults toDetachState.DETACH_LOADED.- Specified by:
getDetachStatein interfaceStoreContext
-
setDetachState
public void setDetachState(int mode)
Description copied from interface:StoreContextDetach mode constant to determine which fields are part of the detached graph. Defaults toDetachState.DETACH_LOADED.- Specified by:
setDetachStatein interfaceStoreContext
-
isDetachedNew
public boolean isDetachedNew()
Description copied from interface:BrokerWhether to treat relations to detached instances during persist operations as new or as pseudo-hollow instances.- Specified by:
isDetachedNewin interfaceBroker
-
setDetachedNew
public void setDetachedNew(boolean isNew)
Description copied from interface:BrokerWhether to treat relations to detached instances as new.- Specified by:
setDetachedNewin interfaceBroker
-
getSyncWithManagedTransactions
public boolean getSyncWithManagedTransactions()
Description copied from interface:BrokerWhether to check for a global transaction upon every managed, non-transactional operation. Defaults to false.- Specified by:
getSyncWithManagedTransactionsin interfaceBroker
-
setSyncWithManagedTransactions
public void setSyncWithManagedTransactions(boolean sync)
Description copied from interface:BrokerWhether to check for a global transaction upon every managed, non-transactional operation. Defaults to false.- Specified by:
setSyncWithManagedTransactionsin interfaceBroker
-
getEvictFromDataCache
public boolean getEvictFromDataCache()
Description copied from interface:BrokerWhether to also evict an object from the store cache when it is evicted through this broker.- Specified by:
getEvictFromDataCachein interfaceBroker
-
setEvictFromDataCache
public void setEvictFromDataCache(boolean evict)
Description copied from interface:BrokerWhether to also evict an object from the store cache when it is evicted through this broker.- Specified by:
setEvictFromDataCachein interfaceBroker
-
getPopulateDataCache
public boolean getPopulateDataCache()
Description copied from interface:StoreContextWhether objects accessed during this transaction will be added to the store cache. Defaults to true.- Specified by:
getPopulateDataCachein interfaceStoreContext
-
setPopulateDataCache
public void setPopulateDataCache(boolean cache)
Description copied from interface:StoreContextWhether to populate the store cache with objects used by this transaction. Defaults to true.- Specified by:
setPopulateDataCachein interfaceStoreContext
-
isTrackChangesByType
public boolean isTrackChangesByType()
Description copied from interface:StoreContextWhether memory usage is reduced during this transaction at the expense of tracking changes at the type level instead of the instance level, resulting in more aggressive cache invalidation.- Specified by:
isTrackChangesByTypein interfaceStoreContext
-
setTrackChangesByType
public void setTrackChangesByType(boolean largeTransaction)
Description copied from interface:StoreContextIf a large number of objects will be created, modified, or deleted during this transaction setting this option to true will reduce memory usage if you perform periodic flushes by tracking changes at the type level instead of the instance level, resulting in more aggressive cache invalidation. Upon transaction commit the data cache will have to more aggressively flush objects. The store cache will have to flush instances of objects for each class of object modified during the transaction. A side benefit of large transaction mode is that smaller update messages can be used forRemoteCommitEvents. Defaults to false.- Specified by:
setTrackChangesByTypein interfaceStoreContext
-
putUserObject
public Object putUserObject(Object key, Object val)
Description copied from interface:BrokerPut the specified key-value pair into the map of user objects. Use a value of null to remove the key.- Specified by:
putUserObjectin interfaceBroker
-
getUserObject
public Object getUserObject(Object key)
Description copied from interface:BrokerGet the value for the specified key from the map of user objects.- Specified by:
getUserObjectin interfaceBroker
-
addTransactionListener
public void addTransactionListener(Object listener)
Description copied from interface:BrokerRegister a listener for transaction-related events.- Specified by:
addTransactionListenerin interfaceBroker
-
removeTransactionListener
public void removeTransactionListener(Object listener)
Description copied from interface:BrokerRemove a listener for transaction-related events.- Specified by:
removeTransactionListenerin interfaceBroker
-
getTransactionListeners
public Collection<Object> getTransactionListeners()
Description copied from interface:BrokerGets an umodifiable collection of currently registered lsteners.- Specified by:
getTransactionListenersin interfaceBroker
-
getTransactionListenerCallbackMode
public int getTransactionListenerCallbackMode()
Description copied from interface:BrokerThe callback mode for handling exceptions from transaction event listeners.- Specified by:
getTransactionListenerCallbackModein interfaceBroker
-
setTransactionListenerCallbackMode
public void setTransactionListenerCallbackMode(int mode)
Description copied from interface:BrokerThe callback mode for handling exceptions from transaction event listeners.- Specified by:
setTransactionListenerCallbackModein interfaceBroker
-
addLifecycleListener
public void addLifecycleListener(Object listener, Class[] classes)
Description copied from interface:BrokerRegister a listener for lifecycle-related events on the specified classes. If the classes are null, all events will be propagated to the listener.- Specified by:
addLifecycleListenerin interfaceBroker
-
removeLifecycleListener
public void removeLifecycleListener(Object listener)
Description copied from interface:BrokerRemove a listener for lifecycle-related events.- Specified by:
removeLifecycleListenerin interfaceBroker
-
getLifecycleListenerCallbackMode
public int getLifecycleListenerCallbackMode()
Description copied from interface:BrokerThe callback mode for handling exceptions from lifecycle event listeners.- Specified by:
getLifecycleListenerCallbackModein interfaceBroker
-
setLifecycleListenerCallbackMode
public void setLifecycleListenerCallbackMode(int mode)
Description copied from interface:BrokerThe callback mode for handling exceptions from lifecycle event listeners.- Specified by:
setLifecycleListenerCallbackModein interfaceBroker
-
getLifecycleEventManager
public LifecycleEventManager getLifecycleEventManager()
Description copied from interface:BrokerReturn the lifecycle event manager associated with the broker.- Specified by:
getLifecycleEventManagerin interfaceBroker
-
begin
public void begin()
Description copied from interface:BrokerBegin a transaction.
-
commit
public void commit()
Description copied from interface:BrokerCommit the current transaction.
-
rollback
public void rollback()
Description copied from interface:BrokerRollback the current transaction.
-
syncWithManagedTransaction
public boolean syncWithManagedTransaction()
Description copied from interface:BrokerAttempt to synchronize with a current managed transaction, returning true if successful, false if no managed transaction is active.- Specified by:
syncWithManagedTransactionin interfaceBroker
-
commitAndResume
public void commitAndResume()
Description copied from interface:BrokerIssue a commit and then start a new transaction. This is identical to:broker.commit (); broker.begin ();
except that the broker's internal atomic lock is utilized, so this method can be safely executed from multiple threads.- Specified by:
commitAndResumein interfaceBroker- See Also:
Broker.commit(),Broker.begin()
-
rollbackAndResume
public void rollbackAndResume()
Description copied from interface:BrokerIssue a rollback and then start a new transaction. This is identical to:broker.rollback (); broker.begin ();
except that the broker's internal atomic lock is utilized, so this method can be safely executed from multiple threads.- Specified by:
rollbackAndResumein interfaceBroker- See Also:
Broker.rollback(),Broker.begin()
-
setRollbackOnly
public void setRollbackOnly()
Description copied from interface:BrokerMark the current transaction for rollback.- Specified by:
setRollbackOnlyin interfaceBroker
-
setRollbackOnly
public void setRollbackOnly(Throwable cause)
Description copied from interface:BrokerMark the current transaction for rollback with the specified cause of the rollback.- Specified by:
setRollbackOnlyin interfaceBroker
-
getRollbackCause
public Throwable getRollbackCause()
Description copied from interface:BrokerReturns the Throwable that caused the transaction to be marked for rollback.- Specified by:
getRollbackCausein interfaceBroker- Returns:
- the Throwable, or null if none was given
-
getRollbackOnly
public boolean getRollbackOnly()
Description copied from interface:BrokerReturn whether the current transaction has been marked for rollback.- Specified by:
getRollbackOnlyin interfaceBroker
-
setSavepoint
public void setSavepoint(String name)
Description copied from interface:BrokerSet a transactional savepoint where operations after this savepoint will be rolled back.- Specified by:
setSavepointin interfaceBroker
-
rollbackToSavepoint
public void rollbackToSavepoint()
Description copied from interface:BrokerRollback the current transaction to the last savepoint. Savepoints set after this one will become invalid.- Specified by:
rollbackToSavepointin interfaceBroker
-
rollbackToSavepoint
public void rollbackToSavepoint(String name)
Description copied from interface:BrokerRollback the current transaction to the given savepoint name. Savepoints set after this one will become invalid.- Specified by:
rollbackToSavepointin interfaceBroker
-
releaseSavepoint
public void releaseSavepoint()
Description copied from interface:BrokerRelease the last set savepoint and any resources associated with it. The given savepoint and any set after it will become invalid.- Specified by:
releaseSavepointin interfaceBroker
-
releaseSavepoint
public void releaseSavepoint(String name)
Description copied from interface:BrokerRelease the savepoint and any resources associated with it. The given savepoint and any set after it will become invalid.- Specified by:
releaseSavepointin interfaceBroker
-
flush
public void flush()
Description copied from interface:BrokerFlush all transactional instances to the data store. This method may set the rollback only flag on the current transaction if it encounters an error.
-
preFlush
public void preFlush()
Description copied from interface:BrokerRun pre-flush actions on transactional objects, including persistence-by-reachability, inverse relationship management, deletion of dependent instances, and instance callbacks. Transaction listeners are not invoked.
-
validateChanges
public void validateChanges()
Description copied from interface:BrokerValidate the changes made in this transaction, reporting any optimistic violations, constraint violations, etc. In a datastore transaction or a flushed optimistic transaction, this method will act just likeBroker.flush(). In an optimistic transaction that has not yet begun a datastore-level transaction, however, it will only report exceptions that would occur on flush, without retaining any datastore resources.- Specified by:
validateChangesin interfaceBroker
-
beginStore
public void beginStore()
Description copied from interface:StoreContextBegin a data store transaction.- Specified by:
beginStorein interfaceStoreContext
-
persist
public void persist(Object obj, OpCallbacks call)
Description copied from interface:BrokerPersist the given object.
-
persistAll
public void persistAll(Collection objs, OpCallbacks call)
Description copied from interface:BrokerPersist the given objects.- Specified by:
persistAllin interfaceBroker
-
persist
public OpenJPAStateManager persist(Object obj, Object id, OpCallbacks call)
Description copied from interface:BrokerMake the given instance persistent. Unlike other persist operations, this method does not immediately cascade to fields markedValueMetaData.CASCADE_IMMEDIATE.
-
delete
public void delete(Object obj, OpCallbacks call)
Description copied from interface:BrokerDelete the given object.
-
deleteAll
public void deleteAll(Collection objs, OpCallbacks call)
Description copied from interface:BrokerDelete the given objects.
-
release
public void release(Object obj, OpCallbacks call)
Description copied from interface:BrokerRelease the given object from management. This operation is not recursive.
-
releaseAll
public void releaseAll(Collection objs, OpCallbacks call)
Description copied from interface:BrokerRelease the given objects from management. This operation is not recursive.- Specified by:
releaseAllin interfaceBroker
-
refresh
public void refresh(Object obj, OpCallbacks call)
Description copied from interface:BrokerRefresh the state of the given object.
-
refreshAll
public void refreshAll(Collection objs, OpCallbacks call)
Description copied from interface:BrokerRefresh the state of the given objects.- Specified by:
refreshAllin interfaceBroker
-
evict
public void evict(Object obj, OpCallbacks call)
Description copied from interface:BrokerEvict the given object.
-
evictAll
public void evictAll(Collection objs, OpCallbacks call)
Description copied from interface:BrokerEvict the given objects.
-
evictAll
public void evictAll(OpCallbacks call)
Description copied from interface:BrokerEvict all clean objects.
-
evictAll
public void evictAll(Extent extent, OpCallbacks call)
Description copied from interface:BrokerEvict all persistent-clean and persistent-nontransactional instances in the givenExtent.
-
detach
public Object detach(Object obj, OpCallbacks call)
Description copied from interface:BrokerDetach the specified object from the broker.
-
detachAll
public Object[] detachAll(Collection objs, OpCallbacks call)
Description copied from interface:BrokerDetach the specified objects from the broker. The objects returned can be manipulated and re-attached withBroker.attachAll(java.util.Collection, boolean, org.apache.openjpa.kernel.OpCallbacks). The detached instances will be unmanaged copies of the specified parameters, and are suitable for serialization and manipulation outside of a OpenJPA environment. When detaching instances, only fields in the currentFetchConfigurationwill be traversed. Thus, to detach a graph of objects, relations to other persistent instances must either be in thedefault-fetch-group, or in the current customFetchConfiguration.
-
detachAll
public void detachAll(OpCallbacks call)
Description copied from interface:BrokerDetach all objects in place. A flush will be performed before detaching the entities.
-
detachAll
public void detachAll(OpCallbacks call, boolean flush)
Description copied from interface:BrokerDetach all objects in place, with the option of performing a flush before doing the detachment.
-
attach
public Object attach(Object obj, boolean copyNew, OpCallbacks call)
Description copied from interface:BrokerImport the specified detached object into the broker.
-
attachAll
public Object[] attachAll(Collection objs, boolean copyNew, OpCallbacks call)
Description copied from interface:BrokerImport the specified objects into the broker. Instances that were previously detached from this or another broker will have their changed merged into the persistent instances. Instances that are new will be persisted as new instances.
-
transactional
public void transactional(Object pc, boolean updateVersion, OpCallbacks call)
Description copied from interface:StoreContextMake the given object transactional.- Specified by:
transactionalin interfaceStoreContext- Parameters:
pc- instance to make transactionalupdateVersion- if true, the instance's version will be incremented at the next flush
-
transactionalAll
public void transactionalAll(Collection objs, boolean updateVersion, OpCallbacks call)
Description copied from interface:StoreContextMake the given objects transactional.- Specified by:
transactionalAllin interfaceStoreContext- Parameters:
objs- instances to make transactionalupdateVersion- if true, the instance's version will be incremented at the next flush
-
nontransactional
public void nontransactional(Object pc, OpCallbacks call)
Description copied from interface:StoreContextMake the given object non-transactional.- Specified by:
nontransactionalin interfaceStoreContext
-
nontransactionalAll
public void nontransactionalAll(Collection objs, OpCallbacks call)
Description copied from interface:StoreContextMake the given objects nontransactional.- Specified by:
nontransactionalAllin interfaceStoreContext
-
newExtent
public Extent newExtent(Class cls, boolean subs)
Description copied from interface:BrokerReturn an extent of the given class, optionally including subclasses.
-
newQuery
public Query newQuery(String language, Class cls, Object query)
Description copied from interface:BrokerCreate a new query from the given data, with the given candidate class and language.
-
newQuery
public Query newQuery(String language, Object query)
Description copied from interface:BrokerCreate a new query in the given language.
-
getIdentitySequence
public Seq getIdentitySequence(ClassMetaData meta)
Description copied from interface:BrokerReturns aSeqfor the datastore identity values of the specified persistent class, or null if the class' identity cannot be represented as a sequence.- Specified by:
getIdentitySequencein interfaceBroker
-
getValueSequence
public Seq getValueSequence(FieldMetaData fmd)
Description copied from interface:BrokerReturns aSeqfor the generated values of the specified field, or null if the field is not generated.- Specified by:
getValueSequencein interfaceBroker
-
lock
public void lock(Object obj, int level, int timeout, OpCallbacks call)
Description copied from interface:BrokerEnsure that the given instance is locked at the given lock level.
-
lock
public void lock(Object obj, OpCallbacks call)
Description copied from interface:BrokerEnsure that the given instance is locked at the current lock level, as set in theFetchConfigurationfor the broker.
-
lockAll
public void lockAll(Collection objs, int level, int timeout, OpCallbacks call)
Description copied from interface:BrokerEnsure that the given instances are locked at the given lock level.
-
lockAll
public void lockAll(Collection objs, OpCallbacks call)
Description copied from interface:BrokerEnsure that the given instances are locked at the current lock level, as set in theFetchConfigurationfor the broker.
-
cancelAll
public boolean cancelAll()
Description copied from interface:BrokerCancel all pending data store statements. If statements are cancelled while a flush is in progress, the transaction rollback only flag will be set.
-
dirtyType
public void dirtyType(Class cls)
Description copied from interface:BrokerMark the given class as dirty within the current transaction.
-
close
public void close()
Description copied from interface:BrokerClose the broker.
-
isClosed
public boolean isClosed()
Description copied from interface:BrokerWhether the broker is closed.
-
isCloseInvoked
public boolean isCloseInvoked()
Description copied from interface:BrokerWhetherBroker.close()has been invoked, though the broker might remain open until the current managed transaction completes.- Specified by:
isCloseInvokedin interfaceBroker
-
assertOpen
public void assertOpen()
Description copied from interface:BrokerThrow an exception if this broker has been closed.- Specified by:
assertOpenin interfaceBroker
-
assertActiveTransaction
public void assertActiveTransaction()
Description copied from interface:BrokerThrow an exception if there is no active transaction.- Specified by:
assertActiveTransactionin interfaceBroker
-
assertNontransactionalRead
public void assertNontransactionalRead()
Description copied from interface:BrokerThrow an exception if there is no transaction active and nontransactional reading is not enabled.- Specified by:
assertNontransactionalReadin interfaceBroker
-
assertWriteOperation
public void assertWriteOperation()
Description copied from interface:BrokerThrow an exception if a write operation is not permitted (there is no active transaction and nontransactional writing is not enabled).- Specified by:
assertWriteOperationin interfaceBroker
-
beforeCompletion
public void beforeCompletion()
- Specified by:
beforeCompletionin interfacejakarta.transaction.Synchronization
-
afterCompletion
public void afterCompletion(int status)
- Specified by:
afterCompletionin interfacejakarta.transaction.Synchronization
-
newInstance
public Object newInstance(Class cls)
Description copied from interface:BrokerCreate a new instance of typecls. Ifclsis an interface or an abstract class whose abstract methods follow the JavaBeans convention, this method will create a concrete implementation according to the metadata that defines the class. Otherwise, ifclsis a managed type, this will return an instance of the specified class.- Specified by:
newInstancein interfaceBroker
-
isDetached
public boolean isDetached(Object obj)
Description copied from interface:BrokerReturnstrueifobjis a detached object (one that can be reattached to aBrokervia a call toBroker.attach(java.lang.Object, boolean, org.apache.openjpa.kernel.OpCallbacks)); otherwise returnsfalse.- Specified by:
isDetachedin interfaceBroker
-
getCachePreparedQuery
public boolean getCachePreparedQuery()
Description copied from interface:BrokerAffirms if this receiver is caching prepared queries.- Specified by:
getCachePreparedQueryin interfaceBroker
-
setCachePreparedQuery
public void setCachePreparedQuery(boolean flag)
Description copied from interface:BrokerSets whether this receiver will cache prepared queries during its lifetime. The cache configured at BrokerFactory level is not affected by setting it inactive for this receiver.- Specified by:
setCachePreparedQueryin interfaceBroker
-
getConnectionFactoryName
public String getConnectionFactoryName()
Description copied from interface:StoreContextReturn the 'JTA' connectionFactoryName- Specified by:
getConnectionFactoryNamein interfaceStoreContext
-
setConnectionFactoryName
public void setConnectionFactoryName(String connectionFactoryName)
Description copied from interface:StoreContextSet the 'JTA' ConnectionFactoryName.- Specified by:
setConnectionFactoryNamein interfaceStoreContext
-
getConnectionFactory2Name
public String getConnectionFactory2Name()
Description copied from interface:StoreContextReturn the 'NonJTA' ConnectionFactoryName.- Specified by:
getConnectionFactory2Namein interfaceStoreContext
-
setConnectionFactory2Name
public void setConnectionFactory2Name(String connectionFactory2Name)
Description copied from interface:StoreContextSet the 'NonJTA' ConnectionFactoryName.- Specified by:
setConnectionFactory2Namein interfaceStoreContext
-
getConnectionFactory
public Object getConnectionFactory()
Description copied from interface:StoreContextReturn the 'JTA' ConnectionFactory, looking it up from JNDI if needed.- Specified by:
getConnectionFactoryin interfaceStoreContext- Returns:
- the JTA connection factory or null if connectionFactoryName is blank.
-
getConnectionFactory2
public Object getConnectionFactory2()
Description copied from interface:StoreContextReturn the 'NonJTA' ConnectionFactory, looking it up from JNDI if needed.- Specified by:
getConnectionFactory2in interfaceStoreContext- Returns:
- the NonJTA connection factory or null if connectionFactoryName is blank.
-
isCached
public boolean isCached(List<Object> oid)
Description copied from interface:StoreContextIndicate whether the oid can be found in the StoreContext's L1 cache or in the StoreManager cache.- Specified by:
isCachedin interfaceStoreContext- Parameters:
oid- List of ObjectIds for PersistenceCapables which may be found in memory.- Returns:
- true if the oid is available in memory (cached) otherwise false.
-
getAllowReferenceToSiblingContext
public boolean getAllowReferenceToSiblingContext()
Description copied from interface:StoreContextAffirms if this context will allow its managed instances to refer instances that are managed by other contexts.- Specified by:
getAllowReferenceToSiblingContextin interfaceStoreContext- Returns:
- false by default.
-
setAllowReferenceToSiblingContext
public void setAllowReferenceToSiblingContext(boolean allow)
Description copied from interface:StoreContextAffirms if this context will allow its managed instances to refer instances that are managed by other contexts. Note: Some specification (such as JPA) does not warranty predictable behavior when strict group-like property of a persistent context (where managed instances can only refer to instances managed by the same context). Please be aware of consequences when the flag is set to true.- Specified by:
setAllowReferenceToSiblingContextin interfaceStoreContext
-
getPostLoadOnMerge
public boolean getPostLoadOnMerge()
Description copied from interface:StoreContextForce sending a @PostLoad lifecycle event while merging.- Specified by:
getPostLoadOnMergein interfaceStoreContext- Returns:
falseby default
-
setPostLoadOnMerge
public void setPostLoadOnMerge(boolean allow)
Description copied from interface:StoreContextSet totrueif the merge operation should trigger a @PostLoad lifecycle event.- Specified by:
setPostLoadOnMergein interfaceStoreContext- Parameters:
allow- PostLoad lifecycle events to be triggered on a merge operation
-
-