net.sf.hajdbc.state.sql

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

java.lang.Object

net.sf.hajdbc.state.sql.SQLStateManager<Z,D>

All Implemented Interfaces:

EventListener, DatabaseClusterListener, DurabilityListener, Lifecycle, ConnectionFactory, SerializedDurabilityListener, StateManager

public class SQLStateManager<Z,D extends Database<Z>>
extends Object
implements StateManager, ConnectionFactory, SerializedDurabilityListener

Author:

Paul Ferraro

Field Summary

Fields inherited from interface net.sf.hajdbc.state.StateManager

CLEAR_LOCAL_STATE

Constructor Summary

Constructors

Constructor and Description
SQLStateManager(DatabaseCluster<Z,D> cluster, DriverDatabase database, PoolFactory poolFactory)

Method Summary

Methods

Modifier and Type	Method and Description
void	activated(DatabaseEvent event) Triggered after database is successfully activated.
void	afterInvocation(byte[] transactionId, byte phase)
void	afterInvocation(InvocationEvent event)
void	afterInvoker(byte[] transactionId, byte phase, String databaseId, byte[] result)
void	afterInvoker(InvokerEvent event)
void	beforeInvocation(byte[] transactionId, byte phase, byte exceptionType)
void	beforeInvocation(InvocationEvent event)
void	beforeInvoker(byte[] transactionId, byte phase, String databaseId)
void	beforeInvoker(InvokerEvent event)
void	deactivated(DatabaseEvent event) Triggered after database is successfully deactivated.
Set<String>	getActiveDatabases()
Connection	getConnection()
boolean	isEnabled()
Map<InvocationEvent,Map<String,InvokerEvent>>	recover()
void	setActiveDatabases(Set<String> databases)
void	start() Called upon database cluster start.
void	stop() Called when database cluster is stopped.

Methods inherited from class java.lang.Object

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

Constructor Detail

SQLStateManager

public SQLStateManager(DatabaseCluster<Z,D> cluster,
               DriverDatabase database,
               PoolFactory poolFactory)

Method Detail

getActiveDatabases

public Set<String> getActiveDatabases()

Specified by:

getActiveDatabases in interface StateManager

See Also:

StateManager.getActiveDatabases()

setActiveDatabases

public void setActiveDatabases(Set<String> databases)

Specified by:

setActiveDatabases in interface StateManager

See Also:

StateManager.setActiveDatabases(java.util.Set)

activated

public void activated(DatabaseEvent event)

Triggered after database is successfully activated.

Specified by:

activated in interface DatabaseClusterListener

Parameters:

event - indicates the database that was activated

See Also:

DatabaseClusterListener.activated(net.sf.hajdbc.state.DatabaseEvent)

deactivated

public void deactivated(DatabaseEvent event)

Triggered after database is successfully deactivated.

Specified by:

deactivated in interface DatabaseClusterListener

Parameters:

event - indicates the database that was deactivated

See Also:

DatabaseClusterListener.deactivated(net.sf.hajdbc.state.DatabaseEvent)

beforeInvocation

public void beforeInvocation(byte[] transactionId,
                    byte phase,
                    byte exceptionType)

Specified by:

beforeInvocation in interface SerializedDurabilityListener

See Also:

SerializedDurabilityListener.beforeInvocation(byte[], byte, byte)

afterInvocation

public void afterInvocation(byte[] transactionId,
                   byte phase)

Specified by:

afterInvocation in interface SerializedDurabilityListener

See Also:

SerializedDurabilityListener.afterInvocation(byte[], byte)

beforeInvoker

public void beforeInvoker(byte[] transactionId,
                 byte phase,
                 String databaseId)

Specified by:

beforeInvoker in interface SerializedDurabilityListener

See Also:

SerializedDurabilityListener.beforeInvoker(byte[], byte, java.lang.String)

afterInvoker

public void afterInvoker(byte[] transactionId,
                byte phase,
                String databaseId,
                byte[] result)

Specified by:

afterInvoker in interface SerializedDurabilityListener

See Also:

SerializedDurabilityListener.afterInvoker(byte[], byte, java.lang.String, byte[])

beforeInvocation

public void beforeInvocation(InvocationEvent event)

Specified by:

beforeInvocation in interface DurabilityListener

See Also:

DurabilityListener.beforeInvocation(net.sf.hajdbc.durability.InvocationEvent)

afterInvocation

public void afterInvocation(InvocationEvent event)

Specified by:

afterInvocation in interface DurabilityListener

See Also:

DurabilityListener.afterInvocation(net.sf.hajdbc.durability.InvocationEvent)

recover

public Map<InvocationEvent,Map<String,InvokerEvent>> recover()

Specified by:

recover in interface StateManager

See Also:

StateManager.recover()

beforeInvoker

public void beforeInvoker(InvokerEvent event)

Specified by:

beforeInvoker in interface DurabilityListener

See Also:

DurabilityListener.beforeInvoker(net.sf.hajdbc.durability.InvokerEvent)

afterInvoker

public void afterInvoker(InvokerEvent event)

Specified by:

afterInvoker in interface DurabilityListener

See Also:

DurabilityListener.afterInvoker(net.sf.hajdbc.durability.InvokerEvent)

isEnabled

public boolean isEnabled()

Specified by:

isEnabled in interface StateManager

start

public void start()
           throws Exception

Called upon database cluster start.

Specified by:

start in interface Lifecycle

Throws:

Exception - if this service fails to start.

See Also:

Lifecycle.start()

stop

public void stop()

Called when database cluster is stopped.

Specified by:

stop in interface Lifecycle

See Also:

Lifecycle.stop()

getConnection

public Connection getConnection()
                         throws SQLException

Specified by:

getConnection in interface ConnectionFactory

Throws:

SQLException

See Also:

ConnectionFactory.getConnection()