org.objectweb.cjdbc.controller.requestmanager.distributed
Class RAIDb2DistributedRequestManager
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.RAIDb2DistributedRequestManager
- All Implemented Interfaces:
- javax.management.DynamicMBean, javax.management.NotificationBroadcaster, javax.management.NotificationEmitter, RequestManagerMBean, XmlComponent
- public class RAIDb2DistributedRequestManager
- extends DistributedRequestManager
This class defines a RAIDb2DistributedRequestManager
- Version:
- 1.0
- Author:
- Emmanuel Cecchet
Nested classes inherited from class javax.management.StandardMBean |
|
Fields inherited from class org.objectweb.cjdbc.controller.requestmanager.RequestManager |
backupManager, beginTimeout, commitTimeout, dbs, loadBalancer, logger, parsingCache, recoveryLog, requiredGranularity, resultCache, rollbackTimeout, scheduler, schedulerParsingranularity, tidLoginTable, vdb |
Fields inherited from class javax.management.StandardMBean |
|
Methods inherited from class org.objectweb.cjdbc.controller.requestmanager.distributed.DistributedRequestManager |
addFailedOnAllBackends, begin, commit, completeFailedOnAllBackends, enableBackend, execDistributedReadStoredProcedureLocally, execDistributedWriteStoredProcedureLocally, execReadStoredProcedure, execWriteRequest, execWriteRequestWithKeys, execWriteStoredProcedure, getLogger, getVirtualDatabase, lazyTransactionStart, rollback, scheduleExecWriteRequest, setControllerId |
Methods inherited from class org.objectweb.cjdbc.controller.requestmanager.RequestManager |
abort, backupBackendWithCheckpoint, callBackupManager, completeTransaction, disableBackend, disableBackendForCheckpoint, disableBackendsForCheckpoint, enableBackendFromCheckpoint, execReadRequest, getAssociatedString, getBackendStateListener, getBackupManager, getBeginTimeout, getCacheParsingranularity, getCommitTimeout, getDatabaseSchema, getLoadBalancer, getLoadBalancerParsingranularity, getMetadataCache, getRecoveryLog, getRequiredGranularity, getRequiredParsingGranularity, getResultCache, getRollbackTimeout, getScheduler, getSchedulerParsingranularity, getTransactionMarker, getXml, isCaseSensitiveParsing, isSchemaIsStatic, loadBalanceExecWriteRequest, loadBalanceExecWriteRequestWithKeys, mergeDatabaseSchema, removeCheckpoint, restoreBackendFromBackupCheckpoint, setBackupManager, setBeginTimeout, setCacheParsingranularity, setCaseSensitiveParsing, setCommitTimeout, setDatabaseSchema, setLoadBalancer, setLoadBalancerParsingranularity, setMetadataCache, setParsingCache, setRecoveryLog, setRequiredGranularity, setResultCache, setRollbackTimeout, setScheduler, setSchedulerParsingranularity, setSchemaIsStatic, storeBackendsInfo, updateAndNotifyExecWriteRequest |
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 |
RAIDb2DistributedRequestManager
public RAIDb2DistributedRequestManager(DistributedVirtualDatabase vdb,
AbstractScheduler scheduler,
AbstractResultCache cache,
AbstractLoadBalancer loadBalancer,
AbstractRecoveryLog recoveryLog,
long beginTimeout,
long commitTimeout,
long rollbackTimeout)
throws java.sql.SQLException,
javax.management.NotCompliantMBeanException
- Creates a new
RAIDb2DistributedRequestManager
instance
- Parameters:
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
- Throws:
java.sql.SQLException
- if an error occurs
javax.management.NotCompliantMBeanException
- if the MBean is not JMX compliant
execDistributedWriteRequest
public int execDistributedWriteRequest(AbstractWriteRequest request)
throws java.sql.SQLException
- Description copied from class:
DistributedRequestManager
- Distributed implementation of a write request execution.
- Specified by:
execDistributedWriteRequest
in class DistributedRequestManager
- Parameters:
request
- request to execute
- Returns:
- number of modified rows
- Throws:
java.sql.SQLException
- if an error occurs- See Also:
DistributedRequestManager.execDistributedWriteRequest(org.objectweb.cjdbc.common.sql.AbstractWriteRequest)
execDistributedWriteRequestWithKeys
public ControllerResultSet execDistributedWriteRequestWithKeys(AbstractWriteRequest request)
throws java.sql.SQLException
- Description copied from class:
DistributedRequestManager
- Distributed implementation of a write request execution that returns
auto-generated keys.
- Specified by:
execDistributedWriteRequestWithKeys
in class DistributedRequestManager
- Parameters:
request
- request to execute
- Returns:
- ResultSet containing the auto-generated keys.
- Throws:
java.sql.SQLException
- if an error occurs- See Also:
DistributedRequestManager.execDistributedWriteRequestWithKeys(org.objectweb.cjdbc.common.sql.AbstractWriteRequest)
execDistributedReadStoredProcedure
public ControllerResultSet execDistributedReadStoredProcedure(StoredProcedure proc)
throws java.sql.SQLException
- Description copied from class:
DistributedRequestManager
- Distributed implementation of a read stored procedure execution.
- Specified by:
execDistributedReadStoredProcedure
in class DistributedRequestManager
- Parameters:
proc
- stored procedure to execute
- Returns:
- ResultSet corresponding to this stored procedure execution
- Throws:
java.sql.SQLException
- if an error occurs- See Also:
DistributedRequestManager.execDistributedReadStoredProcedure(StoredProcedure)
execDistributedWriteStoredProcedure
public int execDistributedWriteStoredProcedure(StoredProcedure proc)
throws java.sql.SQLException
- Description copied from class:
DistributedRequestManager
- Distributed implementation of a write stored procedure execution.
- Specified by:
execDistributedWriteStoredProcedure
in class DistributedRequestManager
- Parameters:
proc
- stored procedure to execute
- Returns:
- number of modified rows
- Throws:
java.sql.SQLException
- if an error occurs- See Also:
DistributedRequestManager.execDistributedWriteStoredProcedure(org.objectweb.cjdbc.common.sql.StoredProcedure)
distributedCommit
public void distributedCommit(long transactionId)
throws java.sql.SQLException
- Description copied from class:
DistributedRequestManager
- Distributed implementation of a commit
- Specified by:
distributedCommit
in class DistributedRequestManager
- Parameters:
transactionId
- id of the commiting transaction
- Throws:
java.sql.SQLException
- if an error occurs- See Also:
DistributedRequestManager.distributedCommit(long)
distributedRollback
public void distributedRollback(long transactionId)
throws java.sql.SQLException
- Description copied from class:
DistributedRequestManager
- Distributed implementation of a rollback
- Specified by:
distributedRollback
in class DistributedRequestManager
- Parameters:
transactionId
- id of the rollbacking transaction
- Throws:
java.sql.SQLException
- if an error occurs- See Also:
DistributedRequestManager.distributedRollback(long)
Copyright © 2002, 2005 - ObjectWeb Consortium - All Rights Reserved.