|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.jdo.impl.fostore.FOStoreConnector
FOStoreConnector represents a connection to the FOStoreDatabase.
Field Summary | |
private boolean |
busy
True if flush is in progress. |
(package private) FOStoreClientConnection |
connection
Connection for interacting with store. |
(package private) static org.apache.commons.logging.Log |
logger
Logger |
private Message |
message
Message in which this Connector buffers requests for the store. |
private static org.apache.jdo.util.I18NHelper |
msg
I18N support. |
private boolean |
okToReleaseConnection
True if we can release this connection after flushing. |
private FOStorePMF |
pmf
Datasource to which this Connector writes its Message. |
private boolean |
rollbackOnly
|
Constructor Summary | |
(package private) |
FOStoreConnector(FOStorePMF pmf)
|
Method Summary | |
private void |
assertNotBusy(java.lang.String methodName)
|
private void |
assertNotRollbackOnly()
|
void |
beforeCompletion()
|
void |
begin(boolean optimistic)
|
void |
commit()
Add a CommitRequest to the connector's message, and send it to the store. |
void |
flush()
Get a connection, process the message by using that connection to interact with the database, read back the reply, release the connection. |
(package private) Message |
getMessage()
Provides the Message which this this connector uses to send data to the store. |
boolean |
getRollbackOnly()
|
void |
rollback()
If rollbackOnly is set, then the store has already done a rollback, so we don't do one now (but neither do we throw an exception, as do other methds). |
void |
setRollbackOnly()
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
private boolean rollbackOnly
Connector.setRollbackOnly()
private static final org.apache.jdo.util.I18NHelper msg
static final org.apache.commons.logging.Log logger
private final Message message
private final FOStorePMF pmf
FOStoreClientConnection connection
private boolean okToReleaseConnection
private boolean busy
Constructor Detail |
FOStoreConnector(FOStorePMF pmf)
Method Detail |
public void begin(boolean optimistic)
begin
in interface org.apache.jdo.store.Connector
Connector.begin(boolean)
public void beforeCompletion()
beforeCompletion
in interface org.apache.jdo.store.Connector
Connector.beforeCompletion()
public void flush()
flush
in interface org.apache.jdo.store.Connector
Connector.flush()
public void commit()
commit
in interface org.apache.jdo.store.Connector
Connector.commit()
public void rollback()
rollback
in interface org.apache.jdo.store.Connector
Connector.rollback()
,
ReplyHandler.processReplies(java.io.DataInput, org.apache.jdo.impl.fostore.Message)
public void setRollbackOnly()
setRollbackOnly
in interface org.apache.jdo.store.Connector
Connector.setRollbackOnly()
public boolean getRollbackOnly()
getRollbackOnly
in interface org.apache.jdo.store.Connector
Connector.getRollbackOnly()
Message getMessage()
private void assertNotRollbackOnly()
private void assertNotBusy(java.lang.String methodName)
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |