Package org.datanucleus.api.jdo
Class JDOPersistenceManagerProxy
java.lang.Object
org.datanucleus.api.jdo.JDOPersistenceManagerProxy
- All Implemented Interfaces:
AutoCloseable
,javax.jdo.PersistenceManager
Implementation of a JDO persistence manager proxy.
JDO spec $11.3.1. Returning a thread-safe PM.
In JTA this delegates to an underlying PM, with the exception of close() which has no effect. If there is a PM associated with the (JTA) transaction the proxy just delegates to whichever PM is still associated. If there is no PM associated to the (JTA) transaction then a PM is created and associated to the (JTA) txn. If there is no (JTA) txn currently associated then a new PM is created
In RESOURCE_LOCAL, this delegates to the PM associated with an implementation defined thread-local variable. The close() on the proxy clears the thread-local, so subsequent calls to getPersistenceManagerProxy() will create a new PM.
-
Field Summary
Fields -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoid
addInstanceLifecycleListener
(javax.jdo.listener.InstanceLifecycleListener listener, Class... classes) void
void
close()
javax.jdo.Transaction
void
deletePersistent
(Object obj) void
deletePersistentAll
(Object... pcs) void
<T> T
detachCopy
(T pc) <T> Collection
<T> detachCopyAll
(Collection<T> pcs) <T> T[]
detachCopyAll
(T... pcs) void
void
evictAll()
void
void
void
evictAll
(Collection pcs) void
flush()
boolean
javax.jdo.datastore.JDOConnection
boolean
<T> javax.jdo.Extent
<T> <T> javax.jdo.Extent
<T> javax.jdo.FetchGroup
getFetchGroup
(Class arg0, String arg1) javax.jdo.FetchPlan
boolean
getManagedObjects
(Class... classes) getManagedObjects
(EnumSet<javax.jdo.ObjectState> states) getManagedObjects
(EnumSet<javax.jdo.ObjectState> states, Class... classes) boolean
<T> T
getObjectById
(Class<T> cls, Object key) getObjectById
(Object id) getObjectById
(Object id, boolean validate) getObjectId
(Object pc) getObjectIdClass
(Class cls) Object[]
getObjectsById
(boolean validate, Object... oids) Object[]
getObjectsById
(Object... oids) Object[]
getObjectsById
(Object[] oids, boolean validate) getObjectsById
(Collection oids) getObjectsById
(Collection oids, boolean validate) javax.jdo.PersistenceManagerFactory
protected javax.jdo.PersistenceManager
getPM()
Accessor for the delegate PM that we hand off to.javax.jdo.datastore.Sequence
getSequence
(String sequenceName) getUserObject
(Object key) boolean
isClosed()
void
void
makeNontransactionalAll
(Object... pcs) void
<T> T
makePersistent
(T obj) <T> Collection
<T> makePersistentAll
(Collection<T> arg0) <T> T[]
makePersistentAll
(T... arg0) void
makeTransactional
(Object arg0) void
makeTransactionalAll
(Object... arg0) void
void
makeTransient
(Object pc) void
makeTransient
(Object pc, boolean useFetchPlan) void
makeTransientAll
(boolean includeFetchPlan, Object... pcs) void
makeTransientAll
(Object... pcs) void
makeTransientAll
(Object[] pcs, boolean includeFetchPlan) void
void
makeTransientAll
(Collection pcs, boolean useFetchPlan) <T> T
newInstance
(Class<T> pc) <T> javax.jdo.JDOQLTypedQuery
<T> newJDOQLTypedQuery
(Class<T> cls) javax.jdo.Query
newNamedQuery
(Class cls, String filter) newObjectIdInstance
(Class pcClass, Object key) javax.jdo.Query
newQuery()
<T> javax.jdo.Query
<T> <T> javax.jdo.Query
<T> <T> javax.jdo.Query
<T> newQuery
(Class<T> cls, Collection<T> cln) <T> javax.jdo.Query
<T> newQuery
(Class<T> cls, Collection<T> cln, String filter) javax.jdo.Query
javax.jdo.Query
javax.jdo.Query
<T> javax.jdo.Query
<T> newQuery
(javax.jdo.Extent<T> cln) <T> javax.jdo.Query
<T> putUserObject
(Object key, Object value) void
void
void
refreshAll
(Object... pcs) void
refreshAll
(Collection pcs) void
refreshAll
(javax.jdo.JDOException exc) void
removeInstanceLifecycleListener
(javax.jdo.listener.InstanceLifecycleListener listener) removeUserObject
(Object key) void
void
void
retrieveAll
(boolean fgOnly, Object... pcs) void
retrieveAll
(Object... pcs) void
retrieveAll
(Object[] pcs, boolean fgOnly) void
retrieveAll
(Collection pcs) void
retrieveAll
(Collection pcs, boolean fgOnly) void
setCopyOnAttach
(boolean flag) void
void
void
setDetachAllOnCommit
(boolean flag) void
setIgnoreCache
(boolean flag) void
setMultithreaded
(boolean flag) void
setProperty
(String arg0, Object arg1) void
setUserObject
(Object userObject)
-
Field Details
-
pmf
-
-
Constructor Details
-
JDOPersistenceManagerProxy
-
-
Method Details
-
getPM
protected javax.jdo.PersistenceManager getPM()Accessor for the delegate PM that we hand off to.- Returns:
- The delegate PM (from the PMF thread-local store)
-
close
public void close()- Specified by:
close
in interfaceAutoCloseable
- Specified by:
close
in interfacejavax.jdo.PersistenceManager
-
addInstanceLifecycleListener
public void addInstanceLifecycleListener(javax.jdo.listener.InstanceLifecycleListener listener, Class... classes) - Specified by:
addInstanceLifecycleListener
in interfacejavax.jdo.PersistenceManager
-
checkConsistency
public void checkConsistency()- Specified by:
checkConsistency
in interfacejavax.jdo.PersistenceManager
-
currentTransaction
public javax.jdo.Transaction currentTransaction()- Specified by:
currentTransaction
in interfacejavax.jdo.PersistenceManager
-
deletePersistent
- Specified by:
deletePersistent
in interfacejavax.jdo.PersistenceManager
-
deletePersistentAll
- Specified by:
deletePersistentAll
in interfacejavax.jdo.PersistenceManager
-
deletePersistentAll
- Specified by:
deletePersistentAll
in interfacejavax.jdo.PersistenceManager
-
detachCopy
public <T> T detachCopy(T pc) - Specified by:
detachCopy
in interfacejavax.jdo.PersistenceManager
-
detachCopyAll
- Specified by:
detachCopyAll
in interfacejavax.jdo.PersistenceManager
-
detachCopyAll
public <T> T[] detachCopyAll(T... pcs) - Specified by:
detachCopyAll
in interfacejavax.jdo.PersistenceManager
-
evict
- Specified by:
evict
in interfacejavax.jdo.PersistenceManager
-
evictAll
public void evictAll()- Specified by:
evictAll
in interfacejavax.jdo.PersistenceManager
-
evictAll
- Specified by:
evictAll
in interfacejavax.jdo.PersistenceManager
-
evictAll
- Specified by:
evictAll
in interfacejavax.jdo.PersistenceManager
-
evictAll
- Specified by:
evictAll
in interfacejavax.jdo.PersistenceManager
-
flush
public void flush()- Specified by:
flush
in interfacejavax.jdo.PersistenceManager
-
getCopyOnAttach
public boolean getCopyOnAttach()- Specified by:
getCopyOnAttach
in interfacejavax.jdo.PersistenceManager
-
getDataStoreConnection
public javax.jdo.datastore.JDOConnection getDataStoreConnection()- Specified by:
getDataStoreConnection
in interfacejavax.jdo.PersistenceManager
-
getDetachAllOnCommit
public boolean getDetachAllOnCommit()- Specified by:
getDetachAllOnCommit
in interfacejavax.jdo.PersistenceManager
-
getExtent
- Specified by:
getExtent
in interfacejavax.jdo.PersistenceManager
-
getExtent
- Specified by:
getExtent
in interfacejavax.jdo.PersistenceManager
-
getFetchGroup
- Specified by:
getFetchGroup
in interfacejavax.jdo.PersistenceManager
-
getFetchPlan
public javax.jdo.FetchPlan getFetchPlan()- Specified by:
getFetchPlan
in interfacejavax.jdo.PersistenceManager
-
getIgnoreCache
public boolean getIgnoreCache()- Specified by:
getIgnoreCache
in interfacejavax.jdo.PersistenceManager
-
getManagedObjects
- Specified by:
getManagedObjects
in interfacejavax.jdo.PersistenceManager
-
getManagedObjects
- Specified by:
getManagedObjects
in interfacejavax.jdo.PersistenceManager
-
getManagedObjects
- Specified by:
getManagedObjects
in interfacejavax.jdo.PersistenceManager
-
getManagedObjects
- Specified by:
getManagedObjects
in interfacejavax.jdo.PersistenceManager
-
getMultithreaded
public boolean getMultithreaded()- Specified by:
getMultithreaded
in interfacejavax.jdo.PersistenceManager
-
getObjectById
- Specified by:
getObjectById
in interfacejavax.jdo.PersistenceManager
-
getObjectById
- Specified by:
getObjectById
in interfacejavax.jdo.PersistenceManager
-
getObjectById
- Specified by:
getObjectById
in interfacejavax.jdo.PersistenceManager
-
getObjectId
- Specified by:
getObjectId
in interfacejavax.jdo.PersistenceManager
-
getObjectIdClass
- Specified by:
getObjectIdClass
in interfacejavax.jdo.PersistenceManager
-
getObjectsById
- Specified by:
getObjectsById
in interfacejavax.jdo.PersistenceManager
-
getObjectsById
- Specified by:
getObjectsById
in interfacejavax.jdo.PersistenceManager
-
getObjectsById
- Specified by:
getObjectsById
in interfacejavax.jdo.PersistenceManager
-
getObjectsById
-
getObjectsById
- Specified by:
getObjectsById
in interfacejavax.jdo.PersistenceManager
-
getPersistenceManagerFactory
public javax.jdo.PersistenceManagerFactory getPersistenceManagerFactory()- Specified by:
getPersistenceManagerFactory
in interfacejavax.jdo.PersistenceManager
-
getSequence
- Specified by:
getSequence
in interfacejavax.jdo.PersistenceManager
-
getServerDate
- Specified by:
getServerDate
in interfacejavax.jdo.PersistenceManager
-
getTransactionalObjectId
- Specified by:
getTransactionalObjectId
in interfacejavax.jdo.PersistenceManager
-
getUserObject
- Specified by:
getUserObject
in interfacejavax.jdo.PersistenceManager
-
getUserObject
- Specified by:
getUserObject
in interfacejavax.jdo.PersistenceManager
-
isClosed
public boolean isClosed()- Specified by:
isClosed
in interfacejavax.jdo.PersistenceManager
-
makeNontransactional
- Specified by:
makeNontransactional
in interfacejavax.jdo.PersistenceManager
-
makeNontransactionalAll
- Specified by:
makeNontransactionalAll
in interfacejavax.jdo.PersistenceManager
-
makeNontransactionalAll
- Specified by:
makeNontransactionalAll
in interfacejavax.jdo.PersistenceManager
-
makePersistent
public <T> T makePersistent(T obj) - Specified by:
makePersistent
in interfacejavax.jdo.PersistenceManager
-
makePersistentAll
public <T> T[] makePersistentAll(T... arg0) - Specified by:
makePersistentAll
in interfacejavax.jdo.PersistenceManager
-
makePersistentAll
- Specified by:
makePersistentAll
in interfacejavax.jdo.PersistenceManager
-
makeTransactional
- Specified by:
makeTransactional
in interfacejavax.jdo.PersistenceManager
-
makeTransactionalAll
- Specified by:
makeTransactionalAll
in interfacejavax.jdo.PersistenceManager
-
makeTransactionalAll
- Specified by:
makeTransactionalAll
in interfacejavax.jdo.PersistenceManager
-
makeTransient
- Specified by:
makeTransient
in interfacejavax.jdo.PersistenceManager
-
makeTransient
- Specified by:
makeTransient
in interfacejavax.jdo.PersistenceManager
-
makeTransientAll
- Specified by:
makeTransientAll
in interfacejavax.jdo.PersistenceManager
-
makeTransientAll
- Specified by:
makeTransientAll
in interfacejavax.jdo.PersistenceManager
-
makeTransientAll
-
makeTransientAll
- Specified by:
makeTransientAll
in interfacejavax.jdo.PersistenceManager
-
makeTransientAll
- Specified by:
makeTransientAll
in interfacejavax.jdo.PersistenceManager
-
newInstance
- Specified by:
newInstance
in interfacejavax.jdo.PersistenceManager
-
newNamedQuery
- Specified by:
newNamedQuery
in interfacejavax.jdo.PersistenceManager
-
newObjectIdInstance
- Specified by:
newObjectIdInstance
in interfacejavax.jdo.PersistenceManager
-
newQuery
public javax.jdo.Query newQuery()- Specified by:
newQuery
in interfacejavax.jdo.PersistenceManager
-
newQuery
- Specified by:
newQuery
in interfacejavax.jdo.PersistenceManager
-
newQuery
- Specified by:
newQuery
in interfacejavax.jdo.PersistenceManager
-
newQuery
- Specified by:
newQuery
in interfacejavax.jdo.PersistenceManager
-
newQuery
public <T> javax.jdo.Query<T> newQuery(javax.jdo.Extent<T> cln) - Specified by:
newQuery
in interfacejavax.jdo.PersistenceManager
-
newQuery
- Specified by:
newQuery
in interfacejavax.jdo.PersistenceManager
-
newQuery
- Specified by:
newQuery
in interfacejavax.jdo.PersistenceManager
-
newQuery
- Specified by:
newQuery
in interfacejavax.jdo.PersistenceManager
-
newQuery
- Specified by:
newQuery
in interfacejavax.jdo.PersistenceManager
-
newQuery
- Specified by:
newQuery
in interfacejavax.jdo.PersistenceManager
-
newJDOQLTypedQuery
- Specified by:
newJDOQLTypedQuery
in interfacejavax.jdo.PersistenceManager
-
putUserObject
- Specified by:
putUserObject
in interfacejavax.jdo.PersistenceManager
-
refresh
- Specified by:
refresh
in interfacejavax.jdo.PersistenceManager
-
refreshAll
public void refreshAll()- Specified by:
refreshAll
in interfacejavax.jdo.PersistenceManager
-
refreshAll
- Specified by:
refreshAll
in interfacejavax.jdo.PersistenceManager
-
refreshAll
- Specified by:
refreshAll
in interfacejavax.jdo.PersistenceManager
-
refreshAll
public void refreshAll(javax.jdo.JDOException exc) - Specified by:
refreshAll
in interfacejavax.jdo.PersistenceManager
-
removeInstanceLifecycleListener
public void removeInstanceLifecycleListener(javax.jdo.listener.InstanceLifecycleListener listener) - Specified by:
removeInstanceLifecycleListener
in interfacejavax.jdo.PersistenceManager
-
removeUserObject
- Specified by:
removeUserObject
in interfacejavax.jdo.PersistenceManager
-
retrieve
- Specified by:
retrieve
in interfacejavax.jdo.PersistenceManager
-
retrieve
- Specified by:
retrieve
in interfacejavax.jdo.PersistenceManager
-
retrieveAll
- Specified by:
retrieveAll
in interfacejavax.jdo.PersistenceManager
-
retrieveAll
- Specified by:
retrieveAll
in interfacejavax.jdo.PersistenceManager
-
retrieveAll
- Specified by:
retrieveAll
in interfacejavax.jdo.PersistenceManager
-
retrieveAll
-
retrieveAll
- Specified by:
retrieveAll
in interfacejavax.jdo.PersistenceManager
-
setCopyOnAttach
public void setCopyOnAttach(boolean flag) - Specified by:
setCopyOnAttach
in interfacejavax.jdo.PersistenceManager
-
setDetachAllOnCommit
public void setDetachAllOnCommit(boolean flag) - Specified by:
setDetachAllOnCommit
in interfacejavax.jdo.PersistenceManager
-
setIgnoreCache
public void setIgnoreCache(boolean flag) - Specified by:
setIgnoreCache
in interfacejavax.jdo.PersistenceManager
-
setMultithreaded
public void setMultithreaded(boolean flag) - Specified by:
setMultithreaded
in interfacejavax.jdo.PersistenceManager
-
setUserObject
- Specified by:
setUserObject
in interfacejavax.jdo.PersistenceManager
-
getDatastoreReadTimeoutMillis
- Specified by:
getDatastoreReadTimeoutMillis
in interfacejavax.jdo.PersistenceManager
-
setDatastoreReadTimeoutMillis
- Specified by:
setDatastoreReadTimeoutMillis
in interfacejavax.jdo.PersistenceManager
-
getDatastoreWriteTimeoutMillis
- Specified by:
getDatastoreWriteTimeoutMillis
in interfacejavax.jdo.PersistenceManager
-
setDatastoreWriteTimeoutMillis
- Specified by:
setDatastoreWriteTimeoutMillis
in interfacejavax.jdo.PersistenceManager
-
getProperties
- Specified by:
getProperties
in interfacejavax.jdo.PersistenceManager
-
getSupportedProperties
- Specified by:
getSupportedProperties
in interfacejavax.jdo.PersistenceManager
-
setProperty
- Specified by:
setProperty
in interfacejavax.jdo.PersistenceManager
-