|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.objectweb.speedo.pm.lib.AbstractPOManager
public abstract class AbstractPOManager
Field Summary | |
---|---|
static java.lang.String |
COMPONENT_BINDING
|
protected java.lang.Object |
connectionSpec
is the information permiting the access to the data store |
protected java.lang.Thread |
currentThread
The lastest thread associated to the current POManagerItf |
protected FetchPlanItf |
fetchPlan
|
protected JormFactory |
jf
The JormFactory able to initialize the Persistent of classes |
static java.lang.String |
JORM_FACTORY_BINDING
|
protected org.objectweb.util.monolog.api.Logger |
logger
|
protected org.objectweb.util.monolog.api.LoggerFactory |
loggerFactory
|
protected short |
nbUse
Indicates if number of po manager user. |
protected POManagerFactoryItf |
pmf
The POManagedFactory managing this POManagerItf |
static java.lang.String |
PNAME_CODER_BINDING
|
protected org.objectweb.jorm.naming.api.PNameCoder |
pnc
The PNameCoder able to encode/decode all PName |
static java.lang.String |
PO_MANAGER_FACTORY_BINDING
|
protected boolean |
prefetchOnExtent
|
protected boolean |
prefetchOnQuery
|
static java.lang.String |
QUERY_MANAGER_BINDING
|
protected QueryManager |
queryManager
The manager of Query. |
protected org.objectweb.perseus.concurrency.lib.Semaphore |
semaphore
A semaphore object used to support the multithread mode |
protected POManagerItf |
thisPM
The fractal reference to this |
protected TransactionalPersistenceManager |
tpm
The TransactionalPersistenceManager (Perseus) |
static java.lang.String |
TRANSACTION_BINDING
|
static java.lang.String |
TRANSACTIONAL_PERSISTENCE_MANAGER_BINDING
|
protected TransactionItf |
tx
The transaction associated to this po manager. |
Constructor Summary | |
---|---|
AbstractPOManager()
|
Method Summary | |
---|---|
void |
addUse()
Signal to the persistence maneger that it is used. |
void |
afterCompletion(int i)
|
protected void |
assertIsOpen()
Verify the persistence manager is open. |
protected void |
assertIsPO(java.lang.Object pc,
java.lang.String cmd)
Verify that an instance is persistence object. |
protected void |
assertPOManager(PersistentObjectItf sp)
Verify the instance is managed by this persistence manager. |
void |
beforeCompletion()
|
void |
bindFc(java.lang.String s,
java.lang.Object o)
|
protected void |
bindPMThread()
|
void |
closePOManager()
Close the POM |
org.objectweb.jorm.naming.api.PName |
decodeIdentifier(java.lang.Class aClass,
java.lang.Object s)
|
java.lang.Object |
getConnectionSpec()
|
java.lang.Object |
getEncodedPName(PersistentObjectItf o)
Encodes a PName into a serializable representation which could be decoded later. |
POManagerFactoryItf |
getPOManagerFactory()
|
org.objectweb.perseus.concurrency.lib.Semaphore |
getSemaphore()
Retrieves the semaphore object permiting the multithreading mode. |
TransactionItf |
getSpeedoTransaction()
|
TransactionalPersistenceManager |
getTransactionalPersistenceManager()
Retrieves the TransactionalPersistenceManager used by this POManagerItf. |
boolean |
isPOMClosed()
A POManager instance can be used until it is closed. |
java.lang.String[] |
listFc()
|
java.lang.Object |
lookupFc(java.lang.String s)
|
void |
open(java.lang.Object connectionspec)
Opens the persistent manager. |
protected void |
resetPMOnOpen(java.lang.Object connectionspec)
|
void |
speedoDeletePersistentAll(java.lang.Object[] o)
|
void |
speedoFlush()
|
abstract FetchPlanItf |
speedoGetFetchPlan()
|
java.lang.Object |
speedoGetObject(java.lang.Object id,
java.lang.Class poc,
boolean validate)
|
java.lang.Object |
speedoGetObject(org.objectweb.jorm.naming.api.PName pn,
boolean validate)
|
protected java.lang.Object |
speedoPersist(PersistentObjectItf po,
java.util.Map map)
|
void |
unbindFc(java.lang.String s)
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Methods inherited from interface org.objectweb.speedo.pm.api.POManagerItf |
---|
speedoAttachCopy, speedoDeletePersistent, speedoDeletePersistent, speedoDetachCopy, speedoMakePersistent, speedoRefresh, speedoRetrieve |
Field Detail |
---|
public static final java.lang.String PO_MANAGER_FACTORY_BINDING
public static final java.lang.String TRANSACTIONAL_PERSISTENCE_MANAGER_BINDING
public static final java.lang.String QUERY_MANAGER_BINDING
public static final java.lang.String TRANSACTION_BINDING
public static final java.lang.String JORM_FACTORY_BINDING
public static final java.lang.String PNAME_CODER_BINDING
public static final java.lang.String COMPONENT_BINDING
protected org.objectweb.util.monolog.api.Logger logger
protected org.objectweb.util.monolog.api.LoggerFactory loggerFactory
protected POManagerFactoryItf pmf
protected TransactionItf tx
protected QueryManager queryManager
protected TransactionalPersistenceManager tpm
protected JormFactory jf
protected org.objectweb.jorm.naming.api.PNameCoder pnc
protected java.lang.Object connectionSpec
protected short nbUse
protected POManagerItf thisPM
protected java.lang.Thread currentThread
protected org.objectweb.perseus.concurrency.lib.Semaphore semaphore
protected boolean prefetchOnExtent
protected boolean prefetchOnQuery
protected FetchPlanItf fetchPlan
Constructor Detail |
---|
public AbstractPOManager()
Method Detail |
---|
public java.lang.String[] listFc()
public java.lang.Object lookupFc(java.lang.String s)
public void bindFc(java.lang.String s, java.lang.Object o)
public void unbindFc(java.lang.String s)
public abstract FetchPlanItf speedoGetFetchPlan()
speedoGetFetchPlan
in interface POManagerItf
public TransactionalPersistenceManager getTransactionalPersistenceManager()
POManagerItf
getTransactionalPersistenceManager
in interface POManagerItf
public void open(java.lang.Object connectionspec)
POManagerItf
open
in interface POManagerItf
connectionspec
- is the information to access to the data store
(user, password, ...)public java.lang.Object getConnectionSpec()
getConnectionSpec
in interface POManagerItf
public void addUse()
POManagerItf
addUse
in interface POManagerItf
public boolean isPOMClosed()
isPOMClosed
in interface POManagerItf
closePOManager()
public void closePOManager()
POManagerItf
closePOManager
in interface POManagerItf
public TransactionItf getSpeedoTransaction()
getSpeedoTransaction
in interface POManagerItf
public POManagerFactoryItf getPOManagerFactory()
getPOManagerFactory
in interface POManagerItf
public java.lang.Object getEncodedPName(PersistentObjectItf o)
POManagerItf
getEncodedPName
in interface POManagerItf
o
- is a persistent objectpublic org.objectweb.jorm.naming.api.PName decodeIdentifier(java.lang.Class aClass, java.lang.Object s)
decodeIdentifier
in interface POManagerItf
public void speedoDeletePersistentAll(java.lang.Object[] o)
speedoDeletePersistentAll
in interface POManagerItf
public void beforeCompletion()
beforeCompletion
in interface javax.transaction.Synchronization
public void afterCompletion(int i)
afterCompletion
in interface javax.transaction.Synchronization
public java.lang.Object speedoGetObject(org.objectweb.jorm.naming.api.PName pn, boolean validate)
speedoGetObject
in interface POManagerItf
public java.lang.Object speedoGetObject(java.lang.Object id, java.lang.Class poc, boolean validate) throws org.objectweb.jorm.api.PException, PersistenceException
org.objectweb.jorm.api.PException
PersistenceException
protected java.lang.Object speedoPersist(PersistentObjectItf po, java.util.Map map) throws org.objectweb.jorm.api.PException, PersistenceException
org.objectweb.jorm.api.PException
PersistenceException
public void speedoFlush() throws PersistenceException
PersistenceException
protected void resetPMOnOpen(java.lang.Object connectionspec)
public org.objectweb.perseus.concurrency.lib.Semaphore getSemaphore()
POManagerItf
getSemaphore
in interface POManagerItf
protected void bindPMThread()
protected void assertIsOpen()
SpeedoRuntimeException
- if the pomanager is closed.protected void assertIsPO(java.lang.Object pc, java.lang.String cmd)
pc
- the object to test.
SpeedoRuntimeException
- if the object is not persistence capable.protected void assertPOManager(PersistentObjectItf sp)
sp
- a speedo po instance.
SpeedoRuntimeException
- if the instance is managed by
another persistence manager.
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |