software.amazon.jdbc

Interface ConnectionPlugin

All Known Implementing Classes:

AbstractConnectionPlugin, AuroraHostListConnectionPlugin, AuroraStaleDnsPlugin, AwsSecretsManagerConnectionPlugin, DataCacheConnectionPlugin, DefaultConnectionPlugin, ExecutionTimeConnectionPlugin, FailoverConnectionPlugin, HostMonitoringConnectionPlugin, IamAuthConnectionPlugin, LogQueryConnectionPlugin

public interface ConnectionPlugin

Interface for connection plugins. This class implements ways to execute a JDBC method and to clean up resources used before closing the plugin.

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)
<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)

Method Detail

getSubscribedMethods

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

execute

<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

Throws:

E extends java.lang.Exception

connect

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

Throws:

java.sql.SQLException

initHostProvider

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

Throws:

java.sql.SQLException

notifyConnectionChanged

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

notifyNodeListChanged

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