|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.objectweb.cjdbc.controller.recoverylog.AbstractRecoveryLog
Log Recovery is responsible for logging performed queries, managing checkpoints and retrieving write requests executed from a given checkpoint.
Field Summary | |
(package private) static Trace |
logger
|
private int |
recoveringNb
|
Constructor Summary | |
AbstractRecoveryLog()
|
Method Summary | |
abstract void |
begin(TransactionMarkerMetaData tm)
Log the beginning of a new transaction. |
void |
beginRecovery()
Notify the recovery log that a recovery process has started. |
abstract void |
cleanRecoveryLog()
Possibly clean the recovery log after all recovery process are done. |
abstract void |
commit(TransactionMarkerMetaData tm)
Log a transaction commit. |
void |
endRecovery()
Notify the recovery log that a recovery process has finished. |
abstract int |
getCheckpointRequestId(java.lang.String checkpointName)
Get the request id corresponding to a given checkpoint. |
abstract java.lang.String |
getXmlInformation()
Get xml information of the current recovery load in the system. |
boolean |
isRecovering()
Returns true if at least one backend has started a recover
process. |
abstract void |
logRequest(AbstractWriteRequest request)
Log a write request. |
abstract void |
logRequest(StoredProcedure proc,
boolean isRead)
Log a call to a stored procedure. |
abstract RecoveryTask |
recoverNextRequest(int previousRequestId)
Get the next request (begin/commit/rollback or WriteRequest) from the recovery log given the id of the previously recovered request. |
abstract void |
rollback(TransactionMarkerMetaData tm)
Log a transaction rollback. |
abstract void |
storeCheckpoint(java.lang.String checkpointName)
Store a Checkpoint using the current log state. |
abstract void |
storeCheckpoint(java.lang.String checkpointName,
int requestId)
Store a Checkpoint using the given request id. |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
static Trace logger
private int recoveringNb
Constructor Detail |
public AbstractRecoveryLog()
Method Detail |
public abstract void logRequest(AbstractWriteRequest request) throws java.sql.SQLException
request
- The write request to log
java.sql.SQLException
- if an error occurspublic abstract void logRequest(StoredProcedure proc, boolean isRead) throws java.sql.SQLException
proc
- The stored procedure call to logisRead
- True if the stored procedure call returns a ResultSet
java.sql.SQLException
- if an error occurspublic abstract void begin(TransactionMarkerMetaData tm) throws java.sql.SQLException
tm
- The transaction marker metadata
java.sql.SQLException
- if an error occurspublic abstract void commit(TransactionMarkerMetaData tm) throws java.sql.SQLException
tm
- The transaction marker metadata
java.sql.SQLException
- if an error occurspublic abstract void rollback(TransactionMarkerMetaData tm) throws java.sql.SQLException
tm
- The transaction marker metadata
java.sql.SQLException
- if an error occurspublic abstract void storeCheckpoint(java.lang.String checkpointName) throws java.sql.SQLException
checkpointName
- Name of the checkpoint
java.sql.SQLException
- if an error occurspublic abstract void storeCheckpoint(java.lang.String checkpointName, int requestId) throws java.sql.SQLException
checkpointName
- Name of the checkpointrequestId
- request identifier
java.sql.SQLException
- if an error occurspublic abstract int getCheckpointRequestId(java.lang.String checkpointName) throws java.sql.SQLException
checkpointName
- Name of the checkpoint
java.sql.SQLException
- if an error occursrecoverNextRequest(int)
public abstract RecoveryTask recoverNextRequest(int previousRequestId) throws java.sql.SQLException
The id of the request before the first one to recover is given by getCheckpointRequestId.
previousRequestId
- id of the previously recovered request
java.sql.SQLException
- if an error occursgetCheckpointRequestId(String)
public void beginRecovery()
public void endRecovery()
cleanRecoveryLog()
public boolean isRecovering()
true
if at least one backend has started a recover
process.
boolean
public abstract void cleanRecoveryLog() throws java.sql.SQLException
java.sql.SQLException
- if an error occurspublic abstract java.lang.String getXmlInformation()
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |