| Method Summary |
|
| public void | abort(long transactionId, boolean logAbort, boolean forceAbort)
Abort a transaction that has been started but in which no query was
executed. |
| final public void | acquireReadLockBackendLists()
Acquires a read lock on the backend lists (both enabled and disabled
backends). |
| protected void | addAdminOperation(AbstractAdminOperation operation)
|
| public void | addBackend(DatabaseBackend db)
Add a backend to this virtual database. |
| public void | addBackend(DatabaseBackend db, boolean checkForCompliance)
Add a backend to this virtual database. |
| public void | addVirtualDatabaseWorkerThread(VirtualDatabaseWorkerThread thread)
Add a VirtualDatabaseWorkerThread to the list of active threads. |
| public void | backupBackend(String backendName, String login, String password, String dumpName, String backuperName, String path, boolean force, ArrayList tables)
|
| public long | begin(String login, boolean isPersistentConnection, long persistentConnectionId)
Begins a new transaction and returns the corresponding transaction
identifier. |
| public String | buildCheckpointName(String event)
Returns a cluster-wide unique checkpoint name. |
| protected ExecuteResult | callableStatementExecute(StoredProcedure proc)
Execute a call to CallableStatement.execute() and returns a suite of
updateCount and/or ResultSets. |
| protected ControllerResultSet | callableStatementExecuteQuery(StoredProcedure proc)
Call a stored procedure that returns a ResultSet. |
| protected ExecuteUpdateResult | callableStatementExecuteUpdate(StoredProcedure proc)
Call a stored procedure that performs an update. |
| public boolean | checkAdminAuthentication(String adminLogin, String adminPassword)
Checks if a given admin login/password is ok.
Parameters:
adminLogin - admin user login
Parameters:
adminPassword - admin user password true if the login/password is known from theAuthenticationManager. |
| public void | checkAndAddVirtualDatabaseUser(VirtualDatabaseUser vdbUser)
Adds a new vdb user. |
| public boolean | checkUserAuthentication(String virtualLogin, String virtualPassword)
Checks if a given virtual login/password is ok.
Parameters:
virtualLogin - the virtual user login
Parameters:
virtualPassword - the virtual user password true if the login/password is known from theAuthenticationManager. |
| public void | cleanMonitoringData()
|
| public void | clearConnectionWarnings(long connId)
Forwards call to clearWarnings() to the given persistent connections on
each backend. |
| public void | closePersistentConnection(String login, long persistentConnectionId)
Close the given persistent connection. |
| public void | commit(long transactionId, boolean logCommit, boolean emptyTransaction)
Commits a transaction given its id. |
| public void | copyDump(String dumpName, String remoteControllerName)
|
| public void | copyLogFromCheckpoint(String dumpName, String controllerName)
|
| protected void | decreaseCurrentNbOfThread()
Substract one to currentNbOfThreads. |
| protected void | decreaseIdleThread()
Remove an idle thread. |
| public void | deleteDump(String dumpName, boolean keepsFile)
Delete the dump entry associated to the dumpName.
If keepsFile is false, the dump file is also removed from
the file system. |
| public void | deleteLogUpToCheckpoint(String checkpointName)
|
| public void | disableAllBackends(boolean forceEnable)
Prepare this virtual database for shutdown. |
| public void | disableAllBackendsWithCheckpoint(String checkpoint)
|
| public void | disableBackendWithCheckpoint(String backendName)
|
| public VirtualDatabaseStaticMetaData | doGetStaticMetaData()
|
| public void | enableAllBackends()
Enable all the backends without any check. |
| public void | enableAllBackendsFromCheckpoint()
|
| public void | enableBackendFromCheckpoint(String backendName, String checkpointName)
Enable the given backend from the given checkpoint. |
| public void | enableBackendFromCheckpoint(String backendName)
|
| public boolean | enforceTableExistenceIntoSchema()
Indicates if the virtual database requires that tables referenced in a
query exist into the schema. |
| public boolean | equals(Object other)
Two virtual databases are equal if they have the same name and group. |
| public void | failoverForPersistentConnection(long persistentConnectionId)
|
| public void | failoverForTransaction(long currentTid)
|
| public void | forceDisableBackend(String backendName)
|
| public void | forceEnableAllBackendsFromCheckpoint(String checkpoint)
Prepare this virtual database for startup. |
| public void | forceEnableBackend(String backendName)
|
| public ArrayList | getActiveThreads()
Returns the activeThreads list. |
| public ArrayList | getAllBackendNames()
|
| public DatabaseBackend | getAndCheckBackend(String backendName, int testEnable)
Find the DatabaseBackend corresponding to the given backend name and check
if it is possible to disable this backend. |
| public AuthenticationManager | getAuthenticationManager()
Returns the authentication manager of this virtual database. |
| public DumpInfo[] | getAvailableDumps()
|
| public String | getBackendInformation(String backendName)
|
| public String | getBackendSchema(String backendName)
|
| public String | getBackendState(String backendName)
|
| public BackendStatistics | getBackendStatistics(String backendName)
|
| public ArrayList | getBackends()
|
| public String[] | getBackuperNames()
|
| public SQLWarning | getConnectionWarnings(long connId)
|
| public int | getCurrentNbOfThreads()
|
| public String | getDatabaseName()
Gets the virtual database name to be used by the client (Sequoia driver)
This method should be used for local references only (it is faster). |
| public String | getDatabaseProductName()
|
| public DatabaseSchema | getDatabaseSchemaFromActiveBackends()
Get the current database schema from merging the schemas of all active
backends. |
| public DatabaseSchema | getDatabaseSchemaFromActiveBackendsAndRefreshDatabaseProductNames()
Get the current database schema from merging the schemas of all active
backends. |
| protected String | getDistributionXml()
Get the XML dump of the Distribution element if any. |
| public String | getDumpFormatForBackuper(String backuperName)
|
| public VirtualDatabaseDynamicMetaData | getDynamicMetaData()
|
| DatabaseBackend | getFirstAvailableBackend()
|
| public int | getIdleThreads()
Returns the number of idle worker threads. |
| final public Trace | getLogger()
Returns the logger value. |
| public int | getMaxNbOfConnections()
Returns the maxNbOfConnections. |
| public int | getMaxNbOfThreads()
Returns the maxNbOfThreads. |
| public long | getMaxThreadIdleTime()
Returns the maxThreadIdleTime. |
| public int | getMinNbOfThreads()
Returns the minNbOfThreads. |
| public long | getNextConnectionId()
Return the next connection identifier (monotically increasing number). |
| public long | getNextRequestId()
Return the next request identifier (monotically increasing number). |
| protected int | getNumberOfEnabledBackends()
|
| public int | getNumberOfSavepointsInTransaction(long tId)
Returns the number of savepoints that are defined for a given transaction
by asking to the request manager. |
| public ArrayList | getPendingConnections()
Returns the pendingConnections. |
| public ControllerResultSet | getPreparedStatementGetMetaData(AbstractRequest request)
|
| public RequestManager | getRequestManager()
Gets the request manager associated to this database. |
| public SQLMonitoring | getSQLMonitor()
|
| public int | getSqlShortFormLength()
Return the sql short form length to use when reporting an error. |
| public VirtualDatabaseStaticMetaData | getStaticMetaData()
Get the whole static metadata for this virtual database. |
| public LinkedList | getTotalOrderQueue()
Returns the totalOrderQueue value. |
| public String | getVirtualDatabaseName()
|
| public VirtualDatabaseWorkerThread | getVirtualDatabaseWorkerThreadForPersistentConnection(long persistentConnectionId)
Return the VirtualDatabaseWorkerThread that is currently executing the
persistent connection identified by the provided id. |
| public VirtualDatabaseWorkerThread | getVirtualDatabaseWorkerThreadForTransaction(long transactionId)
Return the VirtualDatabaseWorkerThread that is currently executing the
transaction identified by the provided id. |
| public String | getXml()
|
| public boolean | hasPersistentConnection(long persistentConnectionId)
Returns true if the virtual database has opened the given persistent
connection. |
| public boolean | hasRecoveryLog()
|
| public boolean | hasResultCache()
|
| protected void | incrementCurrentNbOfThread()
Adds one to currentNbOfThreads. |
| protected void | incrementIdleThreadCount()
Method add an idle thread. |
| public void | initializeFromBackend(String databaseBackendName, boolean force)
|
| public boolean | isDistributed()
|
| public boolean | isDumpNameAvailable(String tentativeDumpName)
Checks if the dump name is available. |
| public boolean | isPoolConnectionThreads()
Returns the poolConnectionThreads. |
| public boolean | isRejectingNewTransaction()
|
| protected boolean | isResyncing()
Returns true if this vdb is resynching. |
| public boolean | isShuttingDown()
Return true if this database is shutting down. |
| public boolean | isValidUserForAllBackends(VirtualDatabaseUser vdbUser)
Checks if a vdb user is valid as a user for allbackends.
Parameters:
vdbUser - vdb user to be checked. |
| public void | openPersistentConnection(String login, long persistentConnectionId)
Open the given persistent connection. |
| public void | performAddVirtualDatabaseUser(VirtualDatabaseUser vdbUser)
Adds new vdb user and its corresponding connection managers. |
| public void | performRemoveVirtualDatabaseUser(VirtualDatabaseUser vdbUser)
Removes vdb user and its corresponding connection managers. |
| final public void | releaseReadLockBackendLists()
Releases the read lock on the backend lists (both enabled and disabled
backends). |
| public void | releaseSavepoint(long transactionId, String savepointName)
Releases a savepoint given its name from a transaction given its id. |
| protected boolean | removeAdminOperation(AbstractAdminOperation operation)
Remove a currently executing admin operation. |
| public void | removeBackend(String backend)
|
| public void | removeBackend(DatabaseBackend db)
Remove a backend from this virtual database. |
| public void | removeCheckpoint(String checkpointName)
|
| public void | replicateBackend(String backendName, String newBackendName, Map parameters)
|
| public void | restoreDumpOnBackend(String databaseBackendName, String login, String password, String dumpName, ArrayList tables)
|
| public String[][] | retrieveBackendsData()
|
| public void | rollback(long transactionId, boolean logRollback)
Rollbacks a transaction given its id. |
| public void | rollback(long transactionId, String savepointName)
|
| protected void | sendJmxNotification(String type, String message)
|
| public void | setAuthenticationManager(AuthenticationManager authenticationManager)
Sets the authentication manager for this virtual database. |
| public void | setBackendLastKnownCheckpoint(String backendName, String checkpoint)
|
| public void | setMaxNbOfConnections(int maxNbOfConnections)
Sets the maxNbOfConnections. |
| public void | setMaxNbOfThreads(int maxNbOfThreads)
Sets the maxNbOfThreads. |
| public void | setMaxThreadIdleTime(long maxThreadIdleTime)
Sets the maxThreadIdleTime. |
| public void | setMinNbOfThreads(int minNbOfThreads)
Sets the minNbOfThreads. |
| public void | setMonitoringToActive(boolean active)
|
| public void | setNotificationBroadcasterSupport(NotificationBroadcasterSupport notificationBroadcasterSupport)
Sets the NotificationBroadcasterSupport associated with the MBean managing
this virtual database. |
| public void | setPoolConnectionThreads(boolean poolConnectionThreads)
Sets the poolConnectionThreads. |
| public void | setRejectingNewTransaction(boolean canAcceptNewTransaction)
|
| public void | setRequestManager(RequestManager requestManager)
Sets a new request manager for this database. |
| public void | setSQLMonitor(SQLMonitoring sqlMonitor)
|
| public int | setSavepoint(long transactionId)
Sets a unnamed savepoint to a transaction given its id. |
| public void | setSavepoint(long transactionId, String name)
Sets a savepoint given its desired name to a transaction given its id. |
| public void | setShutdownCheckpoint()
Sets a checkpoint indicating that this vdb has shutdown. |
| public void | setShuttingDown(boolean shuttingDown)
|
| public void | setStaticDatabaseSchema(DatabaseSchema schema)
Sets a new static database schema for this database if no one exist or
merge the given schema to the existing one. |
| public void | shutdown(int level)
|
| protected ExecuteResult | statementExecute(AbstractRequest request)
Execute a request using Statement.execute(). |
| protected ControllerResultSet | statementExecuteQuery(SelectRequest request)
Performs a read request and returns the reply. |
| protected ExecuteUpdateResult | statementExecuteUpdate(AbstractWriteRequest request)
Performs a write request and returns the number of rows affected. |
| protected GeneratedKeysResult | statementExecuteUpdateWithKeys(AbstractWriteRequest request)
Performs a write request and returns the auto generated keys. |
| public void | storeBackendsInfo()
|
| public void | transferBackend(String backend, String controllerDestination)
|
| public void | transferDump(String dumpName, String remoteControllerName, boolean noCopy)
|
| public void | updateDumpPath(String dumpName, String newPath)
|
| final public boolean | useStaticResultSetMetaData()
Returns the useStaticResultSetMetaData value. |
| public ArrayList | viewAllClientNames()
|
| public String[] | viewBackendInformation(String backendName)
|
| public ArrayList | viewCheckpointNames()
|
| public String[] | viewControllerList()
|
| public Hashtable | viewGroupBackends()
|
| public String | viewOwningController()
|
