net.sf.hajdbc.sql

Class AbstractDatabaseClusterConfiguration<Z,D extends Database<Z>>

java.lang.Object

net.sf.hajdbc.sql.AbstractDatabaseClusterConfiguration<Z,D>

All Implemented Interfaces:

Serializable, DatabaseClusterConfiguration<Z,D>

Direct Known Subclasses:

ConnectionPoolDataSourceDatabaseClusterConfiguration, DataSourceDatabaseClusterConfiguration, DriverDatabaseClusterConfiguration, XADataSourceDatabaseClusterConfiguration

public abstract class AbstractDatabaseClusterConfiguration<Z,D extends Database<Z>>
extends Object
implements DatabaseClusterConfiguration<Z,D>

Author:

Paul Ferraro

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	AbstractDatabaseClusterConfiguration.NestedConfiguration<Z,D extends Database<Z>>
protected static class	AbstractDatabaseClusterConfiguration.Property

Constructor Summary

Constructors

Constructor and Description
AbstractDatabaseClusterConfiguration()

Method Summary

Methods

Modifier and Type	Method and Description
CronExpression	getAutoActivationExpression()
BalancerFactory	getBalancerFactory() Returns the Balancer implementation used by this database cluster.
DatabaseFactory<Z,D>	getDatabaseFactory()
ConcurrentMap<String,D>	getDatabaseMap() Returns the databases of this cluster indexed by identifier
DatabaseMetaDataCacheFactory	getDatabaseMetaDataCacheFactory() Returns a DatabaseMetaData cache.
DecoderFactory	getDecoderFactory()
String	getDefaultSynchronizationStrategy()
DialectFactory	getDialectFactory() Returns a dialect capable of returning database vendor specific values.
CommandDispatcherFactory	getDispatcherFactory()
DurabilityFactory	getDurabilityFactory()
ExecutorServiceProvider	getExecutorProvider()
CronExpression	getFailureDetectionExpression()
InputSinkProvider	getInputSinkProvider()
LockManagerFactory	getLockManagerFactory()
MBeanRegistrar<Z,D>	getMBeanRegistrar()
protected abstract AbstractDatabaseClusterConfiguration.NestedConfiguration<Z,D>	getNestedConfiguration()
StateManagerFactory	getStateManagerFactory() Returns a StateManager for persisting database cluster state.
Map<String,SynchronizationStrategy>	getSynchronizationStrategyMap()
ThreadFactory	getThreadFactory()
TransactionIdentifierFactory<? extends Object>	getTransactionIdentifierFactory()
TransactionMode	getTransactionMode()
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	isEmptyClusterAllowed()
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	setAutoActivationExpression(CronExpression expression)
void	setBalancerFactory(BalancerFactory factory)
void	setCodecFactory(DecoderFactory factory)
void	setCurrentDateEvaluationEnabled(boolean enabled)
void	setCurrentTimeEvaluationEnabled(boolean enabled)
void	setCurrentTimestampEvaluationEnabled(boolean enabled)
void	setDatabaseMetaDataCacheFactory(DatabaseMetaDataCacheFactory factory)
void	setDatabases(Collection<D> databases)
void	setDefaultSynchronizationStrategy(String strategy)
void	setDialectFactory(DialectFactory factory)
void	setDispatcherFactory(CommandDispatcherFactory factory)
void	setDurabilityFactory(DurabilityFactory factory)
void	setEmptyClusterAllowed(boolean emptyClusterAllowed)
void	setExecutorProvider(ExecutorServiceProvider provider)
void	setFailureDetectionExpression(CronExpression expression)
void	setIdentityColumnDetectionEnabled(boolean enabled)
void	setInputSinkFactoryProvider(InputSinkProvider provider)
void	setLockManagerFactory(LockManagerFactory factory)
void	setMBeanRegistrar(MBeanRegistrar<Z,D> registrar)
void	setRandEvaluationEnabled(boolean enabled)
void	setSequenceDetectionEnabled(boolean enabled)
void	setStateManagerFactory(StateManagerFactory factory)
void	setSynchronizationStrategyMap(Map<String,SynchronizationStrategy> strategies)
void	setThreadFactory(ThreadFactory factory)
void	setTransactionMode(TransactionMode mode)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

AbstractDatabaseClusterConfiguration

public AbstractDatabaseClusterConfiguration()

Method Detail

getNestedConfiguration

protected abstract AbstractDatabaseClusterConfiguration.NestedConfiguration<Z,D> getNestedConfiguration()

getDatabaseFactory

public DatabaseFactory<Z,D> getDatabaseFactory()

Specified by:

getDatabaseFactory in interface DatabaseClusterConfiguration<Z,D extends Database<Z>>

getAutoActivationExpression

public CronExpression getAutoActivationExpression()

Specified by:

getAutoActivationExpression in interface DatabaseClusterConfiguration<Z,D extends Database<Z>>

See Also:

DatabaseClusterConfiguration.getAutoActivationExpression()

setAutoActivationExpression

public void setAutoActivationExpression(CronExpression expression)

getBalancerFactory

public BalancerFactory getBalancerFactory()

Returns the Balancer implementation used by this database cluster.

Specified by:

getBalancerFactory in interface DatabaseClusterConfiguration<Z,D extends Database<Z>>

Returns:

an implementation of Balancer

See Also:

DatabaseClusterConfiguration.getBalancerFactory()

setBalancerFactory

public void setBalancerFactory(BalancerFactory factory)

getDispatcherFactory

public CommandDispatcherFactory getDispatcherFactory()

Specified by:

getDispatcherFactory in interface DatabaseClusterConfiguration<Z,D extends Database<Z>>

See Also:

DatabaseClusterConfiguration.getDispatcherFactory()

setDispatcherFactory

public void setDispatcherFactory(CommandDispatcherFactory factory)

getDatabaseMap

public ConcurrentMap<String,D> getDatabaseMap()

Returns the databases of this cluster indexed by identifier

Specified by:

getDatabaseMap in interface DatabaseClusterConfiguration<Z,D extends Database<Z>>

Returns:

a map of databases

See Also:

DatabaseClusterConfiguration.getDatabaseMap()

setDatabases

public void setDatabases(Collection<D> databases)

getDatabaseMetaDataCacheFactory

public DatabaseMetaDataCacheFactory getDatabaseMetaDataCacheFactory()

Returns a DatabaseMetaData cache.

Specified by:

getDatabaseMetaDataCacheFactory in interface DatabaseClusterConfiguration<Z,D extends Database<Z>>

Returns:

a DatabaseMetaDataCache implementation

See Also:

DatabaseClusterConfiguration.getDatabaseMetaDataCacheFactory()

setDatabaseMetaDataCacheFactory

public void setDatabaseMetaDataCacheFactory(DatabaseMetaDataCacheFactory factory)

getDefaultSynchronizationStrategy

public String getDefaultSynchronizationStrategy()

Specified by:

getDefaultSynchronizationStrategy in interface DatabaseClusterConfiguration<Z,D extends Database<Z>>

See Also:

DatabaseClusterConfiguration.getDefaultSynchronizationStrategy()

setDefaultSynchronizationStrategy

public void setDefaultSynchronizationStrategy(String strategy)

getDialectFactory

public DialectFactory getDialectFactory()

Returns a dialect capable of returning database vendor specific values.

Specified by:

getDialectFactory in interface DatabaseClusterConfiguration<Z,D extends Database<Z>>

Returns:

an implementation of Dialect

See Also:

DatabaseClusterConfiguration.getDialectFactory()

setDialectFactory

public void setDialectFactory(DialectFactory factory)

getDurabilityFactory

public DurabilityFactory getDurabilityFactory()

Specified by:

getDurabilityFactory in interface DatabaseClusterConfiguration<Z,D extends Database<Z>>

See Also:

DatabaseClusterConfiguration.getDurabilityFactory()

setDurabilityFactory

public void setDurabilityFactory(DurabilityFactory factory)

getExecutorProvider

public ExecutorServiceProvider getExecutorProvider()

Specified by:

getExecutorProvider in interface DatabaseClusterConfiguration<Z,D extends Database<Z>>

See Also:

DatabaseClusterConfiguration.getExecutorProvider()

setExecutorProvider

public void setExecutorProvider(ExecutorServiceProvider provider)

getThreadFactory

public ThreadFactory getThreadFactory()

Specified by:

getThreadFactory in interface DatabaseClusterConfiguration<Z,D extends Database<Z>>

See Also:

DatabaseClusterConfiguration.getThreadFactory()

setThreadFactory

public void setThreadFactory(ThreadFactory factory)

getDecoderFactory

public DecoderFactory getDecoderFactory()

Specified by:

getDecoderFactory in interface DatabaseClusterConfiguration<Z,D extends Database<Z>>

See Also:

DatabaseClusterConfiguration.getDecoderFactory()

setCodecFactory

public void setCodecFactory(DecoderFactory factory)

getFailureDetectionExpression

public CronExpression getFailureDetectionExpression()

Specified by:

getFailureDetectionExpression in interface DatabaseClusterConfiguration<Z,D extends Database<Z>>

See Also:

DatabaseClusterConfiguration.getFailureDetectionExpression()

setFailureDetectionExpression

public void setFailureDetectionExpression(CronExpression expression)

getStateManagerFactory

public StateManagerFactory getStateManagerFactory()

Returns a StateManager for persisting database cluster state.

Specified by:

getStateManagerFactory in interface DatabaseClusterConfiguration<Z,D extends Database<Z>>

Returns:

a StateManager implementation

See Also:

DatabaseClusterConfiguration.getStateManagerFactory()

setStateManagerFactory

public void setStateManagerFactory(StateManagerFactory factory)

getLockManagerFactory

public LockManagerFactory getLockManagerFactory()

Specified by:

getLockManagerFactory in interface DatabaseClusterConfiguration<Z,D extends Database<Z>>

setLockManagerFactory

public void setLockManagerFactory(LockManagerFactory factory)

getSynchronizationStrategyMap

public Map<String,SynchronizationStrategy> getSynchronizationStrategyMap()

Specified by:

getSynchronizationStrategyMap in interface DatabaseClusterConfiguration<Z,D extends Database<Z>>

See Also:

DatabaseClusterConfiguration.getSynchronizationStrategyMap()

setSynchronizationStrategyMap

public void setSynchronizationStrategyMap(Map<String,SynchronizationStrategy> strategies)

getTransactionMode

public TransactionMode getTransactionMode()

Specified by:

getTransactionMode in interface DatabaseClusterConfiguration<Z,D extends Database<Z>>

See Also:

DatabaseClusterConfiguration.getTransactionMode()

setTransactionMode

public void setTransactionMode(TransactionMode mode)

getInputSinkProvider

public InputSinkProvider getInputSinkProvider()

Specified by:

getInputSinkProvider in interface DatabaseClusterConfiguration<Z,D extends Database<Z>>

setInputSinkFactoryProvider

public void setInputSinkFactoryProvider(InputSinkProvider provider)

isCurrentDateEvaluationEnabled

public boolean isCurrentDateEvaluationEnabled()

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

Specified by:

isCurrentDateEvaluationEnabled in interface DatabaseClusterConfiguration<Z,D extends Database<Z>>

Returns:

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

See Also:

DatabaseClusterConfiguration.isCurrentDateEvaluationEnabled()

setCurrentDateEvaluationEnabled

public void setCurrentDateEvaluationEnabled(boolean enabled)

isCurrentTimeEvaluationEnabled

public boolean isCurrentTimeEvaluationEnabled()

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

Specified by:

isCurrentTimeEvaluationEnabled in interface DatabaseClusterConfiguration<Z,D extends Database<Z>>

Returns:

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

See Also:

DatabaseClusterConfiguration.isCurrentTimeEvaluationEnabled()

setCurrentTimeEvaluationEnabled

public void setCurrentTimeEvaluationEnabled(boolean enabled)

isCurrentTimestampEvaluationEnabled

public boolean isCurrentTimestampEvaluationEnabled()

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

Specified by:

isCurrentTimestampEvaluationEnabled in interface DatabaseClusterConfiguration<Z,D extends Database<Z>>

Returns:

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

See Also:

DatabaseClusterConfiguration.isCurrentTimestampEvaluationEnabled()

setCurrentTimestampEvaluationEnabled

public void setCurrentTimestampEvaluationEnabled(boolean enabled)

isIdentityColumnDetectionEnabled

public boolean isIdentityColumnDetectionEnabled()

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

Specified by:

isIdentityColumnDetectionEnabled in interface DatabaseClusterConfiguration<Z,D extends Database<Z>>

Returns:

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

See Also:

DatabaseClusterConfiguration.isIdentityColumnDetectionEnabled()

setIdentityColumnDetectionEnabled

public void setIdentityColumnDetectionEnabled(boolean enabled)

isRandEvaluationEnabled

public boolean isRandEvaluationEnabled()

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

Specified by:

isRandEvaluationEnabled in interface DatabaseClusterConfiguration<Z,D extends Database<Z>>

Returns:

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

See Also:

DatabaseClusterConfiguration.isRandEvaluationEnabled()

setRandEvaluationEnabled

public void setRandEvaluationEnabled(boolean enabled)

isSequenceDetectionEnabled

public boolean isSequenceDetectionEnabled()

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

Specified by:

isSequenceDetectionEnabled in interface DatabaseClusterConfiguration<Z,D extends Database<Z>>

Returns:

true, if sequence detection is enabled, false otherwise.

See Also:

DatabaseClusterConfiguration.isSequenceDetectionEnabled()

setSequenceDetectionEnabled

public void setSequenceDetectionEnabled(boolean enabled)

getMBeanRegistrar

public MBeanRegistrar<Z,D> getMBeanRegistrar()

Specified by:

getMBeanRegistrar in interface DatabaseClusterConfiguration<Z,D extends Database<Z>>

See Also:

DatabaseClusterConfiguration.getMBeanRegistrar()

setMBeanRegistrar

public void setMBeanRegistrar(MBeanRegistrar<Z,D> registrar)

isEmptyClusterAllowed

public boolean isEmptyClusterAllowed()

Specified by:

isEmptyClusterAllowed in interface DatabaseClusterConfiguration<Z,D extends Database<Z>>

See Also:

DatabaseClusterConfiguration.isEmptyClusterAllowed()

setEmptyClusterAllowed

public void setEmptyClusterAllowed(boolean emptyClusterAllowed)

getTransactionIdentifierFactory

public TransactionIdentifierFactory<? extends Object> getTransactionIdentifierFactory()

Specified by:

getTransactionIdentifierFactory in interface DatabaseClusterConfiguration<Z,D extends Database<Z>>

See Also:

DatabaseClusterConfiguration.getTransactionIdentifierFactory()