|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.objectweb.cjdbc.controller.scheduler.AbstractScheduler
org.objectweb.cjdbc.controller.scheduler.raidb1.RAIDb1OptimisticTransactionLevelScheduler
This scheduler provides transaction level scheduling for RAIDb-1 controllers. Each write takes a lock on the table it affects. All following writes are blocked until the transaction of the first write completes. This scheduler automatically detects simple deadlocks and rollbacks the transaction inducing the deadlock. Note that transitive deadlocks (involving more than 2 tables are not detected).
Field Summary | |
private int |
requestId
|
private SchedulerDatabaseSchema |
schedulerDatabaseSchema
|
Fields inherited from class org.objectweb.cjdbc.controller.scheduler.AbstractScheduler |
logger, needSQLMacroHandling, parsingGranularity, raidbLevel |
Constructor Summary | |
RAIDb1OptimisticTransactionLevelScheduler()
Creates a new Optimistic Transaction Level Scheduler |
Method Summary | |
private void |
acquireLockAndSetRequestId(AbstractWriteRequest request,
TransactionExclusiveLock tableLock)
|
protected void |
commitTransaction(int transactionId)
Commit a transaction given its id. |
java.lang.String |
getInformation()
Get information about the Request Scheduler |
java.lang.String |
getXmlInformation()
Get information about the Request Scheduler in xml format |
void |
mergeDatabaseSchema(DatabaseSchema dbs)
Merge the given DatabaseSchema with the current one. |
void |
notifyWriteCompleted(AbstractWriteRequest request)
Notify the completion of a write statement. |
void |
readCompleted(SelectRequest request)
Notify the completion of a read statement. |
private void |
releaseLocks(int transactionId)
Release all locks we may own on tables. |
protected void |
rollbackTransaction(int transactionId)
Rollback a transaction given its id. |
void |
scheduleNonSuspendedWriteRequest(AbstractWriteRequest request)
Additionally to scheduling the request, this method replaces the SQL Date macros such as now() with the current date. |
void |
scheduleReadRequest(SelectRequest request)
Additionally to scheduling the request, this method replaces the SQL Date macros such as now() with the current date. |
void |
setDatabaseSchema(DatabaseSchema dbs)
Sets the DatabaseSchema of the current virtual database.
|
Methods inherited from class org.objectweb.cjdbc.controller.scheduler.AbstractScheduler |
begin, beginCompleted, commit, commitCompleted, getParsingGranularity, getPendingWrites, getRAIDbLevel, handleSQLMacros, hasSQLMacros, resumeNewTransactions, resumeWrites, rollback, rollbackCompleted, scheduleReadRequest, scheduleWriteRequest, setParsingGranularity, setRAIDbLevel, suspendNewTransactionsForCheckpoint, suspendWrites, writeCompleted |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
private int requestId
private SchedulerDatabaseSchema schedulerDatabaseSchema
Constructor Detail |
public RAIDb1OptimisticTransactionLevelScheduler()
Method Detail |
public void setDatabaseSchema(DatabaseSchema dbs)
DatabaseSchema
of the current virtual database.
This is only needed by some schedulers that will have to define their
own scheduler schema
setDatabaseSchema
in class AbstractScheduler
dbs
- a DatabaseSchema
valueSchedulerDatabaseSchema
public void mergeDatabaseSchema(DatabaseSchema dbs)
DatabaseSchema
with the current one.
mergeDatabaseSchema
in class AbstractScheduler
dbs
- a DatabaseSchema
valueSchedulerDatabaseSchema
public final void scheduleReadRequest(SelectRequest request) throws java.sql.SQLException
scheduleReadRequest
in class AbstractScheduler
request
- Select request to schedule (SQL macros are already handled if needed)
java.sql.SQLException
- if a timeout occursAbstractScheduler.scheduleReadRequest(SelectRequest)
public final void readCompleted(SelectRequest request)
AbstractScheduler
readCompleted
in class AbstractScheduler
request
- the completed requestAbstractScheduler.readCompleted(SelectRequest)
public void scheduleNonSuspendedWriteRequest(AbstractWriteRequest request) throws java.sql.SQLException, RollbackException
scheduleNonSuspendedWriteRequest
in class AbstractScheduler
request
- Write request to schedule (SQL macros are already handled if needed)
RollbackException
- if the transaction must be rollbacked
java.sql.SQLException
- if a timeout occursAbstractScheduler.scheduleWriteRequest(AbstractWriteRequest)
private void acquireLockAndSetRequestId(AbstractWriteRequest request, TransactionExclusiveLock tableLock) throws java.sql.SQLException
java.sql.SQLException
public final void notifyWriteCompleted(AbstractWriteRequest request)
AbstractScheduler
notifyWriteCompleted
in class AbstractScheduler
request
- the completed requestAbstractScheduler.notifyWriteCompleted(AbstractWriteRequest)
protected final void commitTransaction(int transactionId)
AbstractScheduler
commitTransaction
in class AbstractScheduler
transactionId
- the transaction idAbstractScheduler.commitTransaction(int)
protected final void rollbackTransaction(int transactionId)
AbstractScheduler
rollbackTransaction
in class AbstractScheduler
transactionId
- the transaction idAbstractScheduler.rollbackTransaction(int)
private final void releaseLocks(int transactionId)
transactionId
- id of the transaction that releases the lockspublic java.lang.String getInformation()
AbstractScheduler
getInformation
in class AbstractScheduler
String
containing informationAbstractScheduler.getInformation()
public java.lang.String getXmlInformation()
AbstractScheduler
getXmlInformation
in class AbstractScheduler
String
containing information in xmlAbstractScheduler.getXmlInformation()
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |