| java.lang.Object
 org.continuent.sequoia.controller.loadbalancer.AbstractLoadBalancer
org.continuent.sequoia.controller.loadbalancer.raidb2.RAIDb2
All known Subclasses: org.continuent.sequoia.controller.loadbalancer.raidb2.RAIDb2ec, org.continuent.sequoia.controller.loadbalancer.raidb2.RAIDb2_RR, org.continuent.sequoia.controller.loadbalancer.raidb2.RAIDb2_WRR, org.continuent.sequoia.controller.loadbalancer.raidb2.RAIDb2_LPRF,
| RAIDb2 | | abstract public class RAIDb2 extends AbstractLoadBalancer (Code) | | RAIDb-2 load balancer.
This class is an abstract call because the read requests coming from the
Request Manager are NOT treated here but in the subclasses. Transaction
management and write requests are broadcasted to all backends owning the
written table.
author:
Emmanuel Cecchet
author:
Jean-Bernard van Zuylen
author:
version:
1.0 |
| Method Summary | |
| public void | abort(TransactionMetaData tm)
| | final public void | begin(TransactionMetaData tm)
Begins a new transaction. | | public ExecuteResult | callableStatementExecute(StoredProcedure proc, MetadataCache metadataCache)
| | public ControllerResultSet | callableStatementExecuteQuery(StoredProcedure proc, MetadataCache metadataCache)
| | public ExecuteUpdateResult | callableStatementExecuteUpdate(StoredProcedure proc)
| | public void | closePersistentConnection(String login, long persistentConnectionId)
| | public void | commit(TransactionMetaData tm)
Commits a transaction. | | public void | disableBackend(DatabaseBackend db, boolean forceDisable)
Disables a backend that was previously enabled. | | public synchronized void | enableBackend(DatabaseBackend db, boolean writeEnabled)
Enables a Backend that was previously disabled. | | protected ControllerResultSet | executeReadRequestOnBackend(SelectRequest request, DatabaseBackend backend, MetadataCache metadataCache)
Execute a read request on the selected backend. | | protected Object | executeStoredProcedureOnBackend(StoredProcedure proc, boolean isExecuteQuery, DatabaseBackend backend, MetadataCache metadataCache)
Execute a stored procedure on the selected backend. | | public ControllerResultSet | getPreparedStatementGetMetaData(AbstractRequest request)
| | abstract public String | getRaidb2Xml()
| | public String | getXmlImpl()
| | public void | openPersistentConnection(String login, long persistentConnectionId)
| | public void | releaseSavepoint(TransactionMetaData tm, String savepointName)
| | public void | rollback(TransactionMetaData tm)
Rollbacks a transaction. | | public void | rollbackToSavepoint(TransactionMetaData tm, String savepointName)
| | public void | setSavepoint(TransactionMetaData tm, String savepointName)
Set a savepoint to a transaction. | | public ExecuteResult | statementExecute(AbstractRequest request, MetadataCache metadataCache)
| | abstract public ControllerResultSet | statementExecuteQuery(SelectRequest request, MetadataCache metadataCache)
Implementation specific load balanced read execution. | | public ExecuteUpdateResult | statementExecuteUpdate(AbstractWriteRequest request)
Performs a write request. | | public GeneratedKeysResult | statementExecuteUpdateWithKeys(AbstractWriteRequest request, MetadataCache metadataCache)
Perform a write request and return the auto generated keys. |
| CALLABLE_STATEMENT_EXECUTE | | final protected static int CALLABLE_STATEMENT_EXECUTE(Code) | | |
| CALLABLE_STATEMENT_EXECUTE_QUERY | | final protected static int CALLABLE_STATEMENT_EXECUTE_QUERY(Code) | | |
| RAIDb2 | | public RAIDb2(VirtualDatabase vdb, WaitForCompletionPolicy waitForCompletionPolicy, CreateTablePolicy createTablePolicy) throws Exception(Code) | | Creates a new RAIDb-2 request load balancer. A new backend worker thread is
created for each backend.
Parameters:
vdb - the virtual database this load balancer belongs to.
Parameters:
waitForCompletionPolicy - how many backends must complete beforereturning the result ?
Parameters:
createTablePolicy - the policy defining how 'create table' statementsshould be handled
exception:
Exception - if an error occurs |
| disableBackend | | public void disableBackend(DatabaseBackend db, boolean forceDisable) throws SQLException(Code) | | Disables a backend that was previously enabled.
Ask the corresponding connection manager to finalize the connections if
needed.
No sanity checks are performed by this function.
Parameters:
db - the database backend to disable
Parameters:
forceDisable - true if disabling must be forced on the backend
throws:
SQLException - if an error occurs |
| enableBackend | | public synchronized void enableBackend(DatabaseBackend db, boolean writeEnabled) throws SQLException(Code) | | Enables a Backend that was previously disabled.
Ask the corresponding connection manager to initialize the connections if
needed.
No sanity checks are performed by this function.
Parameters:
db - the database backend to enable
Parameters:
writeEnabled - True if the backend must be enabled for writes
throws:
SQLException - if an error occurs |
| executeStoredProcedureOnBackend | | protected Object executeStoredProcedureOnBackend(StoredProcedure proc, boolean isExecuteQuery, DatabaseBackend backend, MetadataCache metadataCache) throws SQLException, UnreachableBackendException(Code) | | Execute a stored procedure on the selected backend.
Parameters:
proc - the stored procedure to execute
Parameters:
isExecuteQuery - true if we must call CallableStatement.executeQuery,false if we must call CallableStatement.execute()
Parameters:
backend - the backend that will execute the request
Parameters:
metadataCache - the metadataCache if any or null a ControllerResultSet if isExecuteQuery is true, anExecuteResult object otherwise
throws:
SQLException - if an error occurs |
| getRaidb2Xml | | abstract public String getRaidb2Xml()(Code) | | return xml formatted information about this raidb2 load balancer
xml formatted string |
| releaseSavepoint | | public void releaseSavepoint(TransactionMetaData tm, String savepointName) throws SQLException(Code) | | Release a savepoint from a transaction
Parameters:
tm - The transaction marker metadata
Parameters:
savepointName - The name of the savepoint ro release
throws:
SQLException - if an error occurs |
| rollbackToSavepoint | | public void rollbackToSavepoint(TransactionMetaData tm, String savepointName) throws SQLException(Code) | | Rollback a transaction to a savepoint
Parameters:
tm - The transaction marker metadata
Parameters:
savepointName - The name of the savepoint
throws:
SQLException - if an error occurs |
| setSavepoint | | public void setSavepoint(TransactionMetaData tm, String savepointName) throws SQLException(Code) | | Set a savepoint to a transaction.
Parameters:
tm - The transaction marker metadata
Parameters:
savepointName - The name of the new savepoint
throws:
SQLException - if an error occurs |
| statementExecuteQuery | | abstract public ControllerResultSet statementExecuteQuery(SelectRequest request, MetadataCache metadataCache) throws SQLException(Code) | | Implementation specific load balanced read execution.
Parameters:
request - an SelectRequest
Parameters:
metadataCache - the metadataCache if any or null the corresponding java.sql.ResultSet
exception:
SQLException - if an error occurs |
| Methods inherited from org.continuent.sequoia.controller.loadbalancer.AbstractLoadBalancer | abstract public void abort(TransactionMetaData tm) throws SQLException(Code)(Java Doc)
protected int acquireLockAndCheckNbOfThreads(Object request, String requestDescription) throws SQLException, NoMoreBackendException(Code)(Java Doc)
abstract public void begin(TransactionMetaData tm) throws SQLException(Code)(Java Doc)
abstract public ExecuteResult callableStatementExecute(StoredProcedure proc, MetadataCache metadataCache) throws AllBackendsFailedException, SQLException(Code)(Java Doc)
abstract public ControllerResultSet callableStatementExecuteQuery(StoredProcedure proc, MetadataCache metadataCache) throws AllBackendsFailedException, SQLException(Code)(Java Doc)
abstract public ExecuteUpdateResult callableStatementExecuteUpdate(StoredProcedure proc) throws AllBackendsFailedException, SQLException(Code)(Java Doc)
abstract public void closePersistentConnection(String login, long persistentConnectionId) throws SQLException(Code)(Java Doc)
abstract public void commit(TransactionMetaData tm) throws AllBackendsFailedException, SQLException(Code)(Java Doc)
abstract public void disableBackend(DatabaseBackend db, boolean forceDisable) throws SQLException(Code)(Java Doc)
abstract public void enableBackend(DatabaseBackend db, boolean writeEnabled) throws SQLException(Code)(Java Doc)
final public static ExecuteResult executeCallableStatementExecuteOnBackend(StoredProcedure proc, DatabaseBackend backend, BackendWorkerThread workerThread, PooledConnection pc, MetadataCache metadataCache) throws SQLException, BadConnectionException(Code)(Java Doc)
final public static ControllerResultSet executeCallableStatementExecuteQueryOnBackend(StoredProcedure proc, DatabaseBackend backend, BackendWorkerThread workerThread, Connection c, MetadataCache metadataCache) throws SQLException, BadConnectionException(Code)(Java Doc)
final public static ExecuteUpdateResult executeCallableStatementExecuteUpdateOnBackend(StoredProcedure proc, DatabaseBackend backend, BackendWorkerThread workerThread, PooledConnection pc) throws SQLException, BadConnectionException(Code)(Java Doc)
final public static ExecuteResult executeStatementExecuteOnBackend(AbstractRequest request, DatabaseBackend backend, BackendWorkerThread workerThread, PooledConnection pc, MetadataCache metadataCache) throws SQLException, BadConnectionException(Code)(Java Doc)
final public static ControllerResultSet executeStatementExecuteQueryOnBackend(SelectRequest request, DatabaseBackend backend, BackendWorkerThread workerThread, Connection c, MetadataCache metadataCache) throws SQLException, BadConnectionException, UnreachableBackendException(Code)(Java Doc)
final public static ExecuteUpdateResult executeStatementExecuteUpdateOnBackend(AbstractWriteRequest request, DatabaseBackend backend, BackendWorkerThread workerThread, PooledConnection pc) throws SQLException, BadConnectionException(Code)(Java Doc)
final public static GeneratedKeysResult executeStatementExecuteUpdateWithKeysOnBackend(AbstractWriteRequest request, DatabaseBackend backend, BackendWorkerThread workerThread, PooledConnection pc, MetadataCache metadataCache) throws SQLException, BadConnectionException(Code)(Java Doc)
final public static Connection getConnectionAndBeginTransaction(DatabaseBackend backend, AbstractConnectionManager cm, AbstractRequest request) throws SQLException, UnreachableBackendException(Code)(Java Doc)
final public static int getDefaultTransactionIsolationLevel()(Code)(Java Doc)
abstract public String getInformation()(Code)(Java Doc)
protected int getNbToWait(int nbOfThreads)(Code)(Java Doc)
public int getNumberOfEnabledBackends()(Code)(Java Doc)
public int getParsingGranularity()(Code)(Java Doc)
abstract public ControllerResultSet getPreparedStatementGetMetaData(AbstractRequest request) throws SQLException(Code)(Java Doc)
public int getRAIDbLevel()(Code)(Java Doc)
final public RecoveryLog getRecoveryLog()(Code)(Java Doc)
public String getXml()(Code)(Java Doc)
abstract public String getXmlImpl()(Code)(Java Doc)
public void handleMacros(AbstractRequest request)(Code)(Java Doc)
abstract public void openPersistentConnection(String login, long persistentConnectionId) throws SQLException(Code)(Java Doc)
final public static ControllerResultSet preparedStatementGetMetaDataOnBackend(String sqlTemplate, DatabaseBackend backend, Connection c) throws SQLException, BadConnectionException(Code)(Java Doc)
abstract public ExecuteResult readOnlyCallableStatementExecute(StoredProcedure proc, MetadataCache metadataCache) throws SQLException(Code)(Java Doc)
abstract public ControllerResultSet readOnlyCallableStatementExecuteQuery(StoredProcedure proc, MetadataCache metadataCache) throws SQLException(Code)(Java Doc)
protected void releaseLockAndUnlockNextQuery(Object currentQuery)(Code)(Java Doc)
abstract public void releaseSavepoint(TransactionMetaData tm, String name) throws AllBackendsFailedException, SQLException(Code)(Java Doc)
public void removeObjectFromAndNotifyTotalOrderQueue(Object request)(Code)(Java Doc)
abstract public void rollback(TransactionMetaData tm) throws AllBackendsFailedException, SQLException(Code)(Java Doc)
abstract public void rollbackToSavepoint(TransactionMetaData tm, String savepointName) throws AllBackendsFailedException, SQLException(Code)(Java Doc)
final public void setDefaultTransactionIsolationLevel(int defaultTransactionIsolationLevel)(Code)(Java Doc)
public void setMacroHandler(MacrosHandler handler)(Code)(Java Doc)
final public void setRecoveryLog(RecoveryLog recoveryLog)(Code)(Java Doc)
abstract public void setSavepoint(TransactionMetaData tm, String name) throws AllBackendsFailedException, SQLException(Code)(Java Doc)
public void setWeight(String name, int w) throws SQLException(Code)(Java Doc)
abstract public ExecuteResult statementExecute(AbstractRequest request, MetadataCache metadataCache) throws AllBackendsFailedException, SQLException(Code)(Java Doc)
abstract public ControllerResultSet statementExecuteQuery(SelectRequest request, MetadataCache metadataCache) throws SQLException, AllBackendsFailedException(Code)(Java Doc)
abstract public ExecuteUpdateResult statementExecuteUpdate(AbstractWriteRequest request) throws AllBackendsFailedException, NoMoreBackendException, SQLException(Code)(Java Doc)
abstract public GeneratedKeysResult statementExecuteUpdateWithKeys(AbstractWriteRequest request, MetadataCache metadataCache) throws AllBackendsFailedException, NoMoreBackendException, SQLException(Code)(Java Doc)
public void waitForSuspendWritesToComplete(AbstractRequest request)(Code)(Java Doc)
public static void waitForTaskCompletion(long timeout, String requestDescription, AbstractTask task) throws SQLException(Code)(Java Doc)
public boolean waitForTotalOrder(Object request, boolean errorIfNotFound)(Code)(Java Doc)
|
|
|