net.sf.hajdbc.sync

Class SynchronizationContextImpl<D>

java.lang.Object

net.sf.hajdbc.sync.SynchronizationContextImpl<D>

Type Parameters:

D - Driver or DataSource

All Implemented Interfaces:

SynchronizationContext<D>

public class SynchronizationContextImpl<D>
extends java.lang.Object
implements SynchronizationContext<D>

Author:

Paul Ferraro

Constructor Summary

Constructors

Constructor and Description
SynchronizationContextImpl(DatabaseCluster<D> cluster, Database<D> database)

Method Summary

Modifier and Type	Method and Description
void	close() Closes any open database connections and shuts down the executor service.
java.util.Set<Database<D>>	getActiveDatabaseSet() Returns a snapshot of the activate databases in the cluster at the time synchronization started.
java.sql.Connection	getConnection(Database<D> database) Returns a connection to the specified database.
Dialect	getDialect() Returns the dialect of the cluster.
java.util.concurrent.ExecutorService	getExecutor() An executor service for executing tasks asynchronously.
Database<D>	getSourceDatabase() Returns the database from which to synchronize.
DatabaseProperties	getSourceDatabaseProperties() Returns a cache of database meta data for the source database.
Database<D>	getTargetDatabase() Returns the database to synchronize.
DatabaseProperties	getTargetDatabaseProperties() Returns a cache of database meta data for the target database.

Methods inherited from class java.lang.Object

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

Constructor Detail

SynchronizationContextImpl

public SynchronizationContextImpl(DatabaseCluster<D> cluster,
                                  Database<D> database)
                           throws java.sql.SQLException

Parameters:

cluster -

database -

Throws:

java.sql.SQLException

Method Detail

getConnection

public java.sql.Connection getConnection(Database<D> database)
                                  throws java.sql.SQLException

Description copied from interface: SynchronizationContext

Returns a connection to the specified database.

Specified by:

getConnection in interface SynchronizationContext<D>

Parameters:

database - a database to which to connect

Returns:

a database connection

Throws:

java.sql.SQLException - if connection could not be obtained

See Also:

SynchronizationContext.getConnection(net.sf.hajdbc.Database)

getSourceDatabase

public Database<D> getSourceDatabase()

Description copied from interface: SynchronizationContext

Returns the database from which to synchronize.

Specified by:

getSourceDatabase in interface SynchronizationContext<D>

Returns:

a database

See Also:

SynchronizationContext.getSourceDatabase()

getTargetDatabase

public Database<D> getTargetDatabase()

Description copied from interface: SynchronizationContext

Returns the database to synchronize.

Specified by:

getTargetDatabase in interface SynchronizationContext<D>

Returns:

a database

See Also:

SynchronizationContext.getTargetDatabase()

getActiveDatabaseSet

public java.util.Set<Database<D>> getActiveDatabaseSet()

Description copied from interface: SynchronizationContext

Returns a snapshot of the activate databases in the cluster at the time synchronization started.

Specified by:

getActiveDatabaseSet in interface SynchronizationContext<D>

Returns:

a collection of databases

See Also:

SynchronizationContext.getActiveDatabaseSet()

getSourceDatabaseProperties

public DatabaseProperties getSourceDatabaseProperties()

Description copied from interface: SynchronizationContext

Returns a cache of database meta data for the source database.

Specified by:

getSourceDatabaseProperties in interface SynchronizationContext<D>

Returns:

a cache of database meta data

See Also:

SynchronizationContext.getSourceDatabaseProperties()

getTargetDatabaseProperties

public DatabaseProperties getTargetDatabaseProperties()

Description copied from interface: SynchronizationContext

Returns a cache of database meta data for the target database.

Specified by:

getTargetDatabaseProperties in interface SynchronizationContext<D>

Returns:

a cache of database meta data

See Also:

SynchronizationContext.getTargetDatabaseProperties()

getDialect

public Dialect getDialect()

Description copied from interface: SynchronizationContext

Returns the dialect of the cluster.

Specified by:

getDialect in interface SynchronizationContext<D>

Returns:

a dialect

See Also:

SynchronizationContext.getDialect()

getExecutor

public java.util.concurrent.ExecutorService getExecutor()

Description copied from interface: SynchronizationContext

An executor service for executing tasks asynchronously.

Specified by:

getExecutor in interface SynchronizationContext<D>

Returns:

an executor service

See Also:

SynchronizationContext.getExecutor()

close

public void close()

Description copied from interface: SynchronizationContext

Closes any open database connections and shuts down the executor service.

Specified by:

close in interface SynchronizationContext<D>

See Also:

SynchronizationContext.close()