|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object javax.management.StandardMBean org.objectweb.cjdbc.controller.jmx.AbstractStandardMBean org.objectweb.cjdbc.controller.requestmanager.RequestManager org.objectweb.cjdbc.controller.requestmanager.distributed.DistributedRequestManager org.objectweb.cjdbc.controller.requestmanager.distributed.RAIDb1DistributedRequestManager
This class defines a RAIDb1DistributedRequestManager
Nested Class Summary |
Nested classes inherited from class javax.management.StandardMBean |
|
Field Summary |
Fields inherited from class org.objectweb.cjdbc.controller.requestmanager.distributed.DistributedRequestManager |
CONTROLLER_ID_BIT_MASK, CONTROLLER_ID_BITS, CONTROLLER_ID_SHIFT_BITS, dvdb, NO_RESULT, TRANSACTION_ID_BIT_MASK |
Fields inherited from class org.objectweb.cjdbc.controller.requestmanager.RequestManager |
backupManager, beginTimeout, commitTimeout, dbs, loadBalancer, logger, parsingCache, recoveryLog, requiredParsingGranularity, resultCache, rollbackTimeout, scheduler, schedulerParsingranularity, tidLoginTable, tidSavepoints, vdb |
Fields inherited from class org.objectweb.cjdbc.controller.jmx.AbstractStandardMBean |
|
Fields inherited from class javax.management.StandardMBean |
|
Fields inherited from interface org.objectweb.cjdbc.common.xml.XmlComponent |
DOCTYPE_CONTROLLER, DOCTYPE_DB, XML_VERSION |
Constructor Summary | |
RAIDb1DistributedRequestManager(DistributedVirtualDatabase vdb,
AbstractScheduler scheduler,
AbstractResultCache cache,
AbstractLoadBalancer loadBalancer,
RecoveryLog recoveryLog,
long beginTimeout,
long commitTimeout,
long rollbackTimeout)
Creates a new RAIDb1DistributedRequestManager instance |
Method Summary | |
void |
distributedCommit(java.lang.String login,
long transactionId)
Distributed implementation of a commit |
void |
distributedReleaseSavepoint(long transactionId,
java.lang.String name)
Distributed implementation of releasing a savepoint from a transaction |
void |
distributedRollback(long transactionId,
java.lang.String savepointName)
Distributed implementation of a rollback to a savepoint |
void |
distributedRollback(java.lang.String login,
long transactionId)
Distributed implementation of a rollback |
void |
distributedSetSavepoint(long transactionId,
java.lang.String name)
Distributed implementation of setting a savepoint to a transaction |
ControllerResultSet |
execDistributedReadStoredProcedure(StoredProcedure proc)
Distributed implementation of a read stored procedure execution. |
int |
execDistributedWriteRequest(AbstractWriteRequest request)
Distributed implementation of a write request execution. |
ControllerResultSet |
execDistributedWriteRequestWithKeys(AbstractWriteRequest request)
Distributed implementation of a write request execution that returns auto-generated keys. |
int |
execDistributedWriteStoredProcedure(StoredProcedure proc)
Distributed implementation of a write stored procedure execution. |
ControllerResultSet |
execRemoteReadRequest(SelectRequest request)
Execute a read request on some remote controller - one in the group. |
Methods inherited from class org.objectweb.cjdbc.controller.jmx.AbstractStandardMBean |
addNotificationListener, getDescription, getDescription, getDescription, getDescription, getDescription, getDescription, getNotificationInfo, getParameterName, getParameterName, removeNotificationListener, removeNotificationListener, sendNotification |
Methods inherited from class javax.management.StandardMBean |
cacheMBeanInfo, getAttribute, getAttributes, getCachedMBeanInfo, getClassName, getConstructors, getDescription, getImpact, getImplementation, getImplementationClass, getMBeanInfo, getMBeanInterface, invoke, setAttribute, setAttributes, setImplementation |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
public RAIDb1DistributedRequestManager(DistributedVirtualDatabase vdb, AbstractScheduler scheduler, AbstractResultCache cache, AbstractLoadBalancer loadBalancer, RecoveryLog recoveryLog, long beginTimeout, long commitTimeout, long rollbackTimeout) throws java.sql.SQLException, javax.management.NotCompliantMBeanException
RAIDb1DistributedRequestManager
instance
vdb
- the virtual database this request manager belongs toscheduler
- the Request Scheduler to usecache
- a Query Cache implementationloadBalancer
- the Request Load Balancer to userecoveryLog
- the Log Recovery to usebeginTimeout
- timeout in seconds for begincommitTimeout
- timeout in seconds for commitrollbackTimeout
- timeout in seconds for rollback
java.sql.SQLException
- if an error occurs
javax.management.NotCompliantMBeanException
- if the MBean is not JMX compliantMethod Detail |
public ControllerResultSet execRemoteReadRequest(SelectRequest request) throws java.sql.SQLException
DistributedRequestManager
execRemoteReadRequest
in class DistributedRequestManager
request
- the request to execute
java.sql.SQLException
- in case of bad requestDistributedRequestManager.execRemoteReadRequest(org.objectweb.cjdbc.common.sql.SelectRequest)
public int execDistributedWriteRequest(AbstractWriteRequest request) throws java.sql.SQLException
DistributedRequestManager
execDistributedWriteRequest
in class DistributedRequestManager
request
- request to execute
java.sql.SQLException
- if an error occursDistributedRequestManager.execDistributedWriteRequest(org.objectweb.cjdbc.common.sql.AbstractWriteRequest)
public ControllerResultSet execDistributedWriteRequestWithKeys(AbstractWriteRequest request) throws java.sql.SQLException
DistributedRequestManager
execDistributedWriteRequestWithKeys
in class DistributedRequestManager
request
- request to execute
java.sql.SQLException
- if an error occursDistributedRequestManager.execDistributedWriteRequestWithKeys(org.objectweb.cjdbc.common.sql.AbstractWriteRequest)
public ControllerResultSet execDistributedReadStoredProcedure(StoredProcedure proc) throws java.sql.SQLException
DistributedRequestManager
execDistributedReadStoredProcedure
in class DistributedRequestManager
proc
- stored procedure to execute
java.sql.SQLException
- if an error occursDistributedRequestManager.execDistributedReadStoredProcedure(StoredProcedure)
public int execDistributedWriteStoredProcedure(StoredProcedure proc) throws java.sql.SQLException
DistributedRequestManager
execDistributedWriteStoredProcedure
in class DistributedRequestManager
proc
- stored procedure to execute
java.sql.SQLException
- if an error occursDistributedRequestManager.execDistributedWriteStoredProcedure(org.objectweb.cjdbc.common.sql.StoredProcedure)
public void distributedCommit(java.lang.String login, long transactionId) throws java.sql.SQLException
DistributedRequestManager
distributedCommit
in class DistributedRequestManager
login
- login that commit the transactiontransactionId
- id of the commiting transaction
java.sql.SQLException
- if an error occursDistributedRequestManager.distributedCommit(String,
long)
public void distributedRollback(java.lang.String login, long transactionId) throws java.sql.SQLException
DistributedRequestManager
distributedRollback
in class DistributedRequestManager
login
- login that rollback the transactiontransactionId
- id of the rollbacking transaction
java.sql.SQLException
- if an error occursDistributedRequestManager.distributedRollback(String,
long)
public void distributedRollback(long transactionId, java.lang.String savepointName) throws java.sql.SQLException
DistributedRequestManager
distributedRollback
in class DistributedRequestManager
transactionId
- id of the transactionsavepointName
- name of the savepoint
java.sql.SQLException
- if an error occursDistributedRequestManager.distributedRollback(long,
String)
public void distributedSetSavepoint(long transactionId, java.lang.String name) throws java.sql.SQLException
DistributedRequestManager
distributedSetSavepoint
in class DistributedRequestManager
transactionId
- id of the transactionname
- name of the savepoint to set
java.sql.SQLException
- if an error occursDistributedRequestManager.distributedSetSavepoint(long,
String)
public void distributedReleaseSavepoint(long transactionId, java.lang.String name) throws java.sql.SQLException
DistributedRequestManager
distributedReleaseSavepoint
in class DistributedRequestManager
transactionId
- id of the transactionname
- name of the savepoint to release
java.sql.SQLException
- if an error occursDistributedRequestManager.distributedReleaseSavepoint(long,
String)
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |