net.sf.hajdbc.sync

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

java.lang.Object

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

Type Parameters:

D - Driver or DataSource

All Implemented Interfaces:

SynchronizationContext<Z,D>

public class SynchronizationContextImpl<Z,D extends Database<Z>>
extends Object
implements SynchronizationContext<Z,D>

Author:

Paul Ferraro

Constructor Summary

Constructors

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

Method Summary

Methods

Modifier and Type	Method and Description
void	close() Closes any open database connections and shuts down the executor service.
Set<D>	getActiveDatabaseSet() Returns a snapshot of the activate databases in the cluster at the time synchronization started.
Connection	getConnection(D database) Returns a connection to the specified database.
Decoder	getDecoder()
Dialect	getDialect() Returns the dialect of the cluster.
ExecutorService	getExecutor() An executor service for executing tasks asynchronously.
D	getSourceDatabase() Returns the database from which to synchronize.
DatabaseProperties	getSourceDatabaseProperties() Returns a cache of database meta data for the source database.
SynchronizationSupport	getSynchronizationSupport()
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<Z,D> cluster,
                          D database)
                           throws SQLException

Parameters:

cluster -

database -

Throws:

SQLException

Method Detail

getConnection

public Connection getConnection(D database)
                         throws SQLException

Description copied from interface: SynchronizationContext

Returns a connection to the specified database.

Specified by:

getConnection in interface SynchronizationContext<Z,D extends Database<Z>>

Parameters:

database - a database to which to connect

Returns:

a database connection

Throws:

SQLException - if connection could not be obtained

See Also:

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

getSourceDatabase

public D getSourceDatabase()

Description copied from interface: SynchronizationContext

Returns the database from which to synchronize.

Specified by:

getSourceDatabase in interface SynchronizationContext<Z,D extends Database<Z>>

Returns:

a database

See Also:

SynchronizationContext.getSourceDatabase()

getTargetDatabase

public D getTargetDatabase()

Description copied from interface: SynchronizationContext

Returns the database to synchronize.

Specified by:

getTargetDatabase in interface SynchronizationContext<Z,D extends Database<Z>>

Returns:

a database

See Also:

SynchronizationContext.getTargetDatabase()

getActiveDatabaseSet

public Set<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<Z,D extends Database<Z>>

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<Z,D extends Database<Z>>

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<Z,D extends Database<Z>>

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<Z,D extends Database<Z>>

Returns:

a dialect

See Also:

SynchronizationContext.getDialect()

getDecoder

public Decoder getDecoder()

Specified by:

getDecoder in interface SynchronizationContext<Z,D extends Database<Z>>

See Also:

SynchronizationContext.getDecoder()

getExecutor

public ExecutorService getExecutor()

Description copied from interface: SynchronizationContext

An executor service for executing tasks asynchronously.

Specified by:

getExecutor in interface SynchronizationContext<Z,D extends Database<Z>>

Returns:

an executor service

See Also:

SynchronizationContext.getExecutor()

getSynchronizationSupport

public SynchronizationSupport getSynchronizationSupport()

Specified by:

getSynchronizationSupport in interface SynchronizationContext<Z,D extends Database<Z>>

See Also:

SynchronizationContext.getSynchronizationSupport()

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<Z,D extends Database<Z>>

See Also:

SynchronizationContext.close()