software.amazon.jdbc.plugin.bluegreen

Class BlueGreenConnectionPlugin

java.lang.Object

software.amazon.jdbc.plugin.AbstractConnectionPlugin

software.amazon.jdbc.plugin.bluegreen.BlueGreenConnectionPlugin

All Implemented Interfaces:

ConnectionPlugin

public class BlueGreenConnectionPlugin
extends AbstractConnectionPlugin

Field Summary

Fields

Modifier and Type	Field and Description
static AwsWrapperProperty	BG_CONNECT_TIMEOUT
protected static java.lang.String	BG_SKIP_ROUTING_IN_FORCE_CONNECT
static AwsWrapperProperty	BGD_ID
protected java.lang.String	bgdId
protected BlueGreenStatus	bgStatus
protected java.lang.String	clusterId
protected java.util.concurrent.atomic.AtomicLong	endTimeNano
protected boolean	isIamInUse
protected PluginService	pluginService
protected java.util.Properties	props
protected static java.util.Map<java.lang.String,BlueGreenStatusProvider>	provider
protected BlueGreenProviderSupplier	providerSupplier
protected RdsUtils	rdsUtils
protected FullServicesContainer	servicesContainer
protected java.util.concurrent.atomic.AtomicLong	startTimeNano
protected StorageService	storageService
protected java.util.Set<java.lang.String>	subscribedMethods
protected TelemetryFactory	telemetryFactory

Constructor Summary

Constructors

Constructor and Description
BlueGreenConnectionPlugin(@NonNull FullServicesContainer servicesContainer, @NonNull java.util.Properties props)
BlueGreenConnectionPlugin(@NonNull FullServicesContainer servicesContainer, @NonNull java.util.Properties props, @NonNull BlueGreenProviderSupplier providerSupplier)

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) Establishes a connection to the given host using the given driver protocol and properties.
protected java.sql.Connection	connectInternal(HostSpec hostSpec, java.util.Properties props, boolean isInitialConnection, boolean useForceConnect, 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.sql.Connection	forceConnect(java.lang.String driverProtocol, HostSpec hostSpec, java.util.Properties props, boolean isInitialConnection, JdbcCallable<java.sql.Connection,java.sql.SQLException> connectFunc) Establishes a connection to the given host using the given driver protocol and properties.
long	getHoldTimeNano()
protected long	getNanoTime()
java.util.Set<java.lang.String>	getSubscribedMethods()
protected void	initProvider()
protected java.sql.Connection	regularOpenConnection(JdbcCallable<java.sql.Connection,java.sql.SQLException> connectFunc, boolean isInitialConnection, boolean useForceConnect)
void	resetRoutingTimeNano()

Methods inherited from class software.amazon.jdbc.plugin.AbstractConnectionPlugin

acceptsStrategy, getHostSpecByStrategy, getHostSpecByStrategy, initHostProvider, notifyConnectionChanged, notifyNodeListChanged

Methods inherited from class java.lang.Object

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

Field Detail

BG_CONNECT_TIMEOUT

public static final AwsWrapperProperty BG_CONNECT_TIMEOUT

BGD_ID

public static final AwsWrapperProperty BGD_ID

provider

protected static java.util.Map<java.lang.String,BlueGreenStatusProvider> provider

BG_SKIP_ROUTING_IN_FORCE_CONNECT

protected static final java.lang.String BG_SKIP_ROUTING_IN_FORCE_CONNECT

See Also:

Constant Field Values

servicesContainer

protected final FullServicesContainer servicesContainer

storageService

protected final StorageService storageService

pluginService

protected final PluginService pluginService

props

protected final java.util.Properties props

providerSupplier

protected BlueGreenProviderSupplier providerSupplier

telemetryFactory

protected final TelemetryFactory telemetryFactory

rdsUtils

protected final RdsUtils rdsUtils

bgStatus

protected BlueGreenStatus bgStatus

bgdId

protected java.lang.String bgdId

clusterId

protected java.lang.String clusterId

isIamInUse

protected boolean isIamInUse

startTimeNano

protected final java.util.concurrent.atomic.AtomicLong startTimeNano

endTimeNano

protected final java.util.concurrent.atomic.AtomicLong endTimeNano

subscribedMethods

protected final java.util.Set<java.lang.String> subscribedMethods

Constructor Detail

BlueGreenConnectionPlugin

public BlueGreenConnectionPlugin(@NonNull FullServicesContainer servicesContainer,
                                 @NonNull java.util.Properties props)

BlueGreenConnectionPlugin

public BlueGreenConnectionPlugin(@NonNull FullServicesContainer servicesContainer,
                                 @NonNull java.util.Properties props,
                                 @NonNull BlueGreenProviderSupplier providerSupplier)

Method Detail

getSubscribedMethods

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

Specified by:

getSubscribedMethods in interface ConnectionPlugin

Specified by:

getSubscribedMethods in class AbstractConnectionPlugin

forceConnect

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

Description copied from interface: ConnectionPlugin

Establishes a connection to the given host using the given driver protocol and properties. This call differs from ConnectionPlugin.connect(java.lang.String, software.amazon.jdbc.HostSpec, java.util.Properties, boolean, software.amazon.jdbc.JdbcCallable<java.sql.Connection, java.sql.SQLException>) in that the default ConnectionProvider will be used to establish the connection even if a non-default ConnectionProvider has been set via Driver.setCustomConnectionProvider(ConnectionProvider). The default ConnectionProvider will be DriverConnectionProvider for connections requested via the DriverManager and DataSourceConnectionProvider for connections requested via an AwsWrapperDataSource.

Specified by:

forceConnect in interface ConnectionPlugin

Overrides:

forceConnect in class AbstractConnectionPlugin

Parameters:

driverProtocol - the driver protocol that should be used to establish the connection

hostSpec - the host details for the desired connection

props - the connection properties

isInitialConnection - a boolean indicating whether the current Connection is establishing an initial physical connection to the database or has already established a physical connection in the past

connectFunc - the function to call to continue the forceConnect request down the forceConnect pipeline

Returns:

a Connection to the requested host

Throws:

java.sql.SQLException - if there was an error establishing a Connection to the requested host

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

Description copied from interface: ConnectionPlugin

Establishes a connection to the given host using the given driver protocol and properties. If a non-default ConnectionProvider has been set with Driver.setCustomConnectionProvider(ConnectionProvider) and ConnectionProvider.acceptsUrl(String, HostSpec, Properties) returns true for the given protocol, host, and properties, the connection will be created by the non-default ConnectionProvider. Otherwise, the connection will be created by the default ConnectionProvider. The default ConnectionProvider will be DriverConnectionProvider for connections requested via the DriverManager and DataSourceConnectionProvider for connections requested via an AwsWrapperDataSource.

Specified by:

connect in interface ConnectionPlugin

Overrides:

connect in class AbstractConnectionPlugin

Parameters:

driverProtocol - the driver protocol that should be used to establish the connection

hostSpec - the host details for the desired connection

props - the connection properties

isInitialConnection - a boolean indicating whether the current Connection is establishing an initial physical connection to the database or has already established a physical connection in the past

connectFunc - the function to call to continue the connect request down the connect pipeline

Returns:

a Connection to the requested host

Throws:

java.sql.SQLException - if there was an error establishing a Connection to the requested host

connectInternal

protected java.sql.Connection connectInternal(HostSpec hostSpec,
                                              java.util.Properties props,
                                              boolean isInitialConnection,
                                              boolean useForceConnect,
                                              JdbcCallable<java.sql.Connection,java.sql.SQLException> connectFunc)
                                       throws java.sql.SQLException

Throws:

java.sql.SQLException

regularOpenConnection

protected java.sql.Connection regularOpenConnection(JdbcCallable<java.sql.Connection,java.sql.SQLException> connectFunc,
                                                    boolean isInitialConnection,
                                                    boolean useForceConnect)
                                             throws java.sql.SQLException

Throws:

java.sql.SQLException

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

Overrides:

execute in class AbstractConnectionPlugin

Throws:

E extends java.lang.Exception

initProvider

protected void initProvider()

getNanoTime

protected long getNanoTime()

getHoldTimeNano

public long getHoldTimeNano()

resetRoutingTimeNano

public void resetRoutingTimeNano()