kodo.kernel
Class KodoBroker

java.lang.Object
  org.apache.openjpa.kernel.BrokerImpl
      kodo.kernel.KodoBroker

All Implemented Interfaces:

Serializable, Cloneable, Synchronization, KodoStoreContext, CallbackModes, AutoClear, AutoDetach, Broker, ConnectionRetainModes, DetachState, FindCallbacks, LockLevels, RestoreState, StoreContext, Closeable

Direct Known Subclasses:

FinalizingKodoBroker

public class KodoBroker
extends BrokerImpl
implements KodoStoreContext

Kodo extensions to standard Broker.

See Also:

Serialized Form

Field Summary

Fields inherited from class org.apache.openjpa.kernel.BrokerImpl

FLUSH_COMMIT, FLUSH_INC, FLUSH_LOGICAL, FLUSH_ROLLBACK

Fields inherited from interface org.apache.openjpa.kernel.StoreContext

EXCLUDE_ALL, OID_ALLOW_NEW, OID_COPY, OID_NODELETED, OID_NOVALIDATE

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.AutoClear

CLEAR_ALL, CLEAR_DATASTORE

Fields inherited from interface org.apache.openjpa.kernel.AutoDetach

DETACH_CLOSE, DETACH_COMMIT, DETACH_NONTXREAD, DETACH_ROLLBACK

Fields inherited from interface org.apache.openjpa.event.CallbackModes

CALLBACK_FAIL_FAST, CALLBACK_IGNORE, CALLBACK_LOG, CALLBACK_RETHROW, CALLBACK_ROLLBACK

Constructor Summary

KodoBroker()

Method Summary

Object	attach(Object obj, boolean copyNew, OpCallbacks call)
Object[]	attachAll(Collection objs, boolean copyNew, OpCallbacks call)
void	begin()
void	commit()
void	delete(Object obj, OpCallbacks call)
void	deleteAll(Collection objs, OpCallbacks call)
Object	detach(Object obj, OpCallbacks call)
Object[]	detachAll(Collection objs, OpCallbacks call)
void	detachAll(OpCallbacks call)
void	evict(Object obj, OpCallbacks call)
void	evictAll(Collection objs, OpCallbacks call)
void	evictAll(Extent ext, OpCallbacks call)
void	evictAll(OpCallbacks call)
Object	find(Object oid, boolean validate, FindCallbacks call)
Object[]	findAll(Collection oids, boolean validate, FindCallbacks call)
protected void	free()
ProfilingAgent	getProfilingAgent()
void	initialize(AbstractBrokerFactory factory, DelegatingStoreManager sm, boolean managed, int connMode, boolean fromDeserialization)
protected StateManagerImpl	initialize(StateManagerImpl sm, boolean load, FetchConfiguration fetch, Object edata)
Query	newQuery(String lang, Class candidate, Object query)
Query	newQuery(String lang, Object query)
protected QueryImpl	newQueryImpl(String language, StoreQuery sq)
protected StateManagerImpl	newStateManagerImpl(Object oid, ClassMetaData meta)
void	nontransactional(Object obj, OpCallbacks call)
void	nontransactionalAll(Collection objs, OpCallbacks call)
void	persist(Object obj, OpCallbacks call)
void	persistAll(Collection objs, OpCallbacks call)
void	refresh(Object obj, OpCallbacks call)
void	refreshAll(Collection objs, OpCallbacks call)
void	release(Object obj, OpCallbacks call)
void	releaseAll(Collection objs, OpCallbacks call)
void	retrieve(Object obj, boolean fgs, OpCallbacks call)
void	retrieveAll(Collection objs, boolean fgs, OpCallbacks call)
void	rollback()
void	transactional(Object obj, boolean versn, OpCallbacks call)
void	transactionalAll(Collection objs, boolean versn, OpCallbacks call)

Methods inherited from class org.apache.openjpa.kernel.BrokerImpl

addLifecycleListener, addTransactionListener, afterCompletion, assertActiveTransaction, assertNontransactionalRead, assertOpen, assertPersistenceCapable, assertWriteOperation, assignObjectId, beforeCompletion, beginOperation, beginStore, cancelAll, checkForDuplicateId, clone, close, commitAndResume, detachAll, dirtyType, embed, endOperation, endTransaction, extentIterator, find, find, findAll, findAll, findCached, flush, flush, getAutoClear, getAutoDetach, getBroker, getBrokerFactory, getClassLoader, getConfiguration, getConnection, getConnectionPassword, getConnectionRetainMode, getConnectionUserName, getDeletedTypes, getDetachState, getDirtyObjects, getDirtyStates, getEvictFromDataCache, getFetchConfiguration, getIdentitySequence, getIgnoreChanges, getInverseManager, getLifecycleEventManager, getLifecycleListenerCallbackMode, getLockLevel, getLockManager, getManagedObjects, getManagedRuntime, getManagedStates, getMultithreaded, getNontransactionalRead, getNontransactionalWrite, getObjectId, getObjectIdType, getOperatingSet, getOptimistic, getOrderDirtyObjects, getPendingTransactionalObjects, getPendingTransactionalStates, getPersistedTypes, getPopulateDataCache, getRestoreState, getRetainState, getRollbackCause, getRollbackOnly, getStateManager, getStateManagerImpl, getStateManagerImplById, getStoreManager, getSynchronization, getSyncWithManagedTransactions, getTransactionalObjects, getTransactionalStates, getTransactionListenerCallbackMode, getUpdatedTypes, getUserObject, getValueSequence, getVersion, hasConnection, isActive, isClosed, isCloseInvoked, isDeleted, isDetached, isDetachedNew, isDirty, isManaged, isNew, isPersistent, isStoreActive, isTrackChangesByType, isTransactional, lock, lock, lock, lockAll, lockAll, newExtent, newInstance, newManagedObjectCache, newObjectId, persist, persist, persist, persistAll, popFetchConfiguration, preFlush, processArgument, processReturn, pushFetchConfiguration, putUserObject, refreshInternal, refreshInternal, releaseSavepoint, releaseSavepoint, removeLifecycleListener, removeTransactionListener, rollbackAndResume, rollbackToSavepoint, rollbackToSavepoint, setAuthentication, setAutoClear, setAutoDetach, setAutoDetach, setDetachedNew, setDetachState, setEvictFromDataCache, setIgnoreChanges, setImplicitBehavior, setLifecycleListenerCallbackMode, setMultithreaded, setNontransactionalRead, setNontransactionalWrite, setOptimistic, setOrderDirtyObjects, setPopulateDataCache, setRestoreState, setRetainState, setRollbackOnly, setRollbackOnly, setSavepoint, setSynchronization, setSyncWithManagedTransactions, setTrackChangesByType, setTransactionListenerCallbackMode, syncWithManagedTransaction, unlock, validateChanges

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.openjpa.kernel.StoreContext

beginStore, embed, extentIterator, find, findAll, findCached, getBroker, getClassLoader, getConfiguration, getConnection, getConnectionPassword, getConnectionUserName, getDeletedTypes, getDetachState, getDirtyObjects, getFetchConfiguration, getLockLevel, getLockManager, getManagedObjects, getObjectId, getObjectIdType, getOrderDirtyObjects, getPendingTransactionalObjects, getPersistedTypes, getPopulateDataCache, getStateManager, getStoreManager, getTransactionalObjects, getUpdatedTypes, getVersion, hasConnection, isActive, isDeleted, isDirty, isManaged, isNew, isPersistent, isStoreActive, isTrackChangesByType, isTransactional, lock, newObjectId, popFetchConfiguration, pushFetchConfiguration, setDetachState, setOrderDirtyObjects, setPopulateDataCache, setTrackChangesByType, unlock

Constructor Detail

KodoBroker

public KodoBroker()

Method Detail

initialize

public void initialize(AbstractBrokerFactory factory,
                       DelegatingStoreManager sm,
                       boolean managed,
                       int connMode,
                       boolean fromDeserialization)

Overrides:

initialize in class BrokerImpl

newStateManagerImpl

protected StateManagerImpl newStateManagerImpl(Object oid,
                                               ClassMetaData meta)

Overrides:

newStateManagerImpl in class BrokerImpl

initialize

protected StateManagerImpl initialize(StateManagerImpl sm,
                                      boolean load,
                                      FetchConfiguration fetch,
                                      Object edata)

Overrides:

initialize in class BrokerImpl

begin

public void begin()

Specified by:

begin in interface Broker

Overrides:

begin in class BrokerImpl

commit

public void commit()

Specified by:

commit in interface Broker

Overrides:

commit in class BrokerImpl

rollback

public void rollback()

Specified by:

rollback in interface Broker

Overrides:

rollback in class BrokerImpl

newQueryImpl

protected QueryImpl newQueryImpl(String language,
                                 StoreQuery sq)

Overrides:

newQueryImpl in class BrokerImpl

free

protected void free()

Overrides:

free in class BrokerImpl

getProfilingAgent

public ProfilingAgent getProfilingAgent()

persist

public void persist(Object obj,
                    OpCallbacks call)

Specified by:

persist in interface Broker

Overrides:

persist in class BrokerImpl

persistAll

public void persistAll(Collection objs,
                       OpCallbacks call)

Specified by:

persistAll in interface Broker

Overrides:

persistAll in class BrokerImpl

delete

public void delete(Object obj,
                   OpCallbacks call)

Specified by:

delete in interface Broker

Overrides:

delete in class BrokerImpl

deleteAll

public void deleteAll(Collection objs,
                      OpCallbacks call)

Specified by:

deleteAll in interface Broker

Overrides:

deleteAll in class BrokerImpl

refresh

public void refresh(Object obj,
                    OpCallbacks call)

Specified by:

refresh in interface Broker

Overrides:

refresh in class BrokerImpl

refreshAll

public void refreshAll(Collection objs,
                       OpCallbacks call)

Specified by:

refreshAll in interface Broker

Overrides:

refreshAll in class BrokerImpl

release

public void release(Object obj,
                    OpCallbacks call)

Specified by:

release in interface Broker

Overrides:

release in class BrokerImpl

releaseAll

public void releaseAll(Collection objs,
                       OpCallbacks call)

Specified by:

releaseAll in interface Broker

Overrides:

releaseAll in class BrokerImpl

transactional

public void transactional(Object obj,
                          boolean versn,
                          OpCallbacks call)

Specified by:

transactional in interface StoreContext

Overrides:

transactional in class BrokerImpl

transactionalAll

public void transactionalAll(Collection objs,
                             boolean versn,
                             OpCallbacks call)

Specified by:

transactionalAll in interface StoreContext

Overrides:

transactionalAll in class BrokerImpl

nontransactional

public void nontransactional(Object obj,
                             OpCallbacks call)

Specified by:

nontransactional in interface StoreContext

Overrides:

nontransactional in class BrokerImpl

nontransactionalAll

public void nontransactionalAll(Collection objs,
                                OpCallbacks call)

Specified by:

nontransactionalAll in interface StoreContext

Overrides:

nontransactionalAll in class BrokerImpl

evict

public void evict(Object obj,
                  OpCallbacks call)

Specified by:

evict in interface Broker

Overrides:

evict in class BrokerImpl

evictAll

public void evictAll(Collection objs,
                     OpCallbacks call)

Specified by:

evictAll in interface Broker

Overrides:

evictAll in class BrokerImpl

evictAll

public void evictAll(Extent ext,
                     OpCallbacks call)

Specified by:

evictAll in interface Broker

Overrides:

evictAll in class BrokerImpl

evictAll

public void evictAll(OpCallbacks call)

Specified by:

evictAll in interface Broker

Overrides:

evictAll in class BrokerImpl

retrieve

public void retrieve(Object obj,
                     boolean fgs,
                     OpCallbacks call)

Specified by:

retrieve in interface StoreContext

Overrides:

retrieve in class BrokerImpl

retrieveAll

public void retrieveAll(Collection objs,
                        boolean fgs,
                        OpCallbacks call)

Specified by:

retrieveAll in interface StoreContext

Overrides:

retrieveAll in class BrokerImpl

find

public Object find(Object oid,
                   boolean validate,
                   FindCallbacks call)

Specified by:

find in interface StoreContext

Overrides:

find in class BrokerImpl

findAll

public Object[] findAll(Collection oids,
                        boolean validate,
                        FindCallbacks call)

Specified by:

findAll in interface StoreContext

Overrides:

findAll in class BrokerImpl

newQuery

public Query newQuery(String lang,
                      Object query)

Specified by:

newQuery in interface Broker

Overrides:

newQuery in class BrokerImpl

newQuery

public Query newQuery(String lang,
                      Class candidate,
                      Object query)

Specified by:

newQuery in interface Broker

Overrides:

newQuery in class BrokerImpl

attach

public Object attach(Object obj,
                     boolean copyNew,
                     OpCallbacks call)

Specified by:

attach in interface Broker

Overrides:

attach in class BrokerImpl

attachAll

public Object[] attachAll(Collection objs,
                          boolean copyNew,
                          OpCallbacks call)

Specified by:

attachAll in interface Broker

Overrides:

attachAll in class BrokerImpl

detach

public Object detach(Object obj,
                     OpCallbacks call)

Specified by:

detach in interface Broker

Overrides:

detach in class BrokerImpl

detachAll

public Object[] detachAll(Collection objs,
                          OpCallbacks call)

Specified by:

detachAll in interface Broker

Overrides:

detachAll in class BrokerImpl

detachAll

public void detachAll(OpCallbacks call)

Specified by:

detachAll in interface Broker

Overrides:

detachAll in class BrokerImpl