net.sf.hajdbc

Interface DatabaseCluster<Z,D extends Database<Z>>

Type Parameters:

Z - either java.sql.Driver or javax.sql.DataSource

D - database implementation

All Superinterfaces:

Lifecycle

All Known Implementing Classes:

DatabaseClusterImpl

public interface DatabaseCluster<Z,D extends Database<Z>>
extends Lifecycle

Author:

Paul Ferraro

Method Summary

Methods

Modifier and Type	Method and Description
boolean	activate(D database, StateManager manager) Activates the specified database
void	addConfigurationListener(DatabaseClusterConfigurationListener<Z,D> listener)
void	addListener(DatabaseClusterListener listener)
void	addSynchronizationListener(SynchronizationListener listener)
boolean	deactivate(D database, StateManager manager) Deactivates the specified database
Balancer<Z,D>	getBalancer() Returns the Balancer implementation used by this database cluster.
D	getDatabase(String id) Returns the database identified by the specified id
DatabaseMetaDataCache<Z,D>	getDatabaseMetaDataCache() Returns a DatabaseMetaData cache.
Decoder	getDecoder()
Dialect	getDialect() Returns a dialect capable of returning database vendor specific values.
Durability<Z,D>	getDurability()
ExecutorService	getExecutor()
String	getId() Returns the identifier of this cluster.
InputSinkStrategy<? extends Object>	getInputSinkStrategy()
LockManager	getLockManager() Returns a LockManager capable of acquiring named read/write locks on the specific objects in this database cluster.
StateManager	getStateManager() Returns a StateManager for persisting database cluster state.
ThreadFactory	getThreadFactory()
TransactionIdentifierFactory<? extends Object>	getTransactionIdentifierFactory()
TransactionMode	getTransactionMode()
boolean	isActive() Indicates whether or not this cluster is active, i.e.
boolean	isCurrentDateEvaluationEnabled() Indicates whether or not non-deterministic CURRENT_DATE SQL functions will be evaluated to deterministic static values.
boolean	isCurrentTimeEvaluationEnabled() Indicates whether or not non-deterministic CURRENT_TIME functions will be evaluated to deterministic static values.
boolean	isCurrentTimestampEvaluationEnabled() Indicates whether or not non-deterministic CURRENT_TIMESTAMP functions will be evaluated to deterministic static values.
boolean	isIdentityColumnDetectionEnabled() Indicates whether or not identity column detection is enabled for this cluster.
boolean	isRandEvaluationEnabled() Indicates whether or not non-deterministic RAND() functions will be replaced by evaluated to static values.
boolean	isSequenceDetectionEnabled() Indicates whether or not sequence detection is enabled for this cluster.
void	removeConfigurationListener(DatabaseClusterConfigurationListener<Z,D> listener)
void	removeListener(DatabaseClusterListener listener)
void	removeSynchronizationListener(SynchronizationListener listener)

Methods inherited from interface net.sf.hajdbc.Lifecycle

start, stop

Method Detail

getId

String getId()

Returns the identifier of this cluster.

Returns:

an identifier

activate

boolean activate(D database,
               StateManager manager)

Activates the specified database

Parameters:

database - a database descriptor

manager - a state manager

Returns:

true, if the database was activated, false it was already active

deactivate

boolean deactivate(D database,
                 StateManager manager)

Deactivates the specified database

Parameters:

database - a database descriptor

manager - a state manager

Returns:

true, if the database was deactivated, false it was already inactive

getDatabase

D getDatabase(String id)

Returns the database identified by the specified id

Parameters:

id - a database identifier

Returns:

a database descriptor

Throws:

IllegalArgumentException - if no database exists with the specified identifier

getBalancer

Balancer<Z,D> getBalancer()

Returns the Balancer implementation used by this database cluster.

Returns:

an implementation of Balancer

getTransactionMode

TransactionMode getTransactionMode()

getExecutor

ExecutorService getExecutor()

getDialect

Dialect getDialect()

Returns a dialect capable of returning database vendor specific values.

Returns:

an implementation of Dialect

getLockManager

LockManager getLockManager()

Returns a LockManager capable of acquiring named read/write locks on the specific objects in this database cluster.

Returns:

a LockManager implementation

getStateManager

StateManager getStateManager()

Returns a StateManager for persisting database cluster state.

Returns:

a StateManager implementation

getDatabaseMetaDataCache

DatabaseMetaDataCache<Z,D> getDatabaseMetaDataCache()

Returns a DatabaseMetaData cache.

Returns:

a DatabaseMetaDataCache implementation

isSequenceDetectionEnabled

boolean isSequenceDetectionEnabled()

Indicates whether or not sequence detection is enabled for this cluster.

Returns:

true, if sequence detection is enabled, false otherwise.

isIdentityColumnDetectionEnabled

boolean isIdentityColumnDetectionEnabled()

Indicates whether or not identity column detection is enabled for this cluster.

Returns:

true, if identity column detection is enabled, false otherwise.

isCurrentDateEvaluationEnabled

boolean isCurrentDateEvaluationEnabled()

Indicates whether or not non-deterministic CURRENT_DATE SQL functions will be evaluated to deterministic static values.

Returns:

true, if temporal SQL replacement is enabled, false otherwise.

isCurrentTimeEvaluationEnabled

boolean isCurrentTimeEvaluationEnabled()

Indicates whether or not non-deterministic CURRENT_TIME functions will be evaluated to deterministic static values.

Returns:

true, if temporal SQL replacement is enabled, false otherwise.

isCurrentTimestampEvaluationEnabled

boolean isCurrentTimestampEvaluationEnabled()

Indicates whether or not non-deterministic CURRENT_TIMESTAMP functions will be evaluated to deterministic static values.

Returns:

true, if temporal SQL replacement is enabled, false otherwise.

isRandEvaluationEnabled

boolean isRandEvaluationEnabled()

Indicates whether or not non-deterministic RAND() functions will be replaced by evaluated to static values.

Returns:

true, if temporal SQL replacement is enabled, false otherwise.

isActive

boolean isActive()

Indicates whether or not this cluster is active, i.e. started, but not yet stopped.

Returns:

true, if this cluster is active, false otherwise.

addListener

void addListener(DatabaseClusterListener listener)

removeListener

void removeListener(DatabaseClusterListener listener)

addSynchronizationListener

void addSynchronizationListener(SynchronizationListener listener)

removeSynchronizationListener

void removeSynchronizationListener(SynchronizationListener listener)

addConfigurationListener

void addConfigurationListener(DatabaseClusterConfigurationListener<Z,D> listener)

removeConfigurationListener

void removeConfigurationListener(DatabaseClusterConfigurationListener<Z,D> listener)

getDurability

Durability<Z,D> getDurability()

getThreadFactory

ThreadFactory getThreadFactory()

getDecoder

Decoder getDecoder()

getTransactionIdentifierFactory

TransactionIdentifierFactory<? extends Object> getTransactionIdentifierFactory()

getInputSinkStrategy

InputSinkStrategy<? extends Object> getInputSinkStrategy()