net.sf.hajdbc.sql

Class ConnectionInvocationHandler<D,P>

java.lang.Object

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

net.sf.hajdbc.sql.AbstractChildInvocationHandler<D,P,java.sql.Connection>

net.sf.hajdbc.sql.ConnectionInvocationHandler<D,P>

Type Parameters:

D -

P -

All Implemented Interfaces:

java.lang.reflect.InvocationHandler, SQLProxy<D,java.sql.Connection>

public class ConnectionInvocationHandler<D,P>
extends AbstractChildInvocationHandler<D,P,java.sql.Connection>

Author:

Paul Ferraro

Nested Class Summary

Nested classes/interfaces inherited from class net.sf.hajdbc.sql.AbstractInvocationHandler

AbstractInvocationHandler.SimpleInvoker

Field Summary

Fields inherited from class net.sf.hajdbc.sql.AbstractInvocationHandler

cluster, logger

Constructor Summary

Constructors

Constructor and Description
ConnectionInvocationHandler(P proxy, SQLProxy<D,P> handler, Invoker<D,P,java.sql.Connection> invoker, java.util.Map<Database<D>,java.sql.Connection> connectionMap, TransactionContext<D> transactionContext)

Method Summary

Modifier and Type	Method and Description
protected void	close(P parent, java.sql.Connection connection)
protected InvocationStrategy<D,java.sql.Connection,?>	getInvocationStrategy(java.sql.Connection connection, java.lang.reflect.Method method, java.lang.Object[] parameters) Returns the appropriate InvocationStrategy for the specified method.
protected Invoker<D,java.sql.Connection,?>	getInvoker(java.sql.Connection connection, java.lang.reflect.Method method, java.lang.Object[] parameters) Return the appropriate invoker for the specified method.
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(java.sql.Connection object, java.lang.reflect.Method method, java.lang.Object[] parameters) Called after method is invoked.

Methods inherited from class net.sf.hajdbc.sql.AbstractChildInvocationHandler

close, createObject, getParent, getParentProxy, getRoot

Methods inherited from class net.sf.hajdbc.sql.AbstractInvocationHandler

addChild, detectClusterPanic, entries, entry, getDatabaseCluster, getObject, handleFailure, handleFailures, handlePartialFailure, invoke, record, removeChild, removeChildren, replay, retain

Methods inherited from class java.lang.Object

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

Constructor Detail

ConnectionInvocationHandler

public ConnectionInvocationHandler(P proxy,
                                   SQLProxy<D,P> handler,
                                   Invoker<D,P,java.sql.Connection> invoker,
                                   java.util.Map<Database<D>,java.sql.Connection> connectionMap,
                                   TransactionContext<D> transactionContext)
                            throws java.lang.Exception

Parameters:

proxy -

handler -

invoker -

connectionMap -

transactionContext -

Throws:

java.lang.Exception

Method Detail

getInvocationStrategy

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

Description copied from class: AbstractInvocationHandler

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.

Overrides:

getInvocationStrategy in class AbstractInvocationHandler<D,java.sql.Connection>

Parameters:

connection - the proxied object

method - the method to invoke

parameters - the method invocation parameters

Returns:

an invocation strategy

Throws:

java.lang.Exception

See Also:

AbstractInvocationHandler.getInvocationStrategy(java.lang.Object, java.lang.reflect.Method, java.lang.Object[])

getInvoker

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

Description copied from class: AbstractInvocationHandler

Return the appropriate invoker for the specified method.

Overrides:

getInvoker in class AbstractInvocationHandler<D,java.sql.Connection>

Returns:

an invoker

Throws:

java.lang.Exception

See Also:

AbstractInvocationHandler.getInvoker(java.lang.Object, java.lang.reflect.Method, java.lang.Object[])

isSQLMethod

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

Description copied from class: AbstractInvocationHandler

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

Overrides:

isSQLMethod in class AbstractInvocationHandler<D,java.sql.Connection>

Parameters:

method - a method

Returns:

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

See Also:

AbstractInvocationHandler.isSQLMethod(java.lang.reflect.Method)

postInvoke

protected void postInvoke(java.sql.Connection object,
                          java.lang.reflect.Method method,
                          java.lang.Object[] parameters)

Description copied from class: AbstractInvocationHandler

Called after method is invoked.

Overrides:

postInvoke in class AbstractInvocationHandler<D,java.sql.Connection>

Parameters:

object - the proxied object

method - the method that was just invoked

parameters - the parameters of the method that was just invoked

See Also:

AbstractInvocationHandler.postInvoke(java.lang.Object, java.lang.reflect.Method, java.lang.Object[])

close

protected void close(P parent,
                     java.sql.Connection connection)
              throws java.sql.SQLException

Specified by:

close in class AbstractChildInvocationHandler<D,P,java.sql.Connection>

Throws:

java.sql.SQLException

See Also:

AbstractChildInvocationHandler.close(java.lang.Object, java.lang.Object)

isRecordable

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

Overrides:

isRecordable in class AbstractInvocationHandler<D,java.sql.Connection>

See Also:

AbstractInvocationHandler.isRecordable(java.lang.reflect.Method)