net.sf.hajdbc.sql

Class AbstractInvocationHandler<D,T>

java.lang.Object

net.sf.hajdbc.sql.AbstractInvocationHandler<D,T>

Type Parameters:

D -

T -

All Implemented Interfaces:

java.lang.reflect.InvocationHandler, SQLProxy<D,T>

Direct Known Subclasses:

AbstractChildInvocationHandler, AbstractRootInvocationHandler

public abstract class AbstractInvocationHandler<D,T>
extends java.lang.Object
implements java.lang.reflect.InvocationHandler, SQLProxy<D,T>

Author:

Paul Ferraro

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	AbstractInvocationHandler.SimpleInvoker

Field Summary

Fields

Modifier and Type	Field and Description
protected DatabaseCluster<D>	cluster
protected Logger	logger

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractInvocationHandler(DatabaseCluster<D> cluster, java.lang.Class<T> proxyClass, java.util.Map<Database<D>,T> objectMap)

Method Summary

Modifier and Type	Method and Description
void	addChild(SQLProxy<D,?> child)
protected abstract void	close(Database<D> database, T object)
protected abstract T	createObject(Database<D> database)
protected void	detectClusterPanic(java.util.Map<java.lang.Boolean,java.util.List<Database<D>>> aliveMap) Detect cluster panic if all conditions are met: We're in distributable mode We're the only group member All alive databases are local All dead databases are remote
java.util.Set<java.util.Map.Entry<Database<D>,T>>	entries()
java.util.Map.Entry<Database<D>,T>	entry()
DatabaseCluster<D>	getDatabaseCluster()
protected InvocationStrategy<D,T,?>	getInvocationStrategy(T object, java.lang.reflect.Method method, java.lang.Object[] parameters) Returns the appropriate InvocationStrategy for the specified method.
protected Invoker<D,T,?>	getInvoker(T object, java.lang.reflect.Method method, java.lang.Object[] parameters) Return the appropriate invoker for the specified method.
T	getObject(Database<D> database) Returns the underlying SQL object for the specified database.
void	handleFailure(Database<D> database, java.lang.Exception exception)
void	handleFailures(java.util.SortedMap<Database<D>,java.lang.Exception> exceptionMap)
<R> java.util.SortedMap<Database<D>,R>	handlePartialFailure(java.util.SortedMap<Database<D>,R> resultMap, java.util.SortedMap<Database<D>,java.lang.Exception> exceptionMap)
java.lang.Object	invoke(java.lang.Object object, java.lang.reflect.Method method, java.lang.Object[] parameters)
protected boolean	isRecordable(java.lang.reflect.Method method)
protected boolean	isSQLMethod(java.lang.reflect.Method method) Indicates whether or not the specified method accepts a SQL string as its first parameter.
protected void	postInvoke(T proxy, java.lang.reflect.Method method, java.lang.Object[] parameters) Called after method is invoked.
protected void	record(Invoker<D,T,?> invoker, java.lang.reflect.Method method, java.lang.Object[] parameters)
void	removeChild(SQLProxy<D,?> child)
void	removeChildren()
protected void	replay(Database<D> database, T object)
void	retain(java.util.Set<Database<D>> databaseSet)

Methods inherited from class java.lang.Object

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

Methods inherited from interface net.sf.hajdbc.sql.SQLProxy

getRoot

Field Detail

logger

protected Logger logger

cluster

protected DatabaseCluster<D> cluster

Constructor Detail

AbstractInvocationHandler

protected AbstractInvocationHandler(DatabaseCluster<D> cluster,
                                    java.lang.Class<T> proxyClass,
                                    java.util.Map<Database<D>,T> objectMap)

Parameters:

cluster - the database cluster

proxyClass - the interface being proxied

objectMap - a map of database to sql object.

Method Detail

invoke

public final java.lang.Object invoke(java.lang.Object object,
                                     java.lang.reflect.Method method,
                                     java.lang.Object[] parameters)
                              throws java.lang.Exception

Specified by:

invoke in interface java.lang.reflect.InvocationHandler

Throws:

java.lang.Exception

See Also:

InvocationHandler.invoke(java.lang.Object, java.lang.reflect.Method, java.lang.Object[])

getInvocationStrategy

protected InvocationStrategy<D,T,?> getInvocationStrategy(T object,
                                                          java.lang.reflect.Method method,
                                                          java.lang.Object[] parameters)
                                                   throws java.lang.Exception

Returns the appropriate InvocationStrategy for the specified method. This implementation detects Wrapper methods; and Object.equals(java.lang.Object), Object.hashCode(), and Object.toString(). Default invocation strategy is DatabaseWriteInvocationStrategy.

Parameters:

object - the proxied object

method - the method to invoke

parameters - the method invocation parameters

Returns:

an invocation strategy

Throws:

java.lang.Exception

getInvoker

protected Invoker<D,T,?> getInvoker(T object,
                                    java.lang.reflect.Method method,
                                    java.lang.Object[] parameters)
                             throws java.lang.Exception

Return the appropriate invoker for the specified method.

Parameters:

object -

method -

parameters -

Returns:

an invoker

Throws:

java.lang.Exception

isSQLMethod

protected boolean isSQLMethod(java.lang.reflect.Method method)

Indicates whether or not the specified method accepts a SQL string as its first parameter.

Parameters:

method - a method

Returns:

true, if the specified method accepts a SQL string as its first parameter, false otherwise.

postInvoke

protected void postInvoke(T proxy,
                          java.lang.reflect.Method method,
                          java.lang.Object[] parameters)

Called after method is invoked.

Parameters:

proxy - the proxied object

method - the method that was just invoked

parameters - the parameters of the method that was just invoked

entry

public java.util.Map.Entry<Database<D>,T> entry()

Specified by:

entry in interface SQLProxy<D,T>

See Also:

SQLProxy.entry()

entries

public java.util.Set<java.util.Map.Entry<Database<D>,T>> entries()

Specified by:

entries in interface SQLProxy<D,T>

See Also:

SQLProxy.entries()

addChild

public final void addChild(SQLProxy<D,?> child)

Specified by:

addChild in interface SQLProxy<D,T>

See Also:

SQLProxy.addChild(net.sf.hajdbc.sql.SQLProxy)

removeChildren

public final void removeChildren()

Specified by:

removeChildren in interface SQLProxy<D,T>

See Also:

SQLProxy.removeChildren()

removeChild

public final void removeChild(SQLProxy<D,?> child)

Specified by:

removeChild in interface SQLProxy<D,T>

See Also:

SQLProxy.removeChild(net.sf.hajdbc.sql.SQLProxy)

getObject

public T getObject(Database<D> database)

Returns the underlying SQL object for the specified database. If the sql object does not exist (this might be the case if the database was newly activated), it will be created from the stored operation. Any recorded operations are also executed. If the object could not be created, or if any of the executed operations failed, then the specified database is deactivated.

Specified by:

getObject in interface SQLProxy<D,T>

Parameters:

database - a database descriptor.

Returns:

an underlying SQL object

createObject

protected abstract T createObject(Database<D> database)
                           throws java.lang.Exception

Throws:

java.lang.Exception

record

protected void record(Invoker<D,T,?> invoker,
                      java.lang.reflect.Method method,
                      java.lang.Object[] parameters)

isRecordable

protected boolean isRecordable(java.lang.reflect.Method method)

replay

protected void replay(Database<D> database,
                      T object)
               throws java.lang.Exception

Throws:

java.lang.Exception

retain

public final void retain(java.util.Set<Database<D>> databaseSet)

Specified by:

retain in interface SQLProxy<D,T>

See Also:

SQLProxy.retain(java.util.Set)

close

protected abstract void close(Database<D> database,
                              T object)

getDatabaseCluster

public final DatabaseCluster<D> getDatabaseCluster()

Specified by:

getDatabaseCluster in interface SQLProxy<D,T>

See Also:

SQLProxy.getDatabaseCluster()

handleFailure

public void handleFailure(Database<D> database,
                          java.lang.Exception exception)
                   throws java.lang.Exception

Specified by:

handleFailure in interface SQLProxy<D,T>

Throws:

java.lang.Exception

See Also:

SQLProxy.handleFailure(net.sf.hajdbc.Database, java.lang.Exception)

handleFailures

public void handleFailures(java.util.SortedMap<Database<D>,java.lang.Exception> exceptionMap)
                    throws java.lang.Exception

Specified by:

handleFailures in interface SQLProxy<D,T>

Throws:

java.lang.Exception

See Also:

SQLProxy.handleFailures(java.util.SortedMap)

handlePartialFailure

public <R> java.util.SortedMap<Database<D>,R> handlePartialFailure(java.util.SortedMap<Database<D>,R> resultMap,
                                                                   java.util.SortedMap<Database<D>,java.lang.Exception> exceptionMap)
                                                            throws java.lang.Exception

Specified by:

handlePartialFailure in interface SQLProxy<D,T>

Throws:

java.lang.Exception

See Also:

SQLProxy.handlePartialFailure(java.util.SortedMap, java.util.SortedMap)

detectClusterPanic

protected void detectClusterPanic(java.util.Map<java.lang.Boolean,java.util.List<Database<D>>> aliveMap)
                           throws java.lang.Exception

Detect cluster panic if all conditions are met:

• We're in distributable mode
• We're the only group member
• All alive databases are local
• All dead databases are remote

Parameters:

aliveMap -

Throws:

java.lang.Exception