クラス org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase

org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabaseに対する継承グラフ

[凡例]org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabaseのコラボレーション図

[凡例]すべてのメンバ一覧

---

説明

A VirtualDatabase represents a database from client point of view and hide the complexity of the cluster distribution to the client. The client always uses the virtual database name and the C-JDBC Controller will use the real connections when an SQL request comes in.

作者:

Emmanuel Cecchet

Mathieu Peltier

Nicolas Modrzyk

Vadim Kassin

バージョン:

1.0

VirtualDatabase.java の 65 行で定義されています。

Public メソッド
	VirtualDatabase (String controllerName, String name, int maxConnections, boolean pool, int minThreads, int maxThreads, long maxThreadIdleTime, int sqlShortFormLength, AbstractBlobFilter blobFilter)
boolean	isDistributed ()
boolean	checkUserAuthentication (String virtualLogin, String virtualPassword)
boolean	checkAdminAuthentication (String adminLogin, String adminPassword)
ControllerResultSet	execReadRequest (SelectRequest request) throws SQLException
int	execWriteRequest (AbstractWriteRequest request) throws SQLException
ControllerResultSet	execWriteRequestWithKeys (AbstractWriteRequest request) throws SQLException
ControllerResultSet	execReadStoredProcedure (StoredProcedure proc) throws SQLException
long	begin (String login) throws SQLException
void	commit (long transactionId) throws SQLException
void	rollback (long transactionId) throws SQLException
void	backupBackendWithCheckpoint (String backendName, String checkpointName, ArrayList tables) throws VirtualDatabaseException
void	addBackend (DatabaseBackend db) throws VirtualDatabaseException
void	addBackend (DatabaseBackend db, boolean checkForCompliance) throws VirtualDatabaseException
void	removeCheckpoint (String checkpointName) throws VirtualDatabaseException
void	removeBackend (DatabaseBackend db) throws VirtualDatabaseException
ArrayList	viewCheckpointNames ()
void	enableBackend (String backendName) throws VirtualDatabaseException
void	enableBackendFromCheckpoint (String backendName, String checkpointName) throws VirtualDatabaseException
DatabaseBackend	getAndCheckBackend (String backendName, int testEnable) throws VirtualDatabaseException
void	disableBackend (String backendName) throws VirtualDatabaseException
void	disableAllBackend () throws VirtualDatabaseException
void	enableAllBackend () throws VirtualDatabaseException
void	enableAllBackend (String checkpoint) throws VirtualDatabaseException
void	disableBackendForCheckpoint (String backendName, String checkpointName) throws VirtualDatabaseException
final void	acquireReadLockBackendLists () throws InterruptedException
final void	releaseReadLockBackendLists ()
AuthenticationManager	getAuthenticationManager ()
void	setAuthenticationManager (AuthenticationManager authenticationManager)
ArrayList	getBackends ()
ArrayList	getAllBackendNames () throws VirtualDatabaseException
String	getDatabaseName ()
String	getDatabaseProductName ()
int	getSQLShortFormLength ()
VirtualDatabaseMetaData	getMetaData ()
DatabaseSchema	getDatabaseSchemaFromActiveBackendsAndRefreshDatabaseProductNames () throws SQLException
void	setDatabaseSchema (DatabaseSchema schema, boolean isStatic)
RequestManager	getRequestManager ()
void	setRequestManager (RequestManager requestManager)
String	getVirtualDatabaseName ()
SQLMonitoring	getSQLMonitor ()
void	setSQLMonitor (SQLMonitoring sqlMonitor)
boolean	equals (Object other)
String	getXml ()
String	getBackendInformation (String backendName) throws VirtualDatabaseException
String	getName ()
int	getCurrentNbOfThreads ()
void	addCurrentNbOfThread ()
void	removeCurrentNbOfThread ()
int	getMinNbOfThreads ()
boolean	isPoolConnectionThreads ()
void	setMinNbOfThreads (int minNbOfThreads)
void	setPoolConnectionThreads (boolean poolConnectionThreads)
long	getMaxThreadIdleTime ()
void	setMaxThreadIdleTime (long maxThreadIdleTime)
int	getMaxNbOfConnections ()
int	getMaxNbOfThreads ()
ArrayList	getPendingConnections ()
void	setMaxNbOfConnections (int maxNbOfConnections)
void	setMaxNbOfThreads (int maxNbOfThreads)
ArrayList	getActiveThreads ()
String[]	viewBackendInformation (String backendName) throws VirtualDatabaseException
void	addIdleThread ()
void	removeIdleThread ()
int	getIdleThreads ()
ArrayList	viewAllBackendNames () throws VirtualDatabaseException
ArrayList	viewAllClientNames ()
void	disableAllBackendForCheckpoint (String checkpoint) throws VirtualDatabaseException
synchronized void	shutdown (int level)
void	shutdown () throws VirtualDatabaseException
void	setBlobFilter (AbstractBlobFilter filter)
AbstractBlobFilter	getBlobFilter ()
String	getBackendState (String backendName) throws VirtualDatabaseException
String	viewOwningController ()
void	restoreBackendFromBackupCheckpoint (String databaseBackendName, String checkpointName) throws VirtualDatabaseException, BackupException, OctopusException
void	storeBackendsCheckpoint ()
boolean	hasRecoveryLog ()
Public 変数
Trace	logger = null
Static Public 変数
final int	CHECK_BACKEND_ENABLE = 1
final int	CHECK_BACKEND_DISABLE = 0
final int	NO_CHECK_BACKEND = -1
Protected メソッド
int	execWriteStoredProcedure (StoredProcedure proc) throws SQLException
String	getDistributionXml ()
Protected 変数
String	name
AuthenticationManager	authenticationManager
ArrayList	backends
ReadPrioritaryFIFOWriteLock	rwLock
RequestManager	requestManager
Trace	requestLogger = null
int	maxNbOfConnections
boolean	poolConnectionThreads
long	maxThreadIdleTime
int	minNbOfThreads
int	maxNbOfThreads
int	currentNbOfThreads
VirtualDatabaseMetaData	metadata
変数
String	controllerName
Private 変数
ArrayList	activeThreads = new ArrayList()
int	idleThreads = 0
ArrayList	pendingConnections = new ArrayList()
SQLMonitoring	sqlMonitor = null
int	sqlShortFormLength
AbstractBlobFilter	blobFilter
String	databaseProductNames = "C-JDBC"

---

コンストラクタとデストラクタ

org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.VirtualDatabase (  String  controllerName, String  name, int  maxConnections, boolean  pool, int  minThreads, int  maxThreads, long  maxThreadIdleTime, int  sqlShortFormLength, AbstractBlobFilter  blobFilter )

Creates a new VirtualDatabase instance. 引数: name  the virtual database name. maxConnections  maximum number of concurrent connections. pool  should we use a pool of threads for handling connections? minThreads  minimum number of threads in the pool maxThreads  maximum number of threads in the pool maxThreadIdleTime  maximum time a thread can remain idle before being removed from the pool. sqlShortFormLength  maximum number of characters of an SQL statement to diplay in traces or exceptions blobFilter  encoding method for blobs controllerName  of the controller we belong to VirtualDatabase.java の 174 行で定義されています。 参照先 org.objectweb.cjdbc.common.log.Trace.getLogger(), org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.requestLogger, と org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.rwLock. { this.controllerName = controllerName; this.name = name; this.maxNbOfConnections = maxConnections; this.poolConnectionThreads = pool; this.minNbOfThreads = minThreads; this.maxNbOfThreads = maxThreads; this.maxThreadIdleTime = maxThreadIdleTime; this.sqlShortFormLength = sqlShortFormLength; this.blobFilter = blobFilter; backends = new ArrayList(); rwLock = new ReadPrioritaryFIFOWriteLock(); logger = Trace.getLogger("org.objectweb.cjdbc.controller.virtualdatabase." + name); requestLogger = Trace .getLogger("org.objectweb.cjdbc.controller.virtualdatabase.request." + name); }

---

メソッド

final void org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.acquireReadLockBackendLists (   )  throws InterruptedException

Acquires a read lock on the backend lists (both enabled and disabled backends). This should be called prior traversing the backend ArrayList. 例外: InterruptedException  if an error occurs VirtualDatabase.java の 1050 行で定義されています。 参照元 org.objectweb.cjdbc.controller.loadbalancer.AbstractLoadBalancer.AbstractLoadBalancer(), org.objectweb.cjdbc.controller.loadbalancer.paralleldb.ParallelDB_RR.chooseBackendForReadRequest(), org.objectweb.cjdbc.controller.loadbalancer.paralleldb.ParallelDB_LPRF.chooseBackendForReadRequest(), org.objectweb.cjdbc.controller.loadbalancer.raidb2.RAIDb2_RR.execReadRequest(), org.objectweb.cjdbc.controller.loadbalancer.raidb2.RAIDb2_LPRF.execReadRequest(), org.objectweb.cjdbc.controller.loadbalancer.raidb0.RAIDb0.execReadRequest(), org.objectweb.cjdbc.controller.loadbalancer.raidb1.RAIDb1_LPRF.executeLPRF(), org.objectweb.cjdbc.controller.loadbalancer.raidb1.RAIDb1_RR.executeRoundRobinRequest(), org.objectweb.cjdbc.controller.loadbalancer.raidb1.RAIDb1_WRR.executeWRR(), org.objectweb.cjdbc.controller.virtualdatabase.DistributedVirtualDatabase.isCompatibleBackend(), と org.objectweb.cjdbc.controller.monitoring.datacollector.DataCollector.retrieveBackendsData(). { rwLock.acquireRead(); }

void org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.addBackend (  DatabaseBackend  db, boolean  checkForCompliance )  throws VirtualDatabaseException

Add a backend to this virtual database. 引数: db  the database backend to add checkForCompliance  should load the driver ? 例外: VirtualDatabaseException  if an error occurs VirtualDatabase.java の 595 行で定義されています。 { if (db == null) { String msg = "Illegal null database backend in addBackend(DatabaseBackend) method"; logger.error(msg); throw new VirtualDatabaseException(msg); } if (db.isReadEnabled()) { String msg = "It is not allowed to add an enabled database."; logger.error(msg); throw new VirtualDatabaseException(msg); } try { rwLock.acquireWrite(); } catch (InterruptedException e) { String msg = Translate.get( "loadbalancer.backendlist.acquire.writelock.failed", e); logger.error(msg); throw new VirtualDatabaseException(msg); } if (backends.indexOf(db) == -1) { // Initialize the driver and check the compliance try { if (logger.isDebugEnabled()) logger.debug("Checking driver compliance"); if (checkForCompliance) db.checkDriverCompliance(); // Also loads the // driver } catch (Exception e) { rwLock.releaseWrite(); String msg = "Error while adding database backend " + db.getName() + " (" + e + ")"; logger.warn(msg); throw new VirtualDatabaseException(msg); } db.setSqlShortFormLength(getSQLShortFormLength()); backends.add(db); // Add the backend to the list if (logger.isDebugEnabled()) logger.debug("Backend " + db.getName() + " added successfully"); rwLock.releaseWrite(); // Relase the lock } else { rwLock.releaseWrite(); String msg = "Duplicate backend " + db.getURL(); logger.warn(msg); throw new VirtualDatabaseException(msg); } }

void org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.addBackend (  DatabaseBackend  db  )  throws VirtualDatabaseException

Add a backend to this virtual database. 引数: db  the database backend to add 例外: VirtualDatabaseException  if an error occurs VirtualDatabase.java の 583 行で定義されています。 { this.addBackend(db, true); }

void org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.addCurrentNbOfThread (   )

Adds one to currentNbOfThreads. Warning! This method is not synchronized. VirtualDatabase.java の 1433 行で定義されています。 参照元 org.objectweb.cjdbc.controller.core.ControllerWorkerThread.run(). { currentNbOfThreads++; }

void org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.addIdleThread (   )

Method add an idle thread. Warning! This method must be called in a synchronized block on activeThreads. VirtualDatabase.java の 1581 行で定義されています。 参照元 org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabaseWorkerThread.run(). { idleThreads++; }

void org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.backupBackendWithCheckpoint (  String  backendName, String  checkpointName, ArrayList  tables )  throws VirtualDatabaseException

参照: org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabaseMBean.backupBackendWithCheckpoint org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabaseMBeanに実装されています. VirtualDatabase.java の 560 行で定義されています。 { try { DatabaseBackend db = getAndCheckBackend(backendName, NO_CHECK_BACKEND); requestManager.backupBackendWithCheckpoint(db, checkpointName, tables, db .isReadEnabled()); } catch (SQLException sql) { throw new VirtualDatabaseException(sql.getMessage()); } }

long org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.begin (  String  login  )  throws SQLException

Begins a new transaction and returns the corresponding transaction identifier. This method is called from the driver when org.objectweb.cjdbc.driver.Connection#setAutoCommit(boolean)is called with false argument. 引数: login  the login used by the connection 戻り値: an unique transaction identifier 例外: SQLException  if an error occurs VirtualDatabase.java の 492 行で定義されています。 参照元 org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabaseWorkerThread.run(). { try { long tid = requestManager.begin(login); if (requestLogger.isInfoEnabled()) requestLogger.info("B " + tid); return tid; } catch (SQLException e) { String msg = "Begin failed (" + e.getMessage() + ")"; logger.warn(msg); throw e; } }

boolean org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.checkAdminAuthentication (  String  adminLogin, String  adminPassword )

Checks if a given admin login/password is ok. 引数: adminLogin  admin user login adminPassword  admin user password 戻り値: true if the login/password is known from the AuthenticationManager. Returns false if no AuthenticationManager is defined. org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabaseMBeanに実装されています. VirtualDatabase.java の 241 行で定義されています。 参照先 org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.authenticationManager, org.objectweb.cjdbc.common.log.Trace.error(), と org.objectweb.cjdbc.controller.authentication.AuthenticationManager.isValidAdminUser(). { if (authenticationManager == null) { logger.error("No authentification manager defined to check admin login '" + adminLogin + "'"); return false; } else return authenticationManager.isValidAdminUser(new VirtualDatabaseUser( adminLogin, adminPassword)); }

boolean org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.checkUserAuthentication (  String  virtualLogin, String  virtualPassword )

Checks if a given virtual login/password is ok. 引数: virtualLogin  the virtual user login virtualPassword  the virtual user password 戻り値: true if the login/password is known from the AuthenticationManager. Returns false if no AuthenticationManager is defined. VirtualDatabase.java の 218 行で定義されています。 参照先 org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.authenticationManager, org.objectweb.cjdbc.common.log.Trace.error(), と org.objectweb.cjdbc.controller.authentication.AuthenticationManager.isValidVirtualUser(). { if (authenticationManager == null) { logger.error("No authentification manager defined to check login '" + virtualLogin + "'"); return false; } else return authenticationManager.isValidVirtualUser(new VirtualDatabaseUser( virtualLogin, virtualPassword)); }

void org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.commit (  long  transactionId  )  throws SQLException

Commits a transaction given its id. 引数: transactionId  the transaction id 例外: SQLException  if an error occurs VirtualDatabase.java の 515 行で定義されています。 参照元 org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabaseWorkerThread.run(), と org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabaseWorkerThread.setRequestParameters(). { try { if (requestLogger.isInfoEnabled()) requestLogger.info("C " + transactionId); requestManager.commit(transactionId); } catch (SQLException e) { String msg = "Commit of transaction '" + transactionId + "' failed (" + e.getMessage() + ")"; logger.warn(msg); throw e; } }

void org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.disableAllBackend (   )  throws VirtualDatabaseException

Prepare this virtual database for shutdown. This turns off all the backends by cutting communication from this database. This does not prevents other virtual database to use shared backends. This doesn't create checkpoints either. 例外: VirtualDatabaseException  if an error occurs org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabaseMBeanに実装されています. VirtualDatabase.java の 944 行で定義されています。 参照先 org.objectweb.cjdbc.controller.backend.DatabaseBackend.getName(), と org.objectweb.cjdbc.controller.backend.DatabaseBackend.isReadEnabled. 参照元 org.objectweb.cjdbc.controller.requestmanager.distributed.DistributedRequestManager.completeFailedOnAllBackends(), と org.objectweb.cjdbc.controller.core.Controller.removeVirtualDatabase(). { try { int size = this.backends.size(); DatabaseBackend dbe; for (int i = 0; i < size; i++) { dbe = (DatabaseBackend) backends.get(i); if (dbe.isReadEnabled()) requestManager.disableBackend(getAndCheckBackend(dbe.getName(), CHECK_BACKEND_DISABLE)); } } catch (Exception e) { throw new VirtualDatabaseException(e.getMessage()); } }

void org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.disableAllBackendForCheckpoint (  String  checkpoint  )  throws VirtualDatabaseException

参照: org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabaseMBean.disableAllBackendForCheckpoint(java.lang.String) org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabaseMBeanに実装されています. VirtualDatabase.java の 1633 行で定義されています。 { if (checkpoint == null) { disableAllBackend(); return; } try { this.acquireReadLockBackendLists(); requestManager.disableBackendsForCheckpoint(backends, checkpoint); this.releaseReadLockBackendLists(); } catch (Exception e) { throw new VirtualDatabaseException(e.getMessage()); } }

void org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.disableBackend (  String  backendName  )  throws VirtualDatabaseException

参照: org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabaseMBean.disableBackend org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabaseMBeanに実装されています. VirtualDatabase.java の 917 行で定義されています。 { try { requestManager.disableBackend(getAndCheckBackend(backendName, CHECK_BACKEND_DISABLE)); requestManager.setDatabaseSchema( getDatabaseSchemaFromActiveBackendsAndRefreshDatabaseProductNames(), false); } catch (Exception e) { logger.error("An error occured while disabling backend " + backendName + " (" + e + ")"); throw new VirtualDatabaseException(e.getMessage()); } }

void org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.disableBackendForCheckpoint (  String  backendName, String  checkpointName )  throws VirtualDatabaseException

参照: org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabaseMBean.disableBackendForCheckpoint org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabaseMBeanに実装されています. VirtualDatabase.java の 1024 行で定義されています。 { try { requestManager.disableBackendForCheckpoint(getAndCheckBackend( backendName, CHECK_BACKEND_DISABLE), checkpointName); requestManager.setDatabaseSchema( getDatabaseSchemaFromActiveBackendsAndRefreshDatabaseProductNames(), false); } catch (Exception e) { logger.error("An error occured while disabling backend " + backendName + " (" + e + ")"); throw new VirtualDatabaseException(e.getMessage()); } }

void org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.enableAllBackend (  String  checkpoint  )  throws VirtualDatabaseException

Prepare this virtual database for startup. This turns on all the backends 引数: checkpoint  checkpoint for recovery log 例外: VirtualDatabaseException  if fails org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabaseMBeanに実装されています. VirtualDatabase.java の 995 行で定義されています。 参照先 org.objectweb.cjdbc.controller.backend.DatabaseBackend.isReadEnabled. { try { int size = this.backends.size(); DatabaseBackend dbe; for (int i = 0; i < size; i++) { dbe = (DatabaseBackend) backends.get(i); if (!dbe.isReadEnabled()) { if (checkpoint == null) enableBackend(((DatabaseBackend) backends.get(i)).getName()); else enableBackendFromCheckpoint(((DatabaseBackend) backends.get(i)) .getName(), checkpoint); } } } catch (Exception e) { throw new VirtualDatabaseException(e.getMessage()); } }

void org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.enableAllBackend (   )  throws VirtualDatabaseException

Prepare this virtual database for startup. This turns on all the backends 例外: VirtualDatabaseException  if fails org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabaseMBeanに実装されています. VirtualDatabase.java の 969 行で定義されています。 参照先 org.objectweb.cjdbc.controller.backend.DatabaseBackend.isReadEnabled. { try { int size = this.backends.size(); DatabaseBackend dbe; for (int i = 0; i < size; i++) { dbe = (DatabaseBackend) backends.get(i); if (!dbe.isReadEnabled()) enableBackend(((DatabaseBackend) backends.get(i)).getName()); } } catch (Exception e) { logger.error(e); throw new VirtualDatabaseException(e.getMessage()); } }

void org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.enableBackend (  String  backendName  )  throws VirtualDatabaseException

参照: org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabaseMBean.enableBackend org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabaseMBeanに実装されています. VirtualDatabase.java の 753 行で定義されています。 参照先 org.objectweb.cjdbc.controller.backend.DatabaseBackend.getDatabaseProductName(), と org.objectweb.cjdbc.controller.backend.DatabaseBackend.getLastKnownCheckpoint(). { // Call the Request Manager try { DatabaseBackend backend = getAndCheckBackend(backendName, CHECK_BACKEND_ENABLE); String lastCheckpoint = backend.getLastKnownCheckpoint(); if (lastCheckpoint != null) { requestManager.enableBackendFromCheckpoint(backend, lastCheckpoint); } else requestManager.enableBackend(backend); // Update the list of database product names if (databaseProductNames.indexOf(backend.getDatabaseProductName()) == -1) databaseProductNames += "," + backend.getDatabaseProductName(); } catch (Exception e) { throw new VirtualDatabaseException(e.getMessage()); } }

void org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.enableBackendFromCheckpoint (  String  backendName, String  checkpointName )  throws VirtualDatabaseException

参照: org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabaseMBean.enableBackendFromCheckpoint org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabaseMBeanに実装されています. VirtualDatabase.java の 781 行で定義されています。 参照先 org.objectweb.cjdbc.controller.backend.DatabaseBackend.getDatabaseProductName(). { // Call the Request Manager try { DatabaseBackend backend = getAndCheckBackend(backendName, CHECK_BACKEND_ENABLE); requestManager.enableBackendFromCheckpoint(backend, checkpointName); // Update the list of database product names if (databaseProductNames.indexOf(backend.getDatabaseProductName()) == -1) databaseProductNames += "," + backend.getDatabaseProductName(); } catch (Exception e) { throw new VirtualDatabaseException( "Failed to enable backend from checkpoint: " + e); } }

boolean org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.equals (  Object  other  )

Two virtual databases are equal if they have the same name and group. 引数: other  the object to compare with 戻り値: true if the two virtual databases are equals org.objectweb.cjdbc.controller.virtualdatabase.DistributedVirtualDatabaseで再定義されています。 VirtualDatabase.java の 1294 行で定義されています。 参照先 org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.getDatabaseName(). { if ((other == null) || (!(other instanceof VirtualDatabase))) return false; else { VirtualDatabase db = (VirtualDatabase) other; return name.equals(db.getDatabaseName()); } }

ControllerResultSet org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.execReadRequest (  SelectRequest  request  )  throws SQLException

Performs a read request and returns the reply. 引数: request  the request to execute 戻り値: a ControllerResultSet value 例外: SQLException  if the request fails VirtualDatabase.java の 262 行で定義されています。 参照先 org.objectweb.cjdbc.controller.requestmanager.RequestManager.execReadRequest(), org.objectweb.cjdbc.common.log.Trace.info(), org.objectweb.cjdbc.common.log.Trace.isInfoEnabled(), org.objectweb.cjdbc.controller.monitoring.SQLMonitoring.logError(), org.objectweb.cjdbc.controller.monitoring.SQLMonitoring.logRequestTime(), org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.requestLogger, org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.sqlMonitor, と org.objectweb.cjdbc.common.log.Trace.warn(). 参照元 org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabaseWorkerThread.run(). { if (request == null) { String msg = "Request failed (null read request received)"; logger.warn(msg); throw new SQLException(msg); } try { if (requestLogger.isInfoEnabled()) requestLogger.info("S " + request.getTransactionId() + " " + request.getSQL()); long start = 0; if (sqlMonitor != null) start = System.currentTimeMillis(); ControllerResultSet rs = requestManager.execReadRequest(request); if (sqlMonitor != null) sqlMonitor.logRequestTime(request, System.currentTimeMillis() - start); return rs; } catch (SQLException e) { String msg = "Request '" + request.getId() + "' failed (" + e.getMessage() + ")"; logger.warn(msg); if (sqlMonitor != null) sqlMonitor.logError(request); throw e; } }

ControllerResultSet org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.execReadStoredProcedure (  StoredProcedure  proc  )  throws SQLException

Call a stored procedure that returns a ResultSet. 引数: proc  the stored procedure call 戻り値: a java.sql.ResultSet value 例外: SQLException  if an error occurs VirtualDatabase.java の 397 行で定義されています。 参照先 org.objectweb.cjdbc.controller.requestmanager.RequestManager.execReadStoredProcedure(), org.objectweb.cjdbc.common.log.Trace.info(), org.objectweb.cjdbc.common.log.Trace.isInfoEnabled(), org.objectweb.cjdbc.controller.monitoring.SQLMonitoring.logError(), org.objectweb.cjdbc.controller.monitoring.SQLMonitoring.logRequestTime(), org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.requestLogger, org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.sqlMonitor, と org.objectweb.cjdbc.common.log.Trace.warn(). 参照元 org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabaseWorkerThread.run(). { if (proc == null) { String msg = "Request failed (null stored procedure received)"; logger.warn(msg); throw new SQLException(msg); } try { if (requestLogger.isInfoEnabled()) requestLogger .info("S " + proc.getTransactionId() + " " + proc.getSQL()); long start = 0; if (sqlMonitor != null) start = System.currentTimeMillis(); ControllerResultSet rs = requestManager.execReadStoredProcedure(proc); if (sqlMonitor != null) sqlMonitor.logRequestTime(proc, System.currentTimeMillis() - start); return rs; } catch (SQLException e) { String msg = Translate.get("loadbalancer.storedprocedure.failed", new String[]{String.valueOf(proc.getId()), e.getMessage()}); logger.warn(msg); if (sqlMonitor != null) sqlMonitor.logError(proc); throw e; } }

int org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.execWriteRequest (  AbstractWriteRequest  request  )  throws SQLException

Performs a write request and returns the number of rows affected. 引数: request  the request to execute 戻り値: number of rows affected 例外: SQLException  if the request fails VirtualDatabase.java の 307 行で定義されています。 参照先 org.objectweb.cjdbc.controller.requestmanager.RequestManager.execWriteRequest(), org.objectweb.cjdbc.common.log.Trace.info(), org.objectweb.cjdbc.common.log.Trace.isInfoEnabled(), org.objectweb.cjdbc.controller.monitoring.SQLMonitoring.logError(), org.objectweb.cjdbc.controller.monitoring.SQLMonitoring.logRequestTime(), org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.requestLogger, org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.sqlMonitor, と org.objectweb.cjdbc.common.log.Trace.warn(). 参照元 org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabaseWorkerThread.run(). { if (request == null) { String msg = "Request failed (null write request received)"; logger.warn(msg); throw new SQLException(msg); } try { if (requestLogger.isInfoEnabled()) requestLogger.info("W " + request.getTransactionId() + " " + request.getSQL()); long start = 0; if (sqlMonitor != null) start = System.currentTimeMillis(); int result = requestManager.execWriteRequest(request); if (sqlMonitor != null) sqlMonitor.logRequestTime(request, System.currentTimeMillis() - start); return result; } catch (SQLException e) { String msg = "Request '" + request.getId() + "' failed (" + e.getMessage() + ")"; logger.warn(msg); if (sqlMonitor != null) sqlMonitor.logError(request); throw e; } }

ControllerResultSet org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.execWriteRequestWithKeys (  AbstractWriteRequest  request  )  throws SQLException

Performs a write request and returns the auto generated keys. 引数: request  the request to execute 戻り値: auto generated keys 例外: SQLException  if the request fails VirtualDatabase.java の 351 行で定義されています。 参照先 org.objectweb.cjdbc.controller.requestmanager.RequestManager.execWriteRequestWithKeys(), org.objectweb.cjdbc.common.log.Trace.info(), org.objectweb.cjdbc.common.log.Trace.isInfoEnabled(), org.objectweb.cjdbc.controller.monitoring.SQLMonitoring.logError(), org.objectweb.cjdbc.controller.monitoring.SQLMonitoring.logRequestTime(), org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.requestLogger, org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.sqlMonitor, と org.objectweb.cjdbc.common.log.Trace.warn(). 参照元 org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabaseWorkerThread.run(). { if (request == null) { String msg = "Request failed (null write request received)"; logger.warn(msg); throw new SQLException(msg); } try { if (requestLogger.isInfoEnabled()) requestLogger.info("W " + request.getTransactionId() + " " + request.getSQL()); long start = 0; if (sqlMonitor != null) start = System.currentTimeMillis(); ControllerResultSet result = requestManager .execWriteRequestWithKeys(request); if (sqlMonitor != null) sqlMonitor.logRequestTime(request, System.currentTimeMillis() - start); return result; } catch (SQLException e) { String msg = "Request '" + request.getId() + "' failed (" + e.getMessage() + ")"; logger.warn(msg); if (sqlMonitor != null) sqlMonitor.logError(request); throw e; } }

int org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.execWriteStoredProcedure (  StoredProcedure  proc  )  throws SQLException [protected]

Call a stored procedure that performs an update. 引数: proc  the stored procedure call 戻り値: number of rows affected 例外: SQLException  if an error occurs VirtualDatabase.java の 442 行で定義されています。 { if (proc == null) { String msg = "Request failed (null stored procedure received)"; logger.warn(msg); throw new SQLException(msg); } try { if (requestLogger.isInfoEnabled()) requestLogger .info("W " + proc.getTransactionId() + " " + proc.getSQL()); long start = 0; if (sqlMonitor != null) start = System.currentTimeMillis(); int result = requestManager.execWriteStoredProcedure(proc); if (sqlMonitor != null) sqlMonitor.logRequestTime(proc, System.currentTimeMillis() - start); return result; } catch (SQLException e) { String msg = Translate.get("loadbalancer.storedprocedure.failed", new String[]{String.valueOf(proc.getId()), e.getMessage()}); logger.warn(msg); if (sqlMonitor != null) sqlMonitor.logError(proc); throw e; } }

ArrayList org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.getActiveThreads (   )

Returns the activeThreads. 戻り値: ArrayList VirtualDatabase.java の 1562 行で定義されています。 参照元 org.objectweb.cjdbc.common.monitor.client.AbstractClientDataCollector.checkClientIndex(), org.objectweb.cjdbc.controller.monitoring.datacollector.DataCollector.retrieveClientsData(), org.objectweb.cjdbc.controller.monitoring.datacollector.DataCollector.retrieveVirtualDatabasesData(), org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabaseWorkerThread.run(), org.objectweb.cjdbc.controller.core.ControllerWorkerThread.run(), org.objectweb.cjdbc.common.monitor.client.AbstractClientDataCollector.setClientIndex(), と org.objectweb.cjdbc.controller.core.shutdown.VirtualDatabaseShutdownThread.terminateClients(). { return activeThreads; }

ArrayList org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.getAllBackendNames (   )  throws VirtualDatabaseException

参照: org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabaseMBean.viewAllBackendNames VirtualDatabase.java の 1102 行で定義されています。 { try { acquireReadLockBackendLists(); } catch (InterruptedException e) { String msg = "Unable to acquire read lock on backend list in getAllBackendNames (" + e + ")"; logger.error(msg); throw new VirtualDatabaseException(msg); } int size = backends.size(); ArrayList result = new ArrayList(); for (int i = 0; i < size; i++) { result.add(((DatabaseBackend) backends.get(i)).getName()); } releaseReadLockBackendLists(); return result; }

DatabaseBackend org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.getAndCheckBackend (  String  backendName, int  testEnable )  throws VirtualDatabaseException

Find the DatabaseBackend corresponding to the given backend name and check if it is possible to disable this backend. In the case enable, this method also updates the virtual database schema by merging it with the one provided by this backend. 引数: backendName  backend to look for testEnable  NO_CHECK_BACKEND no check is done, if CHECK_BACKEND_DISABLE check for disable, if CHECK_BACKEND_ENABLE check for enable, else do not check 戻り値: the backend to disable 例外: VirtualDatabaseException  if an error occurs VirtualDatabase.java の 815 行で定義されています。 参照先 org.objectweb.cjdbc.controller.backend.DatabaseBackend.checkDatabaseSchema(), org.objectweb.cjdbc.controller.backend.DatabaseBackend.getDatabaseSchema(), org.objectweb.cjdbc.controller.backend.DatabaseBackend.getName(), org.objectweb.cjdbc.controller.backend.DatabaseBackend.initializeConnections(), と org.objectweb.cjdbc.controller.backend.DatabaseBackend.isReadEnabled. 参照元 org.objectweb.cjdbc.common.monitor.backend.AbstractBackendDataCollector.collectValue(). { try { acquireReadLockBackendLists(); } catch (InterruptedException e) { String msg = "Unable to acquire read lock on backend list in getAndCheckBackend (" + e + ")"; logger.error(msg); throw new VirtualDatabaseException(msg); } // Find the backend int size = backends.size(); DatabaseBackend b = null; for (int i = 0; i < size; i++) { b = (DatabaseBackend) backends.get(i); if (b.getName().equals(backendName)) break; else b = null; } // Check not null if (b == null) { releaseReadLockBackendLists(); String msg = "Trying to access a non-existing backend " + backendName; logger.warn(msg); throw new VirtualDatabaseException(msg); } // Check enable/disable switch (testEnable) { case NO_CHECK_BACKEND : break; case CHECK_BACKEND_DISABLE : if (!b.isReadEnabled()) { releaseReadLockBackendLists(); String msg = "Backend " + backendName + " is already disabled"; logger.warn(msg); throw new VirtualDatabaseException(msg); } break; case CHECK_BACKEND_ENABLE : if (b.isReadEnabled()) { releaseReadLockBackendLists(); String msg = "Backend " + backendName + " is already enabled"; logger.warn(msg); throw new VirtualDatabaseException(msg); } break; default : String msg = "Unexpected parameter in getAndCheckBackend(...)"; logger.error(msg); throw new VirtualDatabaseException(msg); } releaseReadLockBackendLists(); if (testEnable == CHECK_BACKEND_ENABLE) { // Initialize backend for enable try { if (logger.isDebugEnabled()) logger.debug("Initializing connections for backend " + b.getName()); b.initializeConnections(); if (logger.isDebugEnabled()) logger.debug("Checking schema for backend " + b.getName()); b.checkDatabaseSchema(); DatabaseSchema backendSchema = b.getDatabaseSchema(); if (backendSchema != null) requestManager.mergeDatabaseSchema(backendSchema); else logger.warn("Backend " + b.getName() + " has no defined schema."); } catch (SQLException e) { String msg = "Error while initalizing database backend " + b.getName() + " (" + e + ")"; logger.warn(msg); throw new VirtualDatabaseException(msg); } } return b; }

AuthenticationManager org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.getAuthenticationManager (   )

Returns the authentication manager of this virtual database. 戻り値: an AuthenticationManager instance VirtualDatabase.java の 1072 行で定義されています。 参照元 org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabaseMetaData.getTablePrivileges(), org.objectweb.cjdbc.controller.virtualdatabase.protocol.VirtualDatabaseConfiguration.isCompatible(), org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabaseWorkerThread.run(), と org.objectweb.cjdbc.controller.virtualdatabase.protocol.VirtualDatabaseConfiguration.VirtualDatabaseConfiguration(). { return authenticationManager; }

String org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.getBackendInformation (  String  backendName  )  throws VirtualDatabaseException

参照: org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabaseMBean.getBackendInformation(String) org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabaseMBeanに実装されています. VirtualDatabase.java の 1367 行で定義されています。 参照先 org.objectweb.cjdbc.controller.backend.DatabaseBackend.getName(), と org.objectweb.cjdbc.controller.backend.DatabaseBackend.getXml(). { try { acquireReadLockBackendLists(); } catch (InterruptedException e) { String msg = "Unable to acquire read lock on backend list in getBackendInformation (" + e + ")"; logger.error(msg); throw new VirtualDatabaseException(msg); } // Find the backend int size = backends.size(); DatabaseBackend b = null; for (int i = 0; i < size; i++) { b = (DatabaseBackend) backends.get(i); if (b.getName().equals(backendName)) break; else b = null; } if (b == null) { releaseReadLockBackendLists(); String msg = "Backend " + backendName + " does not exists."; logger.warn(msg); throw new VirtualDatabaseException(msg); } releaseReadLockBackendLists(); return b.getXml(); }

ArrayList org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.getBackends (   )

Return the list of all backends 戻り値: ArrayList of DatabaseBackend Objects VirtualDatabase.java の 1094 行で定義されています。 参照元 org.objectweb.cjdbc.controller.loadbalancer.AbstractLoadBalancer.AbstractLoadBalancer(), org.objectweb.cjdbc.controller.loadbalancer.paralleldb.ParallelDB_RR.chooseBackendForReadRequest(), org.objectweb.cjdbc.controller.loadbalancer.paralleldb.ParallelDB_LPRF.chooseBackendForReadRequest(), org.objectweb.cjdbc.controller.loadbalancer.raidb2.RAIDb2_RR.execReadRequest(), org.objectweb.cjdbc.controller.loadbalancer.raidb2.RAIDb2_LPRF.execReadRequest(), org.objectweb.cjdbc.controller.loadbalancer.raidb0.RAIDb0.execReadRequest(), org.objectweb.cjdbc.controller.loadbalancer.raidb1.RAIDb1_LPRF.executeLPRF(), org.objectweb.cjdbc.controller.loadbalancer.raidb1.RAIDb1_RR.executeRoundRobinRequest(), org.objectweb.cjdbc.controller.loadbalancer.raidb1.RAIDb1_WRR.executeWRR(), org.objectweb.cjdbc.controller.loadbalancer.raidb2.RAIDb2.execWriteRequest(), org.objectweb.cjdbc.controller.loadbalancer.raidb1.RAIDb1ec_RR.getInformation(), org.objectweb.cjdbc.controller.monitoring.datacollector.DataCollector.retrieveBackendsData(), org.objectweb.cjdbc.controller.requestmanager.RequestManager.setBackendsLastKnownCheckpointFromRecoveryLog(), と org.objectweb.cjdbc.controller.virtualdatabase.protocol.VirtualDatabaseConfiguration.VirtualDatabaseConfiguration(). { return backends; }

String org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.getBackendState (  String  backendName  )  throws VirtualDatabaseException

参照: org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabaseMBean.getBackendState(java.lang.String) org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabaseMBeanに実装されています. VirtualDatabase.java の 1704 行で定義されています。 参照先 org.objectweb.cjdbc.controller.backend.DatabaseBackend.isReadEnabled. { DatabaseBackend backend = getAndCheckBackend(backendName, NO_CHECK_BACKEND); // Backend cannot be null, otherwise the above throws an // VirtualDatabaseException return "" + backend.isReadEnabled(); }

AbstractBlobFilter org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.getBlobFilter (   )

Returns the blobFilter associated to this virtual database 戻り値: Returns the blobFilter. VirtualDatabase.java の 1696 行で定義されています。 参照元 org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabaseWorkerThread.run(). { return blobFilter; }

int org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.getCurrentNbOfThreads (   )

Returns the currentNbOfThreads. 戻り値: int VirtualDatabase.java の 1425 行で定義されています。 参照元 org.objectweb.cjdbc.controller.monitoring.datacollector.DataCollector.retrieveVirtualDatabasesData(), と org.objectweb.cjdbc.controller.core.ControllerWorkerThread.run(). { return currentNbOfThreads; }

String org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.getDatabaseName (   )

Gets the virtual database name to be used by the client (C-JDBC driver) This method should be used for local references only (it is faster). For remote RMI calls, use getVirtualDatabaseName(). 戻り値: the virtual database name 参照: VirtualDatabase.getVirtualDatabaseName() VirtualDatabase.java の 1135 行で定義されています。 参照元 org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.equals(), org.objectweb.cjdbc.controller.virtualdatabase.DistributedVirtualDatabase.equals(), org.objectweb.cjdbc.controller.requestmanager.RequestManager.initRequestManagerVariables(), と org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabaseWorkerThread.run(). { return name; }

String org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.getDatabaseProductName (   )

参照: org.objectweb.cjdbc.driver.DatabaseMetaData.getDatabaseProductName() VirtualDatabase.java の 1143 行で定義されています。 参照元 org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabaseWorkerThread.run(). { return databaseProductNames; }

DatabaseSchema org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.getDatabaseSchemaFromActiveBackendsAndRefreshDatabaseProductNames (   )  throws SQLException

Get the current database schema from merging the schemas of all active backends. This is needed when a backend is disabled. 戻り値: the current database schema dynamically gathered 例外: SQLException  if an error occurs VirtualDatabase.java の 1179 行で定義されています。 参照先 org.objectweb.cjdbc.controller.backend.DatabaseBackend.getDatabaseProductName(), org.objectweb.cjdbc.controller.backend.DatabaseBackend.getDatabaseSchema(), org.objectweb.cjdbc.controller.backend.DatabaseBackend.isReadEnabled, と org.objectweb.cjdbc.common.sql.schema.DatabaseSchema.mergeSchema(). 参照元 org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabaseMetaData.getDatabaseSchema(). { try { acquireReadLockBackendLists(); } catch (InterruptedException e) { String msg = "Unable to acquire read lock on backend list in getDatabaseSchemaFromActiveBackends (" + e + ")"; logger.error(msg); throw new SQLException(msg); } // Build the new schema from all active backend's schemas int size = backends.size(); DatabaseSchema schema = null; DatabaseBackend b = null; String dbProductNames = "C-JDBC"; for (int i = 0; i < size; i++) { b = (DatabaseBackend) backends.get(i); if (b.isReadEnabled()) { if (schema == null) schema = b.getDatabaseSchema(); else schema.mergeSchema(b.getDatabaseSchema()); } // Update the list of database product names if (dbProductNames.indexOf(b.getDatabaseProductName()) == -1) dbProductNames += "," + b.getDatabaseProductName(); } releaseReadLockBackendLists(); databaseProductNames = dbProductNames; logger.debug("getDatabaseSchemaFromActiveBackends - end"); return schema; }

String org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.getDistributionXml (   )  [protected]

Get the XML dump of the Distribution element if any. 戻り値: "" org.objectweb.cjdbc.controller.virtualdatabase.DistributedVirtualDatabaseで再定義されています。 VirtualDatabase.java の 1359 行で定義されています。 { return ""; }

int org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.getIdleThreads (   )

Returns the number of idle zorker threads. Warning! This method must be called in a synchronized block on activeThreads. 戻り値: int VirtualDatabase.java の 1601 行で定義されています。 参照元 org.objectweb.cjdbc.controller.core.ControllerWorkerThread.run(). { return idleThreads; }

int org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.getMaxNbOfConnections (   )

Returns the maxNbOfConnections. 戻り値: int VirtualDatabase.java の 1512 行で定義されています。 参照元 org.objectweb.cjdbc.controller.core.ControllerWorkerThread.run(). { return maxNbOfConnections; }

int org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.getMaxNbOfThreads (   )

Returns the maxNbOfThreads. 戻り値: int VirtualDatabase.java の 1522 行で定義されています。 参照元 org.objectweb.cjdbc.controller.core.ControllerWorkerThread.run(). { return maxNbOfThreads; }

long org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.getMaxThreadIdleTime (   )

Returns the maxThreadIdleTime. 戻り値: long VirtualDatabase.java の 1492 行で定義されています。 参照元 org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabaseWorkerThread.run(). { return maxThreadIdleTime; }

VirtualDatabaseMetaData org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.getMetaData (   )

参照: org.objectweb.cjdbc.driver.DatabaseMetaData 戻り値: associated metada for this database VirtualDatabase.java の 1163 行で定義されています。 参照元 org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabaseWorkerThread.run(). { if (metadata == null) { metadata = new VirtualDatabaseMetaData(this); } return metadata; }

int org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.getMinNbOfThreads (   )

Returns the minNbOfThreads. 戻り値: int VirtualDatabase.java の 1452 行で定義されています。 参照元 org.objectweb.cjdbc.controller.core.ControllerWorkerThread.run(). { return minNbOfThreads; }

String org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.getName (   )

Gets the virtual database name to be used by the client (C-JDBC driver) 戻り値: the virtual database name org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabaseMBeanに実装されています. VirtualDatabase.java の 1415 行で定義されています。 参照元 org.objectweb.cjdbc.controller.virtualdatabase.protocol.VirtualDatabaseConfiguration.isCompatible(), org.objectweb.cjdbc.controller.jmx.CjdbcJmxAgent.registerMBean(), org.objectweb.cjdbc.controller.monitoring.datacollector.DataCollector.retrieveVirtualDatabasesData(), org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabaseWorkerThread.run(), org.objectweb.cjdbc.controller.requestmanager.RequestManager.setBackendsLastKnownCheckpointFromRecoveryLog(), org.objectweb.cjdbc.controller.core.shutdown.VirtualDatabaseShutdownThread.terminateClients(), org.objectweb.cjdbc.controller.jmx.CjdbcJmxAgent.unregisterMBean(), org.objectweb.cjdbc.controller.virtualdatabase.protocol.VirtualDatabaseConfiguration.VirtualDatabaseConfiguration(), org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabaseMetaData.VirtualDatabaseMetaData(), org.objectweb.cjdbc.controller.core.shutdown.VirtualDatabaseShutdownThread.VirtualDatabaseShutdownThread(), と org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabaseWorkerThread.VirtualDatabaseWorkerThread(). { return name; }

ArrayList org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.getPendingConnections (   )

Returns the pendingConnections. 戻り値: ArrayList VirtualDatabase.java の 1532 行で定義されています。 参照元 org.objectweb.cjdbc.controller.monitoring.datacollector.DataCollector.retrieveVirtualDatabasesData(), org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabaseWorkerThread.run(), と org.objectweb.cjdbc.controller.core.ControllerWorkerThread.run(). { return pendingConnections; }

RequestManager org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.getRequestManager (   )

Gets the request manager associated to this database. 戻り値: a RequestManager instance VirtualDatabase.java の 1242 行で定義されています。 参照元 org.objectweb.cjdbc.common.monitor.scheduler.AbstractSchedulerDataCollector.collectValue(), org.objectweb.cjdbc.common.monitor.cache.AbstractCacheStatsDataCollector.collectValue(), org.objectweb.cjdbc.controller.core.Controller.isCacheEnableForDatabase(), org.objectweb.cjdbc.controller.virtualdatabase.protocol.VirtualDatabaseConfiguration.isCompatible(), org.objectweb.cjdbc.controller.monitoring.datacollector.DataCollector.retrieveCacheData(), org.objectweb.cjdbc.controller.monitoring.datacollector.DataCollector.retrieveCacheStatsData(), org.objectweb.cjdbc.controller.monitoring.datacollector.DataCollector.retrieveSchedulerData(), org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabaseWorkerThread.run(), org.objectweb.cjdbc.controller.virtualdatabase.protocol.VirtualDatabaseConfiguration.VirtualDatabaseConfiguration(), と org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabaseMetaData.VirtualDatabaseMetaData(). { return requestManager; }

SQLMonitoring org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.getSQLMonitor (   )

Returns the current SQL monitor 戻り値: a SQLMonitoring instance or null if no monitor is defined VirtualDatabase.java の 1273 行で定義されています。 参照元 org.objectweb.cjdbc.controller.monitoring.datacollector.DataCollector.retrieveSQLStats(). { return sqlMonitor; }

int org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.getSQLShortFormLength (   )

Return the sql short form length to use when reporting an error. 戻り値: sql short form length 参照: org.objectweb.cjdbc.common.sql.AbstractRequest.getSQLShortForm(int) VirtualDatabase.java の 1154 行で定義されています。 参照元 org.objectweb.cjdbc.controller.loadbalancer.paralleldb.ParallelDB_RR.chooseBackendForReadRequest(), org.objectweb.cjdbc.controller.loadbalancer.paralleldb.ParallelDB_LPRF.chooseBackendForReadRequest(), org.objectweb.cjdbc.controller.requestmanager.distributed.DistributedRequestManager.completeFailedOnAllBackends(), org.objectweb.cjdbc.controller.requestmanager.distributed.SingleDBDistributedRequestManager.execDistributedWriteRequest(), org.objectweb.cjdbc.controller.requestmanager.distributed.RAIDb2DistributedRequestManager.execDistributedWriteRequest(), org.objectweb.cjdbc.controller.requestmanager.distributed.RAIDb1DistributedRequestManager.execDistributedWriteRequest(), org.objectweb.cjdbc.controller.loadbalancer.singledb.SingleDB.execReadRequest(), org.objectweb.cjdbc.controller.loadbalancer.raidb2.RAIDb2_RR.execReadRequest(), org.objectweb.cjdbc.controller.loadbalancer.raidb2.RAIDb2_LPRF.execReadRequest(), org.objectweb.cjdbc.controller.loadbalancer.raidb0.RAIDb0.execReadRequest(), org.objectweb.cjdbc.controller.loadbalancer.paralleldb.ParallelDB.execReadRequest(), org.objectweb.cjdbc.controller.loadbalancer.raidb1.RAIDb1_LPRF.executeLPRF(), org.objectweb.cjdbc.controller.loadbalancer.raidb1.RAIDb1_RR.executeRoundRobinRequest(), org.objectweb.cjdbc.controller.loadbalancer.raidb1.RAIDb1_WRR.executeWRR(), と org.objectweb.cjdbc.controller.loadbalancer.raidb2.RAIDb2.execWriteRequest(). { return sqlShortFormLength; }

String org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.getVirtualDatabaseName (   )

Gets the virtual database name to be used by the client (C-JDBC driver) 戻り値: the virtual database name VirtualDatabase.java の 1262 行で定義されています。 { return name; }

String org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.getXml (   )

Retrieves this VirtualDatabase object in xml format 戻り値: xml formatted string that conforms to c-jdbc.dtd VirtualDatabase.java の 1310 行で定義されています。 参照元 org.objectweb.cjdbc.controller.core.Controller.viewDatabaseXml(). { StringBuffer info = new StringBuffer(); info.append("<" + DatabasesXmlTags.ELT_VirtualDatabase + " " + DatabasesXmlTags.ATT_name + "=\"" + this.getName() + "\" " + DatabasesXmlTags.ATT_maxNbOfConnections + "=\"" + this.getMaxNbOfConnections() + "\" " + DatabasesXmlTags.ATT_poolThreads + "=\"" + this.isPoolConnectionThreads() + "\" " + DatabasesXmlTags.ATT_minNbOfThreads + "=\"" + this.getMinNbOfThreads() + "\" " + DatabasesXmlTags.ATT_maxNbOfThreads + "=\"" + this.getMaxNbOfThreads() + "\" " + DatabasesXmlTags.ATT_maxThreadIdleTime + "=\"" + this.getMaxThreadIdleTime() / 1000 + DatabasesXmlTags.ATT_sqlDumpLength + "=\"" + this.sqlShortFormLength + "\" " + DatabasesXmlTags.ATT_blobEncodingMethod + "=\"" + this.blobFilter.getXml() + "\">"); info.append(getDistributionXml()); if (this.getSQLMonitor() != null) info.append(sqlMonitor.getXml()); if (this.getAuthenticationManager() != null) info.append(authenticationManager.getXml()); try { acquireReadLockBackendLists(); int size = backends.size(); for (int i = 0; i < size; i++) info.append(((DatabaseBackend) backends.get(i)).getXml()); releaseReadLockBackendLists(); } catch (InterruptedException e) { logger.error(Translate.get("virtualdatabase.fail.read.lock", e)); } if (requestManager != null) info.append(requestManager.getXml()); info.append("</" + DatabasesXmlTags.ELT_VirtualDatabase + ">"); return info.toString(); }

boolean org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.hasRecoveryLog (   )

参照: org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabaseMBean.hasRecoveryLog() org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabaseMBeanに実装されています. VirtualDatabase.java の 1747 行で定義されています。 { AbstractRecoveryLog log = requestManager.getRecoveryLog(); if (log == null) return false; else return true; }

boolean org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.isDistributed (   )

Is this virtual database distributed ? 戻り値: false org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabaseMBeanに実装されています. org.objectweb.cjdbc.controller.virtualdatabase.DistributedVirtualDatabaseで再定義されています。 VirtualDatabase.java の 202 行で定義されています。 参照元 org.objectweb.cjdbc.controller.core.Controller.isDistributedVirtualDatabase(). { return false; }

boolean org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.isPoolConnectionThreads (   )

Returns the poolConnectionThreads. 戻り値: boolean VirtualDatabase.java の 1462 行で定義されています。 { return poolConnectionThreads; }

final void org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.releaseReadLockBackendLists (   )

Releases the read lock on the backend lists (both enabled and disabled backends). This should be called after traversing the backend ArrayList. VirtualDatabase.java の 1060 行で定義されています。 参照元 org.objectweb.cjdbc.controller.loadbalancer.AbstractLoadBalancer.AbstractLoadBalancer(), org.objectweb.cjdbc.controller.virtualdatabase.DistributedVirtualDatabase.isCompatibleBackend(), と org.objectweb.cjdbc.controller.monitoring.datacollector.DataCollector.retrieveBackendsData(). { rwLock.releaseRead(); }

void org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.removeBackend (  DatabaseBackend  db  )  throws VirtualDatabaseException

Remove a backend from this virtual database. 引数: db  the database backend to remove 例外: VirtualDatabaseException  if an error occurs VirtualDatabase.java の 687 行で定義されています。 { if (db == null) { String msg = "Illegal null database backend in removeBackend(DatabaseBackend) method"; logger.error(msg); throw new VirtualDatabaseException(msg); } try { rwLock.acquireWrite(); } catch (InterruptedException e) { String msg = Translate.get( "loadbalancer.backendlist.acquire.writelock.failed", e); logger.error(msg); throw new VirtualDatabaseException(msg); } // Sanity checks int idx = backends.indexOf(db); if (idx == -1) { rwLock.releaseWrite(); // Release the lock String msg = "Trying to remove a non-existing backend " + db.getName(); logger.warn(msg); throw new VirtualDatabaseException(msg); } if (((DatabaseBackend) backends.get(idx)).isReadEnabled()) { rwLock.releaseWrite(); // Release the lock String msg = "Trying to remove an enabled backend " + db.getName(); logger.error(msg); throw new VirtualDatabaseException(msg); } // Remove it backends.remove(idx); rwLock.releaseWrite(); // Relase the lock if (logger.isDebugEnabled()) logger.debug("Backend " + db.getName() + " removed successfully"); }

void org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.removeCheckpoint (  String  checkpointName  )  throws VirtualDatabaseException

Remove a checkpoint from the recovery log of this virtual database 引数: checkpointName  to remove 例外: VirtualDatabaseException  if an error occurs org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabaseMBeanに実装されています. VirtualDatabase.java の 668 行で定義されています。 { try { requestManager.removeCheckpoint(checkpointName); } catch (Exception e) { throw new VirtualDatabaseException(e.getMessage()); } }

void org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.removeCurrentNbOfThread (   )

Substract one to currentNbOfThreads. Warning! This method is not synchronized. VirtualDatabase.java の 1442 行で定義されています。 参照元 org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabaseWorkerThread.run(). { currentNbOfThreads--; }

void org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.removeIdleThread (   )

Remove an idle thread. Warning! This method must be called in a synchronized block on activeThreads. VirtualDatabase.java の 1590 行で定義されています。 参照元 org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabaseWorkerThread.run(). { idleThreads--; }

void org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.restoreBackendFromBackupCheckpoint (  String  databaseBackendName, String  checkpointName )  throws VirtualDatabaseException, BackupException, OctopusException

参照: org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabaseMBean.restoreBackendFromBackupCheckpoint(java.lang.String, java.lang.String) org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabaseMBeanに実装されています. VirtualDatabase.java の 1725 行で定義されています。 { DatabaseBackend backend = getAndCheckBackend(databaseBackendName, NO_CHECK_BACKEND); // Backend cannot be null, otherwise the above throws an // VirtualDatabaseException requestManager.restoreBackendFromBackupCheckpoint(backend, checkpointName); }

void org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.rollback (  long  transactionId  )  throws SQLException

Rollbacks a transaction given its id. 引数: transactionId  the transaction id 例外: SQLException  if an error occurs VirtualDatabase.java の 538 行で定義されています。 参照元 org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabaseWorkerThread.run(). { try { if (requestLogger.isInfoEnabled()) requestLogger.info("R " + transactionId); requestManager.rollback(transactionId); } catch (SQLException e) { String msg = "Rollback of transaction '" + transactionId + "' failed (" + e.getMessage() + ")"; logger.warn(msg); throw e; } }

void org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.setAuthenticationManager (  AuthenticationManager  authenticationManager  )

Sets the authentication manager for this virtual database. 引数: authenticationManager  the AuthenticationManager to set VirtualDatabase.java の 1083 行で定義されています。 { this.authenticationManager = authenticationManager; }

void org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.setBlobFilter (  AbstractBlobFilter  filter  )

Sets the blob encoder 引数: filter  blob encode VirtualDatabase.java の 1686 行で定義されています。 { this.blobFilter = filter; }

void org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.setDatabaseSchema (  DatabaseSchema  schema, boolean  isStatic )

Sets a new database schema for this database if no one exist or merge the given schema to the existing one. A static schema can only be replaced by another static schema. 引数: schema  the new database shema isStatic  true if the schema should be static VirtualDatabase.java の 1228 行で定義されています。 { if (requestManager != null) requestManager.setDatabaseSchema(schema, isStatic); else logger .warn("Unable to set database schema, no request manager has been defined."); }

void org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.setMaxNbOfConnections (  int  maxNbOfConnections  )

Sets the maxNbOfConnections. 引数: maxNbOfConnections  The maxNbOfConnections to set VirtualDatabase.java の 1542 行で定義されています。 { this.maxNbOfConnections = maxNbOfConnections; }

void org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.setMaxNbOfThreads (  int  maxNbOfThreads  )

Sets the maxNbOfThreads. 引数: maxNbOfThreads  The maxNbOfThreads to set VirtualDatabase.java の 1552 行で定義されています。 { this.maxNbOfThreads = maxNbOfThreads; }

void org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.setMaxThreadIdleTime (  long  maxThreadIdleTime  )

Sets the maxThreadIdleTime. 引数: maxThreadIdleTime  The maxThreadIdleTime to set VirtualDatabase.java の 1502 行で定義されています。 { this.maxThreadIdleTime = maxThreadIdleTime; }

void org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.setMinNbOfThreads (  int  minNbOfThreads  )

Sets the minNbOfThreads. 引数: minNbOfThreads  The minNbOfThreads to set VirtualDatabase.java の 1472 行で定義されています。 { this.minNbOfThreads = minNbOfThreads; }

void org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.setPoolConnectionThreads (  boolean  poolConnectionThreads  )

Sets the poolConnectionThreads. 引数: poolConnectionThreads  The poolConnectionThreads to set VirtualDatabase.java の 1482 行で定義されています。 { this.poolConnectionThreads = poolConnectionThreads; }

void org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.setRequestManager (  RequestManager  requestManager  )

Sets a new request manager for this database. 引数: requestManager  the new request manager. org.objectweb.cjdbc.controller.virtualdatabase.DistributedVirtualDatabaseで再定義されています。 VirtualDatabase.java の 1252 行で定義されています。 { this.requestManager = requestManager; }

void org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.setSQLMonitor (  SQLMonitoring  sqlMonitor  )

Sets a new SQL Monitor 引数: sqlMonitor  the new SQL monitor VirtualDatabase.java の 1283 行で定義されています。 { this.sqlMonitor = sqlMonitor; }

void org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.shutdown (   )  throws VirtualDatabaseException

Shutdown this virtual database in fast mode, disconnect clients 例外: VirtualDatabaseException  if fails org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabaseMBeanに実装されています. VirtualDatabase.java の 1674 行で定義されています。 参照先 org.objectweb.cjdbc.controller.core.shutdown.ShutdownThread.run(). { VirtualDatabaseShutdownThread shutdown = new VirtualDatabaseShutdownThread( this, ControllerConstants.CONTROLLER_SHUTDOWN_FAST); shutdown.run(); }

synchronized void org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.shutdown (  int  level  )

Shutdown this virtual database. Finish all threads and stop connection to backends 引数: level  Smart or Fast VirtualDatabase.java の 1662 行で定義されています。 参照先 org.objectweb.cjdbc.controller.core.shutdown.ShutdownThread.run(). 参照元 org.objectweb.cjdbc.controller.core.Controller.shutdownDatabase(). { VirtualDatabaseShutdownThread vdst = new VirtualDatabaseShutdownThread( this, level); vdst.run(); }

void org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.storeBackendsCheckpoint (   )

Write the checkpoints for all backends on the recovery log VirtualDatabase.java の 1739 行で定義されています。 { requestManager.storeBackendsCheckpoint(this.name, getBackends()); }

ArrayList org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.viewAllBackendNames (   )  throws VirtualDatabaseException

参照: org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabaseMBean.viewAllBackendNames() org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabaseMBeanに実装されています. VirtualDatabase.java の 1609 行で定義されています。 参照元 org.objectweb.cjdbc.controller.core.Controller.listBackends(). { return this.getAllBackendNames(); }

ArrayList org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.viewAllClientNames (   )

Get all users connected to that database 戻り値: an ArrayList of strings containing the clients username VirtualDatabase.java の 1620 行で定義されています。 参照元 org.objectweb.cjdbc.controller.core.Controller.listDatabaseClients(). { ArrayList list = this.getActiveThreads(); int size = list.size(); ArrayList clients = new ArrayList(size); for (int i = 0; i < list.size(); i++) clients.add(((VirtualDatabaseWorkerThread) list.get(i)).getUser()); return clients; }

String [] org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.viewBackendInformation (  String  backendName  )  throws VirtualDatabaseException

参照: org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabaseMBean.viewBackendInformation(java.lang.String) org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabaseMBeanに実装されています. VirtualDatabase.java の 1570 行で定義されています。 参照先 org.objectweb.cjdbc.controller.backend.DatabaseBackend.getBackendData(). { DatabaseBackend backend = getAndCheckBackend(backendName, NO_CHECK_BACKEND); return backend.getBackendData(); }

ArrayList org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.viewCheckpointNames (   )

参照: org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabaseMBean.viewCheckpointNames() org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabaseMBeanに実装されています. VirtualDatabase.java の 737 行で定義されています。 参照先 org.objectweb.cjdbc.controller.recoverylog.AbstractRecoveryLog.getCheckpointNames(). { try { AbstractRecoveryLog recoveryLog = requestManager.getRecoveryLog(); return recoveryLog.getCheckpointNames(); } catch (SQLException e) { return new ArrayList(); } }

String org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.viewOwningController (   )

参照: org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabaseMBean.viewOwningController() org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabaseMBeanに実装されています. VirtualDatabase.java の 1716 行で定義されています。 { return controllerName; }

---

変数

ArrayList org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.activeThreads = new ArrayList() [private]

VirtualDatabase.java の 107 行で定義されています。

AuthenticationManager org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.authenticationManager [protected]

Authentification manager matching virtual database login/password to backends login/password VirtualDatabase.java の 91 行で定義されています。 参照元 org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.checkAdminAuthentication(), と org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.checkUserAuthentication().

ArrayList org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.backends [protected]

ArrayList of DatabaseBackend objects VirtualDatabase.java の 94 行で定義されています。

AbstractBlobFilter org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.blobFilter [private]

The filter used to store blobs in the database VirtualDatabase.java の 150 行で定義されています。

final int org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.CHECK_BACKEND_DISABLE = 0 [static]

Use for method getAndCheck VirtualDatabase.java の 142 行で定義されています。

final int org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.CHECK_BACKEND_ENABLE = 1 [static]

Use for method getAndCheck VirtualDatabase.java の 140 行で定義されています。

String org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.controllerName [package]

The controller we belong to VirtualDatabase.java の 153 行で定義されています。

int org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.currentNbOfThreads [protected]

Current number of worker threads VirtualDatabase.java の 132 行で定義されています。 参照元 org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabaseWorkerThread.run().

String org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.databaseProductNames = "C-JDBC" [private]

Comma separated list of database product names (one instance per name) VirtualDatabase.java の 155 行で定義されています。

int org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.idleThreads = 0 [private]

VirtualDatabase.java の 109 行で定義されています。

Trace org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.logger = null

Virtual database logger VirtualDatabase.java の 103 行で定義されています。 参照元 org.objectweb.cjdbc.controller.requestmanager.distributed.DistributedRequestManager.enableBackend(), org.objectweb.cjdbc.controller.virtualdatabase.protocol.VirtualDatabaseConfiguration.isCompatible(), と org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabaseWorkerThread.VirtualDatabaseWorkerThread().

int org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.maxNbOfConnections [protected]

Maximum number of concurrent accepted for this virtual database VirtualDatabase.java の 114 行で定義されています。

int org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.maxNbOfThreads [protected]

Maximum number of worker threads to fork VirtualDatabase.java の 129 行で定義されています。

long org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.maxThreadIdleTime [protected]

Maximum time a worker thread can remain idle before dying VirtualDatabase.java の 120 行で定義されています。

VirtualDatabaseMetaData org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.metadata [protected]

Virtual Database MetaData VirtualDatabase.java の 135 行で定義されています。

int org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.minNbOfThreads [protected]

Minimum number of worker threads to keep in the pool if poolConnectionThreads is true VirtualDatabase.java の 126 行で定義されています。 参照元 org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabaseWorkerThread.run().

String org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.name [protected]

Virtual database name VirtualDatabase.java の 85 行で定義されています。

final int org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.NO_CHECK_BACKEND = -1 [static]

Use for method getAndCheck VirtualDatabase.java の 144 行で定義されています。

ArrayList org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.pendingConnections = new ArrayList() [private]

VirtualDatabase.java の 111 行で定義されています。

boolean org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.poolConnectionThreads [protected]

If false one worker thread is forked per connection else VirtualDatabase.java の 117 行で定義されています。 参照元 org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabaseWorkerThread.run().

Trace org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.requestLogger = null [protected]

VirtualDatabase.java の 104 行で定義されています。 参照元 org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.execReadRequest(), org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.execReadStoredProcedure(), org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.execWriteRequest(), org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.execWriteRequestWithKeys(), と org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.VirtualDatabase().

RequestManager org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.requestManager [protected]

The request manager to use for this database VirtualDatabase.java の 100 行で定義されています。

ReadPrioritaryFIFOWriteLock org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.rwLock [protected]

Read/Write lock for backend list VirtualDatabase.java の 97 行で定義されています。 参照元 org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.VirtualDatabase().

SQLMonitoring org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.sqlMonitor = null [private]

VirtualDatabase.java の 137 行で定義されています。 参照元 org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.execReadRequest(), org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.execReadStoredProcedure(), org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.execWriteRequest(), と org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.execWriteRequestWithKeys().

int org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.sqlShortFormLength [private]

Short form of SQL statements to include in traces and exceptions VirtualDatabase.java の 147 行で定義されています。

---

このクラスの説明は次のファイルから生成されました:

• VirtualDatabase.java

---