org.objectweb.cjdbc.controller.backend.DatabaseBackend Class Reference

Collaboration diagram for org.objectweb.cjdbc.controller.backend.DatabaseBackend:

[legend]List of all members.

Public Member Functions
	DatabaseBackend (String name, String driverPath, String driverClassName, String url, String vdbName, boolean writeCanBeEnabled, String connectionTestStatement) throws NotCompliantMBeanException
	DatabaseBackend (BackendInfo info) throws NotCompliantMBeanException
	DatabaseBackend (String name, String driverPath, String driverClassName, String url, String vdbName, String connectionTestStatement, String dynamicSchemaLevel) throws NotCompliantMBeanException
void	setSqlShortFormLength (int sqlShortFormLength)
int	getSQLShortFormLength ()
boolean	equals (Object other)
boolean	hasTables (ArrayList tables)
boolean	hasTable (String table)
ArrayList	getTables ()
boolean	hasStoredProcedure (String procedureName)
synchronized void	initializeConnections () throws SQLException
synchronized void	finalizeConnections () throws SQLException
boolean	isValidConnection (Connection connection)
void	addConnectionManager (String vLogin, AbstractConnectionManager connectionManager)
synchronized Connection	getConnectionForTransactionAndLazyBeginIfNeeded (Long tid, AbstractConnectionManager cm) throws UnreachableBackendException, NoTransactionStartWhenDisablingException, SQLException
void	startTransaction (Long tid)
void	stopTransaction (Long tid)
void	waitForAllTransactionsToComplete ()
boolean	isStartedTransaction (Long tid)
synchronized boolean	isInitialized () throws SQLException
synchronized boolean	isJDBCConnected ()
synchronized boolean	isReadEnabled ()
synchronized boolean	isWriteEnabled ()
boolean	isRecovering ()
boolean	isDisabling ()
boolean	isDisabled ()
boolean	isKilled ()
String	getState ()
int	getStateValue ()
synchronized void	enableRead ()
synchronized void	disableRead ()
synchronized void	disableWrite ()
synchronized void	enableWrite ()
void	setDisabling ()
synchronized void	disable ()
AbstractConnectionManager	getConnectionManager (String vLogin)
HashMap	getConnectionManagers ()
String	getConnectionTestStatement ()
String	getDriverPath ()
String	getAssociatedString ()
String	getDriverClassName ()
String	getName ()
String	getVirtualDatabaseName ()
Vector	getPendingRequests ()
ArrayList	getPendingRequestsDescription (int count, boolean fromFirst, boolean clone)
void	addPendingReadRequest (Object request)
void	addPendingWriteRequest (Object request)
boolean	removePendingRequest (Object request)
DatabaseSchema	getDatabaseSchema ()
void	setDatabaseSchema (DatabaseSchema databaseSchema, boolean isStatic)
void	refreshSchema ()
MetadataContainer	getDatabaseStaticMetadata ()
boolean	checkDatabaseSchema ()
DriverCompliance	getDriverCompliance ()
void	checkDriverCompliance () throws SQLException
String	getURL ()
void	addRewritingRule (AbstractRewritingRule rule)
String	rewriteQuery (String sqlQuery)
String	getXml ()
String	getSchemaXml (boolean expandSchema)
ArrayList	getActiveTransactions ()
boolean	isSchemaStatic ()
String[]	getBackendData ()
long	getTotalActiveConnections ()
int	getDynamicPrecision ()
void	setDynamicPrecision (int dynamicPrecision, boolean gatherSystemTables, String schemaName)
int	getTotalTransactions ()
int	getTotalReadRequest ()
int	getTotalWriteRequest ()
int	getTotalRequest ()
void	setLastKnownCheckpoint (String checkpoint)
String	getLastKnownCheckpoint ()
String	getDatabaseProductName ()
ArrayList	getRewritingRules ()
void	setRewritingRules (ArrayList rewritingRules)
DatabaseBackend	copy (String newName, Map parameters) throws Exception
boolean	isBackuping ()
synchronized void	setState (int state)
void	notifyStateChange ()
void	notifyJmx (String type)
void	notifyJmxError (String type, Exception e)
boolean	isWriteCanBeEnabled ()
void	setStateListener (BackendStateListener stateListener)
String	toString ()
Protected Attributes
transient Trace	logger

---

Detailed Description

A DatabaseBackend represents a real database backend that will have to be bound to a virtual C-JDBC database. All connections opened will use the same url but possibly different login/password.

Author:

Emmanuel Cecchet

Mathieu Peltier

Sara Bouchenak

Nicolas Modrzyk

Version:

1.0

Definition at line 80 of file DatabaseBackend.java.

---

Constructor & Destructor Documentation

org.objectweb.cjdbc.controller.backend.DatabaseBackend.DatabaseBackend (  String  name, String  driverPath, String  driverClassName, String  url, String  vdbName, boolean  writeCanBeEnabled, String  connectionTestStatement )  throws NotCompliantMBeanException

Creates a new DatabaseBackend instance. Parameters: name  logical name assigned to this backend driverPath  path for driver driverClassName  class name of the database native JDBC driver to load url  URL to access the database vdbName  Name of the virtual database this backend is attached to writeCanBeEnabled  if writes can be enabled on this backend connectionTestStatement  SQL statement used to check if a connection is still valid Exceptions: NotCompliantMBeanException  if the mbean can not be created (unless we refactor the code this cannot happend) Definition at line 182 of file DatabaseBackend.java. References org.objectweb.cjdbc.controller.backend.DatabaseBackend.logger. { super(DatabaseBackendMBean.class); if (name == null) throw new IllegalArgumentException(Translate .get("backend.null.backend.name")); if (driverClassName == null) throw new IllegalArgumentException(Translate.get("backend.null.driver")); if (url == null) throw new IllegalArgumentException(Translate.get("backend.null.url")); if (vdbName == null) throw new IllegalArgumentException(Translate .get("backend.null.virtualdatabase.name")); if (connectionTestStatement == null) throw new IllegalArgumentException(Translate .get("backend.null.connection.test")); this.name = name; this.writeCanBeEnabled = writeCanBeEnabled; this.driverPath = driverPath; this.driverClassName = driverClassName; this.url = url; this.virtualDatabaseName = vdbName; this.connectionTestStatement = connectionTestStatement; this.connectionManagers = new HashMap(); logger = Trace .getLogger("org.objectweb.cjdbc.controller.backend.DatabaseBackend." + name); this.driverCompliance = new DriverCompliance(logger); totalRequest = 0; dynamicPrecision = DatabaseBackendSchemaConstants.DynamicPrecisionAll; }

org.objectweb.cjdbc.controller.backend.DatabaseBackend.DatabaseBackend (  BackendInfo  info  )  throws NotCompliantMBeanException

Creates a new DatabaseBackend object Parameters: info  a backend info object to create a database backend object from Exceptions: NotCompliantMBeanException  if mbean is not compliant (unless we refactor the code this cannot happend) Definition at line 229 of file DatabaseBackend.java. References org.objectweb.cjdbc.controller.backend.DatabaseBackend.logger. { this(info.getName(), info.getDriverPath(), info.getDriverClassName(), info .getUrl(), info.getVirtualDatabaseName(), true, info .getConnectionTestStatement()); try { String xml = info.getXml(); StringReader sreader = new StringReader(xml); SAXReader reader = new SAXReader(); Document document = reader.read(sreader); Element root = document.getRootElement(); Iterator iter1 = root.elementIterator(); while (iter1.hasNext()) { Element elem = (Element) iter1.next(); if (elem.getName().equals(DatabasesXmlTags.ELT_ConnectionManager)) { String vuser = elem.valueOf("@" + DatabasesXmlTags.ATT_vLogin); String rlogin = elem.valueOf("@" + DatabasesXmlTags.ATT_rLogin); String rpassword = elem.valueOf("@" + DatabasesXmlTags.ATT_rPassword); Iterator iter2 = elem.elementIterator(); while (iter2.hasNext()) { Element connectionManager = (Element) iter2.next(); String cname = connectionManager.getName(); if (cname .equals(DatabasesXmlTags.ELT_VariablePoolConnectionManager)) { int minPoolSize = Integer.parseInt(connectionManager.valueOf("@" + DatabasesXmlTags.ATT_minPoolSize)); int maxPoolSize = Integer.parseInt(connectionManager.valueOf("@" + DatabasesXmlTags.ATT_maxPoolSize)); int idleTimeout = Integer.parseInt(connectionManager.valueOf("@" + DatabasesXmlTags.ATT_idleTimeout)); int waitTimeout = Integer.parseInt(connectionManager.valueOf("@" + DatabasesXmlTags.ATT_waitTimeout)); this.addConnectionManager(vuser, new VariablePoolConnectionManager(url, name, rlogin, rpassword, driverPath, driverClassName, minPoolSize, maxPoolSize, idleTimeout, waitTimeout)); } else if (cname.equals(DatabasesXmlTags.ELT_SimpleConnectionManager)) { this.addConnectionManager(vuser, new SimpleConnectionManager(url, name, rlogin, rpassword, driverPath, driverClassName)); } else if (cname .equals(DatabasesXmlTags.ELT_RandomWaitPoolConnectionManager)) { int poolSize = Integer.parseInt(connectionManager.valueOf("@" + DatabasesXmlTags.ATT_poolSize)); int timeout = Integer.parseInt(connectionManager.valueOf("@" + DatabasesXmlTags.ATT_timeout)); this .addConnectionManager(vuser, new RandomWaitPoolConnectionManager(url, name, rlogin, rpassword, driverPath, driverClassName, poolSize, timeout)); } else if (cname .equals(DatabasesXmlTags.ELT_FailFastPoolConnectionManager)) { int poolSize = Integer.parseInt(connectionManager.valueOf("@" + DatabasesXmlTags.ATT_poolSize)); this.addConnectionManager(vuser, new FailFastPoolConnectionManager(url, name, rlogin, rpassword, driverPath, driverClassName, poolSize)); } } } } } catch (Exception e) { logger .error(Translate.get("backend.add.connection.manager.failed", e), e); } }

org.objectweb.cjdbc.controller.backend.DatabaseBackend.DatabaseBackend (  String  name, String  driverPath, String  driverClassName, String  url, String  vdbName, String  connectionTestStatement, String  dynamicSchemaLevel )  throws NotCompliantMBeanException

Additionnal constructor for setting a different dynamic schema level. Default was to gather all information Creates a new DatabaseBackend instance. Parameters: name  logical name assigned to this backend driverPath  path for driver driverClassName  class name of the database native JDBC driver to load url  URL to access the database vdbName  Name of the virtual database this backend is attached to connectionTestStatement  SQL statement used to check if a connection is still valid dynamicSchemaLevel  for dynamically gathering schema from backend Exceptions: NotCompliantMBeanException  (unless we refactor the code this cannot happend) Definition at line 327 of file DatabaseBackend.java. { this(name, driverPath, driverClassName, url, vdbName, true, connectionTestStatement); this.dynamicPrecision = DatabaseBackendSchemaConstants .getDynamicSchemaLevel(dynamicSchemaLevel); }

---

Member Function Documentation

void org.objectweb.cjdbc.controller.backend.DatabaseBackend.addConnectionManager (  String  vLogin, AbstractConnectionManager  connectionManager )

Adds a ConnectionManager to this backend. Note that the ConnectionManager is not initialized in this method. Parameters: vLogin  the virtual login corresponding to this connection manager connectionManager  the ConnectionManager to add Definition at line 546 of file DatabaseBackend.java. Referenced by org.objectweb.cjdbc.controller.backend.DatabaseBackend.copy(). { if (connectionManager == null) throw new IllegalArgumentException(Translate.get( "backend.null.connection.manager", new String[]{name, url})); if (logger.isInfoEnabled()) logger.info(Translate.get("backend.add.connection.manager.for.user", vLogin)); connectionManager.setVLogin(vLogin); connectionManagers.put(vLogin, connectionManager); }

void org.objectweb.cjdbc.controller.backend.DatabaseBackend.addPendingReadRequest (  Object  request  )

Adds a pending request (or task) to this backend. Note that the underlying vector is synchronized. Parameters: request  the request to add Definition at line 1036 of file DatabaseBackend.java. { synchronized (this) { totalRequest++; totalReadRequest++; } pendingRequests.add(request); }

void org.objectweb.cjdbc.controller.backend.DatabaseBackend.addPendingWriteRequest (  Object  request  )

Adds a pending request (or task) to this backend. Note that the underlying vector is synchronized. Parameters: request  the request to add Definition at line 1052 of file DatabaseBackend.java. { synchronized (this) { totalRequest++; totalWriteRequest++; } pendingRequests.add(request); }

void org.objectweb.cjdbc.controller.backend.DatabaseBackend.addRewritingRule (  AbstractRewritingRule  rule  )

Add a AbstractRewritingRule at the end of the rule list. Parameters: rule  a AbstractRewritingRule Definition at line 1269 of file DatabaseBackend.java. References org.objectweb.cjdbc.controller.backend.rewriting.AbstractRewritingRule.getQueryPattern(), and org.objectweb.cjdbc.controller.backend.rewriting.AbstractRewritingRule.getRewrite(). { if (rewritingRules == null) rewritingRules = new ArrayList(); if (logger.isDebugEnabled()) logger.debug(Translate.get("backend.rewriting.rule.add", new String[]{ rule.getQueryPattern(), rule.getRewrite()})); rewritingRules.add(rule); }

boolean org.objectweb.cjdbc.controller.backend.DatabaseBackend.checkDatabaseSchema (   )

See also: DatabaseBackendMBean#checkDatabaseSchema() Definition at line 1149 of file DatabaseBackend.java. References org.objectweb.cjdbc.controller.backend.DatabaseBackendMetaData.getDatabaseSchema(), and org.objectweb.cjdbc.controller.connection.AbstractConnectionManager.getLogin(). Referenced by org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.getAndCheckBackend(). { if (logger.isDebugEnabled()) logger.debug(Translate.get("backend.dynamic.schema", DatabaseBackendSchemaConstants .getDynamicSchemaLevel(dynamicPrecision))); boolean checked = true; AbstractConnectionManager connectionMananger; Iterator iter = connectionManagers.values().iterator(); while (iter.hasNext()) { connectionMananger = (AbstractConnectionManager) iter.next(); // Gather the database schema from this connection manager DatabaseBackendMetaData meta = new DatabaseBackendMetaData( connectionMananger, logger, dynamicPrecision, gatherSystemTables, schemaName); DatabaseSchema metaSchema; try { if (logger.isInfoEnabled()) logger.info(Translate.get("backend.gathering.database.schema")); metaSchema = meta.getDatabaseSchema(); } catch (SQLException e) { if (logger.isWarnEnabled()) logger.warn(Translate.get("backend.gather.schema.failed", e)); return false; } if (schema == null) { if (logger.isDebugEnabled()) logger.debug(Translate.get("backend.use.gathered.schema.as.new")); schema = metaSchema; } else { if (dynamicPrecision == DatabaseBackendSchemaConstants.DynamicPrecisionStatic) { if (logger.isInfoEnabled()) logger.info(Translate.get("backend.schema.static.no.check", name)); } else { if (logger.isInfoEnabled()) logger.info(Translate.get("backend.check.schema.compatibility")); if (schema.isCompatibleSubset(metaSchema)) logger.info(Translate.get("backend.schema.compatible.for.login", connectionMananger.getLogin())); else { checked = false; logger.warn(Translate.get( "backend.schema.not.compatible.for.login", connectionMananger .getLogin())); } } } } return checked; }

void org.objectweb.cjdbc.controller.backend.DatabaseBackend.checkDriverCompliance (   )  throws SQLException

Check if the driver used by this backend is compliant with C-JDBC needs. Exceptions: SQLException  if the driver is not compliant Definition at line 1226 of file DatabaseBackend.java. Referenced by org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.getAndCheckBackend(). { if (connectionManagers.isEmpty()) throw new SQLException(Translate.get("backend.null.connection.manager", new String[]{name, url})); AbstractConnectionManager connectionManager; Iterator iter = connectionManagers.values().iterator(); connectionManager = (AbstractConnectionManager) iter.next(); try { if (!driverCompliance.complianceTest(url, connectionManager.getLogin(), connectionManager.getPassword(), connectionManager.getDriverPath(), connectionManager.getDriverClassName(), connectionTestStatement)) throw new SQLException(Translate.get("backend.driver.not.compliant", driverClassName)); } catch (ConnectException e) { throw new SQLException(Translate.get("backend.cannot.connect.to", e)); } }

DatabaseBackend org.objectweb.cjdbc.controller.backend.DatabaseBackend.copy (  String  newName, Map  parameters )  throws Exception

Returns a deeply copied clone of this backend Will use the same rewriting rules and will get new instance of connection managers with the same configuration Parameters: newName  the new name for this new backend parameters  a set of parameters to use to replace values from the copied backend. The different parameters are: driverPath: the path to the driver driver: the driver class name url: the url to connect to the database connectionTestStatement: the query to test the connection Returns: DatabaseBackend instance Exceptions: Exception  if cannot proceed the copy Definition at line 1593 of file DatabaseBackend.java. References org.objectweb.cjdbc.controller.backend.DatabaseBackend.addConnectionManager(), org.objectweb.cjdbc.controller.connection.AbstractConnectionManager.copy(), org.objectweb.cjdbc.controller.backend.DatabaseBackend.getConnectionManagers(), org.objectweb.cjdbc.controller.connection.AbstractConnectionManager.getDriverClassName(), org.objectweb.cjdbc.controller.connection.AbstractConnectionManager.getDriverPath(), and org.objectweb.cjdbc.controller.backend.DatabaseBackend.setRewritingRules(). Referenced by org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.replicateBackend(). { // Get the parameters from the backend if they are not specified, or take // them from the map of parameters otherwise. String driverPath = parameters.containsKey(DatabasesXmlTags.ATT_driverPath) ? (String) parameters.get(DatabasesXmlTags.ATT_driverPath) : this.getDriverPath(); String driverClassName = parameters .containsKey(DatabasesXmlTags.ATT_driver) ? (String) parameters .get(DatabasesXmlTags.ATT_driver) : this.getDriverClassName(); String url = parameters.containsKey(DatabasesXmlTags.ATT_url) ? (String) parameters.get(DatabasesXmlTags.ATT_url) : this.getURL(); String connectionTestStatement = parameters .containsKey(DatabasesXmlTags.ATT_connectionTestStatement) ? (String) parameters.get(DatabasesXmlTags.ATT_connectionTestStatement) : this.getConnectionTestStatement(); // Create the new backend object DatabaseBackend newBackend = new DatabaseBackend(newName, driverPath, driverClassName, url, virtualDatabaseName, writeCanBeEnabled, connectionTestStatement); // Set the rewriting rules and the connection managers as the backend we // are copying newBackend.setRewritingRules(this.getRewritingRules()); // Set Connection managers HashMap connectionManagers = this.getConnectionManagers(); Iterator iter = connectionManagers.keySet().iterator(); String vlogin = null; AbstractConnectionManager connectionManager; while (iter.hasNext()) { vlogin = (String) iter.next(); connectionManager = (AbstractConnectionManager) connectionManagers .get(vlogin); newBackend.addConnectionManager(vlogin, connectionManager.copy(url, newName)); } return newBackend; }

synchronized void org.objectweb.cjdbc.controller.backend.DatabaseBackend.disable (   )

Sets the database backend state to disable. This state is just an indication and it has no semantic effect. It is up to the request manager (especially the load balancer) to ensure that no more requests are sent to this backend. Definition at line 904 of file DatabaseBackend.java. Referenced by org.objectweb.cjdbc.controller.loadbalancer.AbstractLoadBalancer.AbstractLoadBalancer(), and org.objectweb.cjdbc.controller.loadbalancer.paralleldb.ParallelDB.disableBackend(). { setState(BackendState.DISABLED); }

synchronized void org.objectweb.cjdbc.controller.backend.DatabaseBackend.disableRead (   )

See also: org.objectweb.cjdbc.common.jmx.mbeans.DatabaseBackendMBean.disableRead() Definition at line 850 of file DatabaseBackend.java. { if (isWriteEnabled()) setState(BackendState.READ_DISABLED_WRITE_ENABLED); else setState(BackendState.DISABLED); }

synchronized void org.objectweb.cjdbc.controller.backend.DatabaseBackend.disableWrite (   )

See also: org.objectweb.cjdbc.common.jmx.mbeans.DatabaseBackendMBean.disableWrite() Definition at line 861 of file DatabaseBackend.java. { if (isReadEnabled()) setState(BackendState.READ_ENABLED_WRITE_DISABLED); else setState(BackendState.DISABLED); }

synchronized void org.objectweb.cjdbc.controller.backend.DatabaseBackend.enableRead (   )

Enables the database backend for reads. This method should only be called when the backend is synchronized with the others. Definition at line 839 of file DatabaseBackend.java. Referenced by org.objectweb.cjdbc.controller.loadbalancer.paralleldb.ParallelDB.enableBackend(). { if (isWriteEnabled()) setState(BackendState.READ_ENABLED_WRITE_ENABLED); else setState(BackendState.READ_ENABLED_WRITE_DISABLED); }

synchronized void org.objectweb.cjdbc.controller.backend.DatabaseBackend.enableWrite (   )

Enables the database backend for writes. This method should only be called when the backend is synchronized with the others. Definition at line 873 of file DatabaseBackend.java. Referenced by org.objectweb.cjdbc.controller.loadbalancer.paralleldb.ParallelDB.enableBackend(). { if (isReadEnabled()) setState(BackendState.READ_ENABLED_WRITE_ENABLED); else setState(BackendState.READ_DISABLED_WRITE_ENABLED); }

boolean org.objectweb.cjdbc.controller.backend.DatabaseBackend.equals (  Object  other  )

Two database backends are considered equal if they have the same name, URL and driver class name. Parameters: other  an object Returns: a boolean value Definition at line 368 of file DatabaseBackend.java. References org.objectweb.cjdbc.controller.backend.DatabaseBackend.getDriverClassName(), org.objectweb.cjdbc.controller.backend.DatabaseBackend.getName(), and org.objectweb.cjdbc.controller.backend.DatabaseBackend.getURL(). Referenced by org.objectweb.cjdbc.controller.loadbalancer.raidb2.RAIDb2ec.disableBackend(), org.objectweb.cjdbc.controller.loadbalancer.raidb2.RAIDb2.disableBackend(), org.objectweb.cjdbc.controller.loadbalancer.raidb1.RAIDb1ec.disableBackend(), org.objectweb.cjdbc.controller.loadbalancer.raidb1.RAIDb1.disableBackend(), org.objectweb.cjdbc.controller.loadbalancer.raidb0.RAIDb0.disableBackend(), org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.getAndCheckBackend(), org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.getBackendInformation(), org.objectweb.cjdbc.controller.virtualdatabase.DistributedVirtualDatabase.handleMessageMultiThreaded(), and org.objectweb.cjdbc.controller.virtualdatabase.DistributedVirtualDatabase.isCompatibleBackend(). { if ((other == null) || (!(other instanceof DatabaseBackend))) return false; else { DatabaseBackend b = (DatabaseBackend) other; return name.equals(b.getName()) && driverClassName.equals(b.getDriverClassName()) && url.equals(b.getURL()); } }

synchronized void org.objectweb.cjdbc.controller.backend.DatabaseBackend.finalizeConnections (   )  throws SQLException

Releases all the connections to the database held by the connection managers. Exceptions: SQLException  if an error occurs Definition at line 484 of file DatabaseBackend.java. Referenced by org.objectweb.cjdbc.controller.loadbalancer.paralleldb.ParallelDB.disableBackend(). { if (connectionManagers.isEmpty()) throw new SQLException(Translate.get("backend.not.defined", new String[]{ name, url})); AbstractConnectionManager connectionManager; Iterator iter = connectionManagers.values().iterator(); while (iter.hasNext()) { connectionManager = (AbstractConnectionManager) iter.next(); if (connectionManager.isInitialized()) connectionManager.finalizeConnections(); } }

ArrayList org.objectweb.cjdbc.controller.backend.DatabaseBackend.getActiveTransactions (   )

Returns: Returns the activeTransactions. Definition at line 1377 of file DatabaseBackend.java. { return activeTransactions; }

String org.objectweb.cjdbc.controller.backend.DatabaseBackend.getAssociatedString (   )

See also: org.objectweb.cjdbc.controller.jmx.AbstractStandardMBean.getAssociatedString() Definition at line 955 of file DatabaseBackend.java. { return "backend"; }

String [] org.objectweb.cjdbc.controller.backend.DatabaseBackend.getBackendData (   )

Get data about this backend. Format is: data[0] = this.name; data[1] = this.driverClassName; data[2] = this.url; data[3] = String.valueOf(this.activeTransactions.size()); data[4] = String.valueOf(this.pendingRequests.size()); data[5] = String.valueOf(this.isReadEnabled()); data[6] = String.valueOf(this.isWriteEnabled()); data[7] = String.valueOf(this.isInitialized()); data[8] = String.valueOf(this.schemaIsStatic); data[9] = String.valueOf(this.connectionManagers.size()); data[10] = String.valueOf(getTotalActiveConnections()); data[11] = String.valueOf(totalRequest); data[12] = String.valueOf(totalTransactions); data[13] = lastKnownCheckpoint; * Returns: an array of strings Definition at line 1412 of file DatabaseBackend.java. References org.objectweb.cjdbc.controller.connection.AbstractConnectionManager.driverClassName. Referenced by org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.viewBackendInformation(). { String[] data = new String[14]; data[0] = this.name; data[1] = this.driverClassName; data[2] = this.url; data[3] = String.valueOf(this.activeTransactions.size()); data[4] = String.valueOf(this.pendingRequests.size()); data[5] = String.valueOf(this.isReadEnabled()); data[6] = String.valueOf(this.isWriteEnabled()); try { data[7] = String.valueOf(this.isInitialized()); } catch (Exception e) { data[7] = "unknown"; } data[8] = String.valueOf(this.schemaIsStatic); data[9] = String.valueOf(this.connectionManagers.size()); data[10] = String.valueOf(getTotalActiveConnections()); data[11] = String.valueOf(totalRequest); data[12] = String.valueOf(totalTransactions); if (lastKnownCheckpoint == null || lastKnownCheckpoint.equalsIgnoreCase("")) data[13] = "<unknown>"; else data[13] = lastKnownCheckpoint; return data; }

synchronized Connection org.objectweb.cjdbc.controller.backend.DatabaseBackend.getConnectionForTransactionAndLazyBeginIfNeeded (  Long  tid, AbstractConnectionManager  cm )  throws UnreachableBackendException, NoTransactionStartWhenDisablingException, SQLException

Retrieve a connection for a given transaction or create a new connection and start a new transaction. This method is synchronized so that concurrent writes within the same transaction that are allowed to execute out of order will not open separate connection if they race on transaction begin. Parameters: tid  transaction identifier cm  connection manager to get the connection from Returns: the connection for the given transaction id Exceptions: UnreachableBackendException  if the backend is no more reachable NoTransactionStartWhenDisablingException  if a new transaction needed to be started but the backend is in the disabling state SQLException  if another error occurs Definition at line 574 of file DatabaseBackend.java. Referenced by org.objectweb.cjdbc.controller.loadbalancer.tasks.WriteStoredProcedureTask.executeTask(), org.objectweb.cjdbc.controller.loadbalancer.tasks.WriteRequestWithKeysTask.executeTask(), org.objectweb.cjdbc.controller.loadbalancer.tasks.WriteRequestTask.executeTask(), org.objectweb.cjdbc.controller.loadbalancer.tasks.SelectRequestTask.executeTask(), org.objectweb.cjdbc.controller.loadbalancer.tasks.ReadStoredProcedureTask.executeTask(), and org.objectweb.cjdbc.controller.loadbalancer.tasks.BeginTask.executeTask(). { if (isStartedTransaction(tid)) { // Transaction has already been started, retrieve connection return cm.retrieveConnection(tid.longValue()); } else { if (isDisabling()) throw new NoTransactionStartWhenDisablingException(); // begin transaction startTransaction(tid); // Transaction has not been started yet, this is a lazy begin return AbstractLoadBalancer.getConnectionAndBeginTransaction(this, cm, tid.longValue()); } }

AbstractConnectionManager org.objectweb.cjdbc.controller.backend.DatabaseBackend.getConnectionManager (  String  vLogin  )

Returns the ConnectionManager associated to this backend for a given virtual login. Parameters: vLogin  the virtual login Returns: an AbstractConnectionManager instance Definition at line 918 of file DatabaseBackend.java. Referenced by org.objectweb.cjdbc.controller.loadbalancer.paralleldb.ParallelDB.commit(), org.objectweb.cjdbc.controller.loadbalancer.tasks.WriteStoredProcedureTask.executeTask(), org.objectweb.cjdbc.controller.loadbalancer.tasks.WriteRequestWithKeysTask.executeTask(), org.objectweb.cjdbc.controller.loadbalancer.tasks.WriteRequestTask.executeTask(), org.objectweb.cjdbc.controller.loadbalancer.tasks.SelectRequestTask.executeTask(), org.objectweb.cjdbc.controller.loadbalancer.tasks.RollbackTask.executeTask(), org.objectweb.cjdbc.controller.loadbalancer.tasks.ReadStoredProcedureTask.executeTask(), org.objectweb.cjdbc.controller.loadbalancer.tasks.CommitTask.executeTask(), org.objectweb.cjdbc.controller.loadbalancer.tasks.BeginTask.executeTask(), org.objectweb.cjdbc.controller.loadbalancer.raidb0.RAIDb0.execWriteRequest(), org.objectweb.cjdbc.controller.loadbalancer.raidb0.RAIDb0.execWriteRequestWithKeys(), and org.objectweb.cjdbc.controller.loadbalancer.paralleldb.ParallelDB.rollback(). { return (AbstractConnectionManager) connectionManagers.get(vLogin); }

HashMap org.objectweb.cjdbc.controller.backend.DatabaseBackend.getConnectionManagers (   )

Returns a HashMap of all the ConnectionManager associated with this DatabaseBackend Returns: the hashmap of connection managers Definition at line 929 of file DatabaseBackend.java. Referenced by org.objectweb.cjdbc.controller.backend.DatabaseBackend.copy(). { return this.connectionManagers; }

String org.objectweb.cjdbc.controller.backend.DatabaseBackend.getConnectionTestStatement (   )

Returns the SQL statement to use to check the connection validity. Returns: a String containing a SQL statement Definition at line 939 of file DatabaseBackend.java. Referenced by org.objectweb.cjdbc.common.shared.BackendInfo.BackendInfo(). { return connectionTestStatement; }

String org.objectweb.cjdbc.controller.backend.DatabaseBackend.getDatabaseProductName (   )

Returns the databaseProductName value. Returns: Returns the databaseProductName. Definition at line 1548 of file DatabaseBackend.java. Referenced by org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.enableBackend(), org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.enableBackendFromCheckpoint(), and org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.getDatabaseSchemaFromActiveBackendsAndRefreshDatabaseProductNames(). { return driverCompliance.getDatabaseProductName(); }

DatabaseSchema org.objectweb.cjdbc.controller.backend.DatabaseBackend.getDatabaseSchema (   )

Returns the schema of this database. Returns: the schema of this database. Returns null if the schema has not been set. See also: setDatabaseSchema Definition at line 1081 of file DatabaseBackend.java. Referenced by org.objectweb.cjdbc.controller.loadbalancer.tasks.WriteRequestWithKeysTask.executeTask(), org.objectweb.cjdbc.controller.loadbalancer.tasks.WriteRequestTask.executeTask(), org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.getAndCheckBackend(), and org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.getDatabaseSchemaFromActiveBackendsAndRefreshDatabaseProductNames(). { return schema; }

MetadataContainer org.objectweb.cjdbc.controller.backend.DatabaseBackend.getDatabaseStaticMetadata (   )

Get the Database static metadata from this backend using a connection from the first available connection manager. Returns: Static metadata information Definition at line 1122 of file DatabaseBackend.java. References org.objectweb.cjdbc.controller.backend.DatabaseBackendMetaData.retrieveDatabaseMetadata(). Referenced by org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabaseStaticMetaData.gatherStaticMetadata(). { AbstractConnectionManager connectionMananger; Iterator iter = connectionManagers.values().iterator(); if (iter.hasNext()) { connectionMananger = (AbstractConnectionManager) iter.next(); // Gather the static metadata from the first connection manager DatabaseBackendMetaData meta = new DatabaseBackendMetaData( connectionMananger, logger, dynamicPrecision, gatherSystemTables, schemaName); try { return meta.retrieveDatabaseMetadata(); } catch (SQLException e) { return null; } } else return null; }

String org.objectweb.cjdbc.controller.backend.DatabaseBackend.getDriverClassName (   )

Returns the database native JDBC driver class name. Returns: the driver class name Definition at line 965 of file DatabaseBackend.java. Referenced by org.objectweb.cjdbc.common.shared.BackendInfo.BackendInfo(), org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.disableBackend(), org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.enableBackend(), and org.objectweb.cjdbc.controller.backend.DatabaseBackend.equals(). { return driverClassName; }

DriverCompliance org.objectweb.cjdbc.controller.backend.DatabaseBackend.getDriverCompliance (   )

Returns: the driver compliance to C-JDBC requirements. Definition at line 1216 of file DatabaseBackend.java. Referenced by org.objectweb.cjdbc.controller.loadbalancer.tasks.WriteRequestWithKeysTask.executeTask(), and org.objectweb.cjdbc.controller.loadbalancer.raidb0.RAIDb0.execWriteRequestWithKeys(). { return driverCompliance; }

String org.objectweb.cjdbc.controller.backend.DatabaseBackend.getDriverPath (   )

See also: org.objectweb.cjdbc.common.jmx.mbeans.DatabaseBackendMBean.getDriverPath() Definition at line 947 of file DatabaseBackend.java. Referenced by org.objectweb.cjdbc.common.shared.BackendInfo.BackendInfo(). { return driverPath; }

int org.objectweb.cjdbc.controller.backend.DatabaseBackend.getDynamicPrecision (   )

Returns: Returns the dynamicPrecision. Definition at line 1462 of file DatabaseBackend.java. { return dynamicPrecision; }

String org.objectweb.cjdbc.controller.backend.DatabaseBackend.getLastKnownCheckpoint (   )

Returns the lastKnownCheckpoint value. Returns: Returns the lastKnownCheckpoint. Definition at line 1538 of file DatabaseBackend.java. Referenced by org.objectweb.cjdbc.controller.backend.BackendStateListener.changeState(), org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.disableBackend(), org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.enableBackend(), org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.enableBackendFromCheckpoint(), org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.removeBackend(), and org.objectweb.cjdbc.controller.requestmanager.RequestManager.storeBackendsInfo(). { return lastKnownCheckpoint; }

String org.objectweb.cjdbc.controller.backend.DatabaseBackend.getName (   )

Returns the backend logical name. Returns: the backend logical name Definition at line 975 of file DatabaseBackend.java. Referenced by org.objectweb.cjdbc.controller.loadbalancer.AbstractLoadBalancer.AbstractLoadBalancer(), org.objectweb.cjdbc.common.shared.BackendInfo.BackendInfo(), org.objectweb.cjdbc.controller.backend.BackendStateListener.changeState(), org.objectweb.cjdbc.controller.loadbalancer.paralleldb.ParallelDB.commit(), org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.disableAllBackends(), org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.disableBackend(), org.objectweb.cjdbc.controller.requestmanager.RequestManager.disableBackendsForCheckpoint(), org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.enableAllBackendsFromCheckpoint(), org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.enableBackend(), org.objectweb.cjdbc.controller.backend.DatabaseBackend.equals(), org.objectweb.cjdbc.controller.loadbalancer.raidb2.RAIDb2_RR.execReadOnlyReadStoredProcedure(), org.objectweb.cjdbc.controller.loadbalancer.raidb2.RAIDb2_LPRF.execReadOnlyReadStoredProcedure(), 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.tasks.WriteStoredProcedureTask.executeTask(), org.objectweb.cjdbc.controller.loadbalancer.tasks.WriteRequestWithKeysTask.executeTask(), org.objectweb.cjdbc.controller.loadbalancer.tasks.WriteRequestTask.executeTask(), org.objectweb.cjdbc.controller.loadbalancer.tasks.SelectRequestTask.executeTask(), org.objectweb.cjdbc.controller.loadbalancer.tasks.RollbackTask.executeTask(), org.objectweb.cjdbc.controller.loadbalancer.tasks.ReadStoredProcedureTask.executeTask(), org.objectweb.cjdbc.controller.loadbalancer.tasks.CommitTask.executeTask(), org.objectweb.cjdbc.controller.loadbalancer.tasks.BeginTask.executeTask(), org.objectweb.cjdbc.controller.loadbalancer.raidb0.RAIDb0.execWriteRequest(), org.objectweb.cjdbc.controller.loadbalancer.raidb0.RAIDb0.execWriteRequestWithKeys(), org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.forceEnableAllBackendsFromCheckpoint(), org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabaseStaticMetaData.gatherStaticMetadata(), org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.getAndCheckBackend(), org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.getBackendInformation(), org.objectweb.cjdbc.controller.loadbalancer.policies.createtable.CreateTableRule.getBackends(), org.objectweb.cjdbc.controller.virtualdatabase.DistributedVirtualDatabase.handleMessageMultiThreaded(), org.objectweb.cjdbc.controller.virtualdatabase.DistributedVirtualDatabase.handleMessageSingleThreaded(), org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.removeBackend(), org.objectweb.cjdbc.controller.loadbalancer.paralleldb.ParallelDB.rollback(), org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.setBackendLastKnownCheckpoint(), and org.objectweb.cjdbc.controller.requestmanager.RequestManager.storeBackendsInfo(). { return name; }

Vector org.objectweb.cjdbc.controller.backend.DatabaseBackend.getPendingRequests (   )

Returns the list of pending requests for this backend. Returns: Vector of AbstractRequests or AbstractTask objects Definition at line 996 of file DatabaseBackend.java. Referenced by org.objectweb.cjdbc.controller.loadbalancer.paralleldb.ParallelDB_LPRF.chooseBackendForReadRequest(), org.objectweb.cjdbc.controller.loadbalancer.paralleldb.ParallelDB_LPRF.chooseBackendForWriteRequest(), org.objectweb.cjdbc.controller.loadbalancer.raidb2.RAIDb2_LPRF.execReadOnlyReadStoredProcedure(), and org.objectweb.cjdbc.controller.loadbalancer.raidb2.RAIDb2_LPRF.execReadRequest(). { return pendingRequests; }

ArrayList org.objectweb.cjdbc.controller.backend.DatabaseBackend.getPendingRequestsDescription (  int  count, boolean  fromFirst, boolean  clone )

See also: org.objectweb.cjdbc.common.jmx.mbeans.DatabaseBackendMBean.getPendingRequestsDescription(int, boolean, boolean) Definition at line 1005 of file DatabaseBackend.java. References org.objectweb.cjdbc.controller.connection.AbstractConnectionManager.clone(). { int size = pendingRequests.size(); int limit = (count == 0 || count > size) ? size : Math.min(size, count); ArrayList list = new ArrayList(limit); int start = (fromFirst) ? 0 : Math.min(limit - count, 0); if (!clone) { synchronized (pendingRequests) { for (int i = start; i < limit; i++) list.add(pendingRequests.get(i).toString()); } return list; } else { Vector cloneVector = (Vector) pendingRequests.clone(); for (int i = start; i < limit; i++) list.add(cloneVector.get(i).toString()); return list; } }

ArrayList org.objectweb.cjdbc.controller.backend.DatabaseBackend.getRewritingRules (   )

Returns the rewritingRules value. Returns: Returns the rewritingRules. Definition at line 1558 of file DatabaseBackend.java. { return rewritingRules; }

String org.objectweb.cjdbc.controller.backend.DatabaseBackend.getSchemaXml (  boolean  expandSchema  )

See also: org.objectweb.cjdbc.common.jmx.mbeans.DatabaseBackendMBean.getSchemaXml(boolean) Definition at line 1356 of file DatabaseBackend.java. Referenced by org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.getBackendSchema(). { StringBuffer info = new StringBuffer(); info.append("<" + DatabasesXmlTags.ELT_DatabaseSchema + " " + DatabasesXmlTags.ATT_dynamicPrecision + "=\"" + DatabaseBackendSchemaConstants .getDynamicSchemaLevel(dynamicPrecision) + "\" " + DatabasesXmlTags.ATT_gatherSystemTables + "=\"" + (gatherSystemTables ? "true" : "false") + "\">"); if (expandSchema) info.append(schema.getXml()); info.append("</" + DatabasesXmlTags.ELT_DatabaseSchema + ">"); return info.toString(); }

int org.objectweb.cjdbc.controller.backend.DatabaseBackend.getSQLShortFormLength (   )

Return the sql short form length to use when reporting an error. Returns: sql short form length See also: org.objectweb.cjdbc.common.sql.AbstractRequest.getSQLShortForm(int) Definition at line 354 of file DatabaseBackend.java. Referenced by org.objectweb.cjdbc.controller.loadbalancer.tasks.WriteStoredProcedureTask.executeTask(), org.objectweb.cjdbc.controller.loadbalancer.tasks.WriteRequestWithKeysTask.executeTask(), org.objectweb.cjdbc.controller.loadbalancer.tasks.WriteRequestTask.executeTask(), org.objectweb.cjdbc.controller.loadbalancer.tasks.SelectRequestTask.executeTask(), and org.objectweb.cjdbc.controller.loadbalancer.tasks.ReadStoredProcedureTask.executeTask(). { return sqlShortFormLength; }

String org.objectweb.cjdbc.controller.backend.DatabaseBackend.getState (   )

Retrieve the state of the backend. See also: CjdbcNotificationList#VIRTUALDATABASE_BACKEND_DISABLED CjdbcNotificationList#VIRTUALDATABASE_BACKEND_RECOVERING CjdbcNotificationList#VIRTUALDATABASE_BACKEND_BACKINGUP CjdbcNotificationList#VIRTUALDATABASE_BACKEND_DISABLING CjdbcNotificationList#VIRTUALDATABASE_BACKEND_ENABLED CjdbcNotificationList#VIRTUALDATABASE_BACKEND_DISABLED Returns: one of the above Definition at line 796 of file DatabaseBackend.java. Referenced by org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.getBackendState(). { switch (state) { case BackendState.READ_ENABLED_WRITE_DISABLED : return CjdbcNotificationList.VIRTUALDATABASE_BACKEND_ENABLED; case BackendState.READ_ENABLED_WRITE_ENABLED : return CjdbcNotificationList.VIRTUALDATABASE_BACKEND_ENABLED_WRITE; case BackendState.READ_DISABLED_WRITE_ENABLED : return CjdbcNotificationList.VIRTUALDATABASE_BACKEND_ENABLED_WRITE; case BackendState.DISABLING : return CjdbcNotificationList.VIRTUALDATABASE_BACKEND_DISABLING; case BackendState.BACKUPING : return CjdbcNotificationList.VIRTUALDATABASE_BACKEND_BACKINGUP; case BackendState.RECOVERING : return CjdbcNotificationList.VIRTUALDATABASE_BACKEND_RECOVERING; case BackendState.REPLAYING : return CjdbcNotificationList.VIRTUALDATABASE_BACKEND_REPLAYING; case BackendState.DISABLED : return CjdbcNotificationList.VIRTUALDATABASE_BACKEND_DISABLED; case BackendState.UNKNOWN : return CjdbcNotificationList.VIRTUALDATABASE_BACKEND_UNKNOWN; default : throw new IllegalArgumentException("Unknown backend state:" + state); } }

int org.objectweb.cjdbc.controller.backend.DatabaseBackend.getStateValue (   )

Return the integer value corresponding to the state of the backend. The values are defined in BackendState Returns: int value See also: BackendState Definition at line 830 of file DatabaseBackend.java. Referenced by org.objectweb.cjdbc.controller.backend.BackendStateListener.changeState(), org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.setBackendLastKnownCheckpoint(), and org.objectweb.cjdbc.controller.requestmanager.RequestManager.storeBackendsInfo(). { return state; }

ArrayList org.objectweb.cjdbc.controller.backend.DatabaseBackend.getTables (   )

Get all the names of tables of this database Returns: ArrayList of DatabaseTable Definition at line 430 of file DatabaseBackend.java. { if (schema == null) throw new NullPointerException(Translate.get("backend.schema.not.set")); return schema.getTables(); }

long org.objectweb.cjdbc.controller.backend.DatabaseBackend.getTotalActiveConnections (   )

Get the total number of active connections for this backend Returns: number of active connections for all AbstractConnectionManager connected to this backend Definition at line 1449 of file DatabaseBackend.java. References org.objectweb.cjdbc.controller.connection.AbstractConnectionManager.getCurrentNumberOfConnections(). { int activeConnections = 0; Iterator iter = connectionManagers.keySet().iterator(); while (iter.hasNext()) activeConnections += ((AbstractConnectionManager) connectionManagers .get(iter.next())).getCurrentNumberOfConnections(); return activeConnections; }

int org.objectweb.cjdbc.controller.backend.DatabaseBackend.getTotalReadRequest (   )

Returns the total number of read requests executed by this backend. Returns: Returns the totalReadRequest. Definition at line 1498 of file DatabaseBackend.java. { return totalReadRequest; }

int org.objectweb.cjdbc.controller.backend.DatabaseBackend.getTotalRequest (   )

Returns the total number of requests executed by this backend. Returns: Returns the totalRequest. Definition at line 1518 of file DatabaseBackend.java. { return totalRequest; }

int org.objectweb.cjdbc.controller.backend.DatabaseBackend.getTotalTransactions (   )

Returns the total number of transactions executed by this backend. Returns: Total number of transactions. Definition at line 1488 of file DatabaseBackend.java. { return totalTransactions; }

int org.objectweb.cjdbc.controller.backend.DatabaseBackend.getTotalWriteRequest (   )

Returns the total number of write requests executed by this backend. Returns: Returns the totalWriteRequest. Definition at line 1508 of file DatabaseBackend.java. { return totalWriteRequest; }

String org.objectweb.cjdbc.controller.backend.DatabaseBackend.getURL (   )

Returns the JDBC URL used to access the database. Returns: a JDBC URL Definition at line 1255 of file DatabaseBackend.java. Referenced by org.objectweb.cjdbc.common.shared.BackendInfo.BackendInfo(), org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.disableBackend(), org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.enableBackend(), org.objectweb.cjdbc.controller.backend.DatabaseBackend.equals(), and org.objectweb.cjdbc.controller.virtualdatabase.DistributedVirtualDatabase.isCompatibleBackend(). { return url; }

String org.objectweb.cjdbc.controller.backend.DatabaseBackend.getVirtualDatabaseName (   )

Returns the virtual database name this backend belongs to. Returns: Returns the virtual database name. Definition at line 985 of file DatabaseBackend.java. Referenced by org.objectweb.cjdbc.common.shared.BackendInfo.BackendInfo(). { return virtualDatabaseName; }

String org.objectweb.cjdbc.controller.backend.DatabaseBackend.getXml (   )

Get xml information about this backend. Returns: xml formatted information on this database backend. Definition at line 1315 of file DatabaseBackend.java. References org.objectweb.cjdbc.controller.connection.AbstractConnectionManager.getXml(). Referenced by org.objectweb.cjdbc.controller.virtualdatabase.DistributedVirtualDatabase.createBackendInfo(), and org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.getBackendInformation(). { StringBuffer info = new StringBuffer(); info.append("<" + DatabasesXmlTags.ELT_DatabaseBackend + " " + DatabasesXmlTags.ATT_name + "=\"" + name + "\" " + DatabasesXmlTags.ATT_driver + "=\"" + driverClassName + "\" " + DatabasesXmlTags.ATT_url + "=\"" + url + "\" " + DatabasesXmlTags.ATT_connectionTestStatement + "=\"" + connectionTestStatement + "\">"); boolean expandSchema = this.schema != null && dynamicPrecision == DatabaseBackendSchemaConstants.DynamicPrecisionStatic; info.append(getSchemaXml(expandSchema)); if (rewritingRules != null) { int size = rewritingRules.size(); for (int i = 0; i < size; i++) info.append(((AbstractRewritingRule) rewritingRules.get(i)).getXml()); } if (connectionManagers != null) { if (connectionManagers.isEmpty() == false) { AbstractConnectionManager connectionManager; Iterator iter = connectionManagers.values().iterator(); while (iter.hasNext()) { connectionManager = (AbstractConnectionManager) iter.next(); info.append(connectionManager.getXml()); } } } info.append("</" + DatabasesXmlTags.ELT_DatabaseBackend + ">"); return info.toString(); }

boolean org.objectweb.cjdbc.controller.backend.DatabaseBackend.hasStoredProcedure (  String  procedureName  )

Returns true if this backend has the given stored procedure in its schema. The caller must ensure that the database schema has been defined, using the setDatabaseSchema(DatabaseSchema, boolean)or checkDatabaseSchema() Parameters: procedureName  The stored procedure name to look for Returns: true if procedure name is found in the schema Definition at line 446 of file DatabaseBackend.java. Referenced by org.objectweb.cjdbc.controller.loadbalancer.raidb2.RAIDb2_RR.execReadOnlyReadStoredProcedure(), and org.objectweb.cjdbc.controller.loadbalancer.raidb2.RAIDb2_LPRF.execReadOnlyReadStoredProcedure(). { if (schema == null) throw new NullPointerException(Translate.get("backend.schema.not.set")); return schema.hasProcedure(procedureName); }

boolean org.objectweb.cjdbc.controller.backend.DatabaseBackend.hasTable (  String  table  )

Returns true if this backend has the given table in its schema. The caller must ensure that the database schema has been defined, using the setDatabaseSchema(DatabaseSchema, boolean)or checkDatabaseSchema() Parameters: table  The table name to look for Returns: true if tables is found in the schema Definition at line 417 of file DatabaseBackend.java. Referenced by org.objectweb.cjdbc.controller.loadbalancer.raidb0.RAIDb0.execWriteRequest(), and org.objectweb.cjdbc.controller.loadbalancer.raidb0.RAIDb0.execWriteRequestWithKeys(). { if (schema == null) throw new NullPointerException(Translate.get("backend.schema.not.set")); return schema.hasTable(table); }

boolean org.objectweb.cjdbc.controller.backend.DatabaseBackend.hasTables (  ArrayList  tables  )

Returns true if this backend has the given list of tables in its schema. The caller must ensure that the database schema has been defined, using the setDatabaseSchema(DatabaseSchema, boolean)or checkDatabaseSchema()methods. Parameters: tables  the list of table names (ArrayList of String) to look for Returns: true if all the tables are found Definition at line 391 of file DatabaseBackend.java. Referenced by org.objectweb.cjdbc.controller.loadbalancer.raidb2.RAIDb2_RR.execReadRequest(), org.objectweb.cjdbc.controller.loadbalancer.raidb2.RAIDb2_LPRF.execReadRequest(), and org.objectweb.cjdbc.controller.loadbalancer.raidb0.RAIDb0.execReadRequest(). { if (schema == null) throw new NullPointerException(Translate.get("backend.schema.not.set")); if (tables == null) throw new IllegalArgumentException(Translate.get("backend.null.tables")); int size = tables.size(); for (int i = 0; i < size; i++) { if (!schema.hasTable((String) tables.get(i))) return false; } return true; }

synchronized void org.objectweb.cjdbc.controller.backend.DatabaseBackend.initializeConnections (   )  throws SQLException

Initializes the connection managers' connections. The caller must ensure that the driver has already been loaded else an exception will be thrown. Exceptions: SQLException  if an error occurs Definition at line 462 of file DatabaseBackend.java. Referenced by org.objectweb.cjdbc.controller.loadbalancer.paralleldb.ParallelDB.enableBackend(), and org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.getAndCheckBackend(). { if (connectionManagers.isEmpty()) throw new SQLException(Translate.get("backend.not.defined", new String[]{ name, url})); AbstractConnectionManager connectionManager; Iterator iter = connectionManagers.values().iterator(); while (iter.hasNext()) { connectionManager = (AbstractConnectionManager) iter.next(); if (!connectionManager.isInitialized()) connectionManager.initializeConnections(); } }

boolean org.objectweb.cjdbc.controller.backend.DatabaseBackend.isBackuping (   )

Returns the isBackuping value. Returns: Returns the isBackuping. Definition at line 1647 of file DatabaseBackend.java. { return state == BackendState.BACKUPING; }

boolean org.objectweb.cjdbc.controller.backend.DatabaseBackend.isDisabled (   )

See also: org.objectweb.cjdbc.common.jmx.mbeans.DatabaseBackendMBean.isDisabled() Definition at line 769 of file DatabaseBackend.java. Referenced by org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.setBackendLastKnownCheckpoint(). { return state == BackendState.DISABLED; }

boolean org.objectweb.cjdbc.controller.backend.DatabaseBackend.isDisabling (   )

Returns the isDisabling value. Returns: Returns the isDisabling. Definition at line 761 of file DatabaseBackend.java. Referenced by org.objectweb.cjdbc.controller.loadbalancer.paralleldb.ParallelDB_RR.chooseBackendForWriteRequest(), org.objectweb.cjdbc.controller.loadbalancer.paralleldb.ParallelDB_LPRF.chooseBackendForWriteRequest(), org.objectweb.cjdbc.controller.loadbalancer.tasks.WriteStoredProcedureTask.executeTask(), org.objectweb.cjdbc.controller.loadbalancer.tasks.WriteRequestWithKeysTask.executeTask(), org.objectweb.cjdbc.controller.loadbalancer.tasks.WriteRequestTask.executeTask(), org.objectweb.cjdbc.controller.loadbalancer.tasks.BeginTask.executeTask(), org.objectweb.cjdbc.controller.loadbalancer.raidb0.RAIDb0.execWriteRequest(), and org.objectweb.cjdbc.controller.loadbalancer.raidb0.RAIDb0.execWriteRequestWithKeys(). { return state == BackendState.DISABLING; }

synchronized boolean org.objectweb.cjdbc.controller.backend.DatabaseBackend.isInitialized (   )  throws SQLException

Tests if this backend is enabled (active and synchronized). Returns: true if this backend is enabled Exceptions: SQLException  if an error occurs Definition at line 679 of file DatabaseBackend.java. { if (connectionManagers.isEmpty()) throw new SQLException(Translate.get("backend.null.connection.manager", new String[]{name, url})); Iterator iter = connectionManagers.values().iterator(); while (iter.hasNext()) { if (!((AbstractConnectionManager) iter.next()).isInitialized()) return false; } return true; }

synchronized boolean org.objectweb.cjdbc.controller.backend.DatabaseBackend.isJDBCConnected (   )

Is the backend accessible ? Returns: true if a jdbc connection is still possible from the controller Definition at line 699 of file DatabaseBackend.java. References org.objectweb.cjdbc.controller.connection.AbstractConnectionManager.getConnectionFromDriver(). { try { if (connectionManagers.isEmpty()) throw new SQLException(Translate.get("backend.null.connection.manager", new String[]{name, url})); AbstractConnectionManager connectionManager; Iterator iter = connectionManagers.values().iterator(); connectionManager = (AbstractConnectionManager) iter.next(); Connection con = connectionManager.getConnectionFromDriver(); con.createStatement().execute(this.connectionTestStatement); return true; } catch (Exception e) { String msg = Translate.get("loadbalancer.backend.unreacheable", name); logger.warn(msg, e); return false; } }

boolean org.objectweb.cjdbc.controller.backend.DatabaseBackend.isKilled (   )

Returns true if the backend cannot be used anymore Returns: Returns true if the backend was removed from activity by the load balancer Definition at line 780 of file DatabaseBackend.java. { return state == BackendState.UNKNOWN; }

synchronized boolean org.objectweb.cjdbc.controller.backend.DatabaseBackend.isReadEnabled (   )

Tests if this backend is read enabled (active and synchronized). Returns: true if this backend is enabled. Definition at line 728 of file DatabaseBackend.java. Referenced by 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.virtualdatabase.VirtualDatabase.disableAllBackends(), org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.enableAllBackends(), org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.enableAllBackendsFromCheckpoint(), org.objectweb.cjdbc.controller.loadbalancer.raidb2.RAIDb2_RR.execReadOnlyReadStoredProcedure(), org.objectweb.cjdbc.controller.loadbalancer.raidb2.RAIDb2_LPRF.execReadOnlyReadStoredProcedure(), 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.virtualdatabase.VirtualDatabase.forceEnableAllBackendsFromCheckpoint(), org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.getAndCheckBackend(), org.objectweb.cjdbc.controller.loadbalancer.policies.errorchecking.ErrorCheckingRoundRobin.getBackends(), org.objectweb.cjdbc.controller.loadbalancer.policies.errorchecking.ErrorCheckingRandom.getBackends(), and org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.getDatabaseSchemaFromActiveBackendsAndRefreshDatabaseProductNames(). { return state == BackendState.READ_ENABLED_WRITE_DISABLED || state == BackendState.READ_ENABLED_WRITE_ENABLED; }

boolean org.objectweb.cjdbc.controller.backend.DatabaseBackend.isRecovering (   )

Returns the isRecovering value. Returns: Returns the isRecovering. Definition at line 751 of file DatabaseBackend.java. { return state == BackendState.RECOVERING; }

boolean org.objectweb.cjdbc.controller.backend.DatabaseBackend.isSchemaStatic (   )

Returns: Returns the schemaIsStatic. Definition at line 1385 of file DatabaseBackend.java. { return schemaIsStatic; }

boolean org.objectweb.cjdbc.controller.backend.DatabaseBackend.isStartedTransaction (  Long  tid  )

Returns true if the specified transaction has been started on this backend (a connection has been allocated for this transaction). Parameters: tid  transaction identifier Returns: true if the transaction has been started Definition at line 665 of file DatabaseBackend.java. Referenced by org.objectweb.cjdbc.controller.loadbalancer.raidb2.RAIDb2.commit(), org.objectweb.cjdbc.controller.loadbalancer.raidb1.RAIDb1.commit(), org.objectweb.cjdbc.controller.loadbalancer.raidb0.RAIDb0.commit(), org.objectweb.cjdbc.controller.loadbalancer.raidb2.RAIDb2.rollback(), org.objectweb.cjdbc.controller.loadbalancer.raidb1.RAIDb1.rollback(), and org.objectweb.cjdbc.controller.loadbalancer.raidb0.RAIDb0.rollback(). { synchronized (activeTransactions) { return activeTransactions.contains(tid); } }

boolean org.objectweb.cjdbc.controller.backend.DatabaseBackend.isValidConnection (  Connection  connection  )

Check if the given connection is valid or not. This function issues the connectionTestStatement query on the connection and if it succeeds then the connection is declared valid. If an exception occurs, the connection is declared invalid. Parameters: connection  the connection to test Returns: true if the connection is valid Definition at line 509 of file DatabaseBackend.java. References java.sql.Statement.executeQuery(). { try { Statement s = connection.createStatement(); s.executeQuery(connectionTestStatement); } catch (SQLException e) { if ("25P02".equals(e.getSQLState()) || (e.getMessage() != null && e .getMessage() .indexOf( "current transaction is aborted, queries ignored until end of transaction block") > 0)) { // see bug item #300873 on the forge for details // postgres throws an exception if a query is issued after a request has // failed within a transaction, we now have to check for this exception // as it is means the connection is valid // // postgres versions after 7.4 will return the SQLState, whereas // postgres versions prior to 7.4 will have to be checked for the // message text return true; } return false; } return true; }

boolean org.objectweb.cjdbc.controller.backend.DatabaseBackend.isWriteCanBeEnabled (   )

Returns the writeCanBeEnabled value. Returns: Returns the writeCanBeEnabled. Definition at line 1746 of file DatabaseBackend.java. { return writeCanBeEnabled; }

synchronized boolean org.objectweb.cjdbc.controller.backend.DatabaseBackend.isWriteEnabled (   )

Tests if this backend is write enabled (active and synchronized). Returns: true if this backend is enabled. Definition at line 739 of file DatabaseBackend.java. Referenced by org.objectweb.cjdbc.controller.loadbalancer.AbstractLoadBalancer.AbstractLoadBalancer(), org.objectweb.cjdbc.controller.loadbalancer.paralleldb.ParallelDB_RR.chooseBackendForWriteRequest(), org.objectweb.cjdbc.controller.loadbalancer.paralleldb.ParallelDB_LPRF.chooseBackendForWriteRequest(), org.objectweb.cjdbc.controller.requestmanager.RequestManager.disableBackendsForCheckpoint(), org.objectweb.cjdbc.controller.loadbalancer.raidb0.RAIDb0.execWriteRequest(), org.objectweb.cjdbc.controller.loadbalancer.raidb0.RAIDb0.execWriteRequestWithKeys(), org.objectweb.cjdbc.controller.loadbalancer.policies.errorchecking.ErrorCheckingRoundRobin.getBackends(), org.objectweb.cjdbc.controller.loadbalancer.policies.errorchecking.ErrorCheckingRandom.getBackends(), and org.objectweb.cjdbc.controller.loadbalancer.policies.createtable.CreateTableRule.getBackends(). { return state == BackendState.READ_ENABLED_WRITE_ENABLED || state == BackendState.READ_DISABLED_WRITE_ENABLED || state == BackendState.DISABLING; }

void org.objectweb.cjdbc.controller.backend.DatabaseBackend.notifyJmx (  String  type  )

Sends JMX notification Parameters: type  notification type See also: CjdbcNotificationList Definition at line 1704 of file DatabaseBackend.java. { notifyJmx(type, CjdbcNotificationList.NOTIFICATION_LEVEL_INFO, Translate .get(type, getName())); }

void org.objectweb.cjdbc.controller.backend.DatabaseBackend.notifyJmxError (  String  type, Exception  e )

Sends JMX error notification Parameters: e  Exception object. Only the message will be used type  notification type See also: CjdbcNotificationList Definition at line 1717 of file DatabaseBackend.java. { notifyJmx(type, CjdbcNotificationList.NOTIFICATION_LEVEL_ERROR, Translate .get(type, new String[]{getName(), e.getMessage()})); }

void org.objectweb.cjdbc.controller.backend.DatabaseBackend.notifyStateChange (   )

Notify the state of the backend has changed. This does two things: 1. Change the state of the backend stored in the recovery log 2. Sends a jmx notification. This method has all the data prefilled because we know all the parameters in advance, except the type of the notification. See also: CjdbcNotificationList Definition at line 1691 of file DatabaseBackend.java. { if (stateListener != null) stateListener.changeState(this); notifyJmx(getState()); }

void org.objectweb.cjdbc.controller.backend.DatabaseBackend.refreshSchema (   )

Erase the current schema and force a re-fetch of all the meta data Definition at line 1110 of file DatabaseBackend.java. Referenced by org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.getDatabaseSchemaFromActiveBackendsAndRefreshDatabaseProductNames(). { setDatabaseSchema(null, isSchemaStatic()); checkDatabaseSchema(); }

boolean org.objectweb.cjdbc.controller.backend.DatabaseBackend.removePendingRequest (  Object  request  )

Removes a pending request from this backend. Note that the underlying vector is synchronized. Parameters: request  the request to remove Returns: true if the request has been found and removed Definition at line 1069 of file DatabaseBackend.java. { return pendingRequests.remove(request); }

String org.objectweb.cjdbc.controller.backend.DatabaseBackend.rewriteQuery (  String  sqlQuery  )

Rewrite the current query according to the rewriting rules. Parameters: sqlQuery  request to rewrite Returns: the rewritten SQL query according to rewriting rules. Definition at line 1285 of file DatabaseBackend.java. References org.objectweb.cjdbc.controller.backend.rewriting.AbstractRewritingRule.hasMatched, org.objectweb.cjdbc.controller.backend.rewriting.AbstractRewritingRule.isStopOnMatch(), and org.objectweb.cjdbc.controller.backend.rewriting.AbstractRewritingRule.rewrite. { if (rewritingRules == null) return sqlQuery; int size = rewritingRules.size(); for (int i = 0; i < size; i++) { AbstractRewritingRule rule = (AbstractRewritingRule) rewritingRules .get(i); sqlQuery = rule.rewrite(sqlQuery); if (rule.hasMatched()) { // Rule matched, query rewriten if (logger.isDebugEnabled()) logger.debug(Translate.get("backend.rewriting.query", sqlQuery)); if (rule.isStopOnMatch()) break; // Ok, stop here. } } return sqlQuery; }

void org.objectweb.cjdbc.controller.backend.DatabaseBackend.setDatabaseSchema (  DatabaseSchema  databaseSchema, boolean  isStatic )

Sets the database schema. Parameters: databaseSchema  the schema to set isStatic  true if the schema should be static See also: getDatabaseSchema Definition at line 1093 of file DatabaseBackend.java. Referenced by org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.disableBackendWithCheckpoint(), org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.enableBackend(), org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.enableBackendFromCheckpoint(), and org.objectweb.cjdbc.controller.requestmanager.RequestManager.setDatabaseSchema(). { if (schema == null) { schemaIsStatic = isStatic; schema = databaseSchema; } else { if (!isStatic) schema = databaseSchema; } }

void org.objectweb.cjdbc.controller.backend.DatabaseBackend.setDisabling (   )

This is used when the backend must be disabled but currently open transactions must terminate. This is a transitional state. When disabling is complete the caller must set the backend state to disabled. Reads are no more allowed on the backend and the state is updated so that isReadEnabled() returns false. See also: disable() isReadEnabled() Deprecated: not used anymore. Please use the setState method instead Definition at line 893 of file DatabaseBackend.java. { setState(BackendState.DISABLING); }

void org.objectweb.cjdbc.controller.backend.DatabaseBackend.setDynamicPrecision (  int  dynamicPrecision, boolean  gatherSystemTables, String  schemaName )

Set the amount of information that must be gathered when fetching database schema information. Parameters: dynamicPrecision  The dynamicPrecision to set. gatherSystemTables  True if we must gather system tables schemaName  Schema name to use to gather tables Definition at line 1475 of file DatabaseBackend.java. { this.dynamicPrecision = dynamicPrecision; this.gatherSystemTables = gatherSystemTables; this.schemaName = schemaName; }

void org.objectweb.cjdbc.controller.backend.DatabaseBackend.setLastKnownCheckpoint (  String  checkpoint  )

setLastKnownCheckpoint for this backend Parameters: checkpoint  the checkpoint Definition at line 1528 of file DatabaseBackend.java. Referenced by org.objectweb.cjdbc.controller.requestmanager.RequestManager.disableBackendsForCheckpoint(), org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.forceEnableAllBackendsFromCheckpoint(), and org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.setBackendLastKnownCheckpoint(). { this.lastKnownCheckpoint = checkpoint; }

void org.objectweb.cjdbc.controller.backend.DatabaseBackend.setRewritingRules (  ArrayList  rewritingRules  )

Sets the rewritingRules value. Parameters: rewritingRules  The rewritingRules to set. Definition at line 1568 of file DatabaseBackend.java. Referenced by org.objectweb.cjdbc.controller.backend.DatabaseBackend.copy(). { this.rewritingRules = rewritingRules; }

void org.objectweb.cjdbc.controller.backend.DatabaseBackend.setSqlShortFormLength (  int  sqlShortFormLength  )

Sets the sqlShortFormLength value. Parameters: sqlShortFormLength  The sqlShortFormLength to set. Definition at line 343 of file DatabaseBackend.java. { this.sqlShortFormLength = sqlShortFormLength; }

synchronized void org.objectweb.cjdbc.controller.backend.DatabaseBackend.setState (  int  state  )

Set the state of a backend Parameters: state  see BackendState for a possible list of the different state See also: org.objectweb.cjdbc.common.shared.BackendState Definition at line 1658 of file DatabaseBackend.java. References org.objectweb.cjdbc.controller.backend.DatabaseBackend.state. Referenced by org.objectweb.cjdbc.controller.requestmanager.RequestManager.disableBackendsForCheckpoint(). { switch (state) { case BackendState.UNKNOWN : lastKnownCheckpoint = null; case BackendState.READ_ENABLED_WRITE_DISABLED : case BackendState.READ_ENABLED_WRITE_ENABLED : case BackendState.READ_DISABLED_WRITE_ENABLED : case BackendState.DISABLING : case BackendState.BACKUPING : case BackendState.RECOVERING : case BackendState.REPLAYING : case BackendState.DISABLED : this.state = state; if (logger.isDebugEnabled()) logger.debug(Translate.get("backend.state.changed", new String[]{ name, getState()})); notifyStateChange(); break; default : throw new IllegalArgumentException("Unknown backend state:" + state); } }

void org.objectweb.cjdbc.controller.backend.DatabaseBackend.setStateListener (  BackendStateListener  stateListener  )

Sets the stateListener value. Parameters: stateListener  The stateListener to set. Definition at line 1756 of file DatabaseBackend.java. References org.objectweb.cjdbc.controller.backend.DatabaseBackend.stateListener. Referenced by org.objectweb.cjdbc.controller.requestmanager.RequestManager.setRecoveryLog(). { this.stateListener = stateListener; }

void org.objectweb.cjdbc.controller.backend.DatabaseBackend.startTransaction (  Long  tid  )

Signals that a transaction has been started on this backend. It means that a connection has been allocated for this transaction. Parameters: tid  transaction identifier Definition at line 605 of file DatabaseBackend.java. Referenced by org.objectweb.cjdbc.controller.loadbalancer.paralleldb.ParallelDB.begin(). { synchronized (activeTransactions) { totalTransactions++; activeTransactions.add(tid); } }

void org.objectweb.cjdbc.controller.backend.DatabaseBackend.stopTransaction (  Long  tid  )

Signals that a transaction has been stopped on this backend. It means that the connection has been released for this transaction. Parameters: tid  transaction identifier Definition at line 620 of file DatabaseBackend.java. Referenced by org.objectweb.cjdbc.controller.loadbalancer.paralleldb.ParallelDB.commit(), org.objectweb.cjdbc.controller.loadbalancer.tasks.RollbackTask.executeTask(), org.objectweb.cjdbc.controller.loadbalancer.tasks.CommitTask.executeTask(), and org.objectweb.cjdbc.controller.loadbalancer.paralleldb.ParallelDB.rollback(). { synchronized (activeTransactions) { if (!activeTransactions.remove(tid)) throw new IllegalArgumentException(Translate.get( "backend.transaction.not.started", new String[]{"" + tid, name})); // If this was the last open transaction, we notify people possibly // waiting on waitForAllTransactionsToComplete() if (activeTransactions.isEmpty()) { activeTransactions.notifyAll(); } } }

String org.objectweb.cjdbc.controller.backend.DatabaseBackend.toString (   )

String description Returns: a string description of the backend. Definition at line 1766 of file DatabaseBackend.java. Referenced by org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.getXml(), org.objectweb.cjdbc.controller.requestmanager.RequestManager.getXml(), and org.objectweb.cjdbc.controller.loadbalancer.paralleldb.ParallelDB.getXmlImpl(). { return "Backend: Name[" + this.name + "] State[" + this.state + "] JDBCConnected[" + isJDBCConnected() + "] ActiveTransactions[" + activeTransactions.size() + "] PendingRequests[" + pendingRequests.size() + "]"; }

void org.objectweb.cjdbc.controller.backend.DatabaseBackend.waitForAllTransactionsToComplete (   )

This method waits until all currently open transactions on this backend complete. If no transaction are currently running on this backend, this method immediately returns. Definition at line 641 of file DatabaseBackend.java. Referenced by org.objectweb.cjdbc.controller.requestmanager.RequestManager.disableBackendsForCheckpoint(). { synchronized (activeTransactions) { if (activeTransactions.isEmpty()) return; else try { activeTransactions.wait(); } catch (InterruptedException ignore) { } } }

---

Member Data Documentation

transient Trace org.objectweb.cjdbc.controller.backend.DatabaseBackend.logger [protected]

Logger instance. Definition at line 131 of file DatabaseBackend.java. Referenced by org.objectweb.cjdbc.controller.backend.DatabaseBackend.DatabaseBackend().

---

The documentation for this class was generated from the following file:

• DatabaseBackend.java

---