software.amazon.jdbc.plugin

Class DefaultConnectionPlugin

java.lang.Object

software.amazon.jdbc.plugin.DefaultConnectionPlugin

All Implemented Interfaces:

ConnectionPlugin

public final class DefaultConnectionPlugin
extends java.lang.Object
implements ConnectionPlugin

This connection plugin will always be the last plugin in the connection plugin chain, and will invoke the JDBC method passed down the chain.

Constructor Summary

Constructors

Constructor and Description
DefaultConnectionPlugin(PluginService pluginService, ConnectionProvider connectionProvider, PluginManagerService pluginManagerService)

Method Summary

Modifier and Type	Method and Description
java.sql.Connection	connect(java.lang.String driverProtocol, HostSpec hostSpec, java.util.Properties props, boolean isInitialConnection, JdbcCallable<java.sql.Connection,java.sql.SQLException> connectFunc)
boolean	doesCloseTransaction(java.lang.String statement)
boolean	doesOpenTransaction(java.lang.String statement)
<T,E extends java.lang.Exception> T	execute(java.lang.Class<T> resultClass, java.lang.Class<E> exceptionClass, java.lang.Object methodInvokeOn, java.lang.String methodName, JdbcCallable<T,E> jdbcMethodFunc, java.lang.Object[] jdbcMethodArgs)
java.util.Set<java.lang.String>	getSubscribedMethods()
void	initHostProvider(java.lang.String driverProtocol, java.lang.String initialUrl, java.util.Properties props, HostListProviderService hostListProviderService, JdbcCallable<java.lang.Void,java.sql.SQLException> initHostProviderFunc)
OldConnectionSuggestedAction	notifyConnectionChanged(java.util.EnumSet<NodeChangeOptions> changes)
void	notifyNodeListChanged(java.util.Map<java.lang.String,java.util.EnumSet<NodeChangeOptions>> changes)

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultConnectionPlugin

public DefaultConnectionPlugin(PluginService pluginService,
                               ConnectionProvider connectionProvider,
                               PluginManagerService pluginManagerService)

Method Detail

getSubscribedMethods

public java.util.Set<java.lang.String> getSubscribedMethods()

Specified by:

getSubscribedMethods in interface ConnectionPlugin

execute

public <T,E extends java.lang.Exception> T execute(java.lang.Class<T> resultClass,
                                                   java.lang.Class<E> exceptionClass,
                                                   java.lang.Object methodInvokeOn,
                                                   java.lang.String methodName,
                                                   JdbcCallable<T,E> jdbcMethodFunc,
                                                   java.lang.Object[] jdbcMethodArgs)
                                            throws E extends java.lang.Exception

Specified by:

execute in interface ConnectionPlugin

Throws:

E extends java.lang.Exception

connect

public java.sql.Connection connect(java.lang.String driverProtocol,
                                   HostSpec hostSpec,
                                   java.util.Properties props,
                                   boolean isInitialConnection,
                                   JdbcCallable<java.sql.Connection,java.sql.SQLException> connectFunc)
                            throws java.sql.SQLException

Specified by:

connect in interface ConnectionPlugin

Throws:

java.sql.SQLException

initHostProvider

public void initHostProvider(java.lang.String driverProtocol,
                             java.lang.String initialUrl,
                             java.util.Properties props,
                             HostListProviderService hostListProviderService,
                             JdbcCallable<java.lang.Void,java.sql.SQLException> initHostProviderFunc)
                      throws java.sql.SQLException

Specified by:

initHostProvider in interface ConnectionPlugin

Throws:

java.sql.SQLException

notifyConnectionChanged

public OldConnectionSuggestedAction notifyConnectionChanged(java.util.EnumSet<NodeChangeOptions> changes)

Specified by:

notifyConnectionChanged in interface ConnectionPlugin

notifyNodeListChanged

public void notifyNodeListChanged(java.util.Map<java.lang.String,java.util.EnumSet<NodeChangeOptions>> changes)

Specified by:

notifyNodeListChanged in interface ConnectionPlugin

doesOpenTransaction

public boolean doesOpenTransaction(java.lang.String statement)

doesCloseTransaction

public boolean doesCloseTransaction(java.lang.String statement)