software.amazon.jdbc.plugin.readwritesplitting.handler

Class GdbInitAndVerify

java.lang.Object

software.amazon.jdbc.plugin.readwritesplitting.handler.GdbInitAndVerify

All Implemented Interfaces:

InitialConnectionHandler

public class GdbInitAndVerify
extends java.lang.Object
implements InitialConnectionHandler

Global Database InitialConnectionHandler: resolves and validates the home/accessible regions once (fail-fast), then delegates to the topology role-verification handler. Ports the legacy GdbReadWriteSplittingPlugin.connect/initSettings.

Constructor Summary

Constructors

Constructor and Description
GdbInitAndVerify(GdbSettings settings, InitialConnectionHandler delegate)

Method Summary

Modifier and Type	Method and Description
java.sql.Connection	onConnect(RwSplitContext ctx, java.lang.String driverProtocol, HostSpec hostSpec, java.util.Properties props, boolean isInitialConnection, @NonNull JdbcCallable<java.sql.Connection,java.sql.SQLException> connectFunc) Invoked from the unified plugin's connect.

Methods inherited from class java.lang.Object

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

Constructor Detail

GdbInitAndVerify

public GdbInitAndVerify(GdbSettings settings,
                        InitialConnectionHandler delegate)

Method Detail

onConnect

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

Description copied from interface: InitialConnectionHandler

Invoked from the unified plugin's connect.

Specified by:

onConnect in interface InitialConnectionHandler

Parameters:

ctx - the read/write splitting context

driverProtocol - the driver protocol

hostSpec - the host being connected to

props - the connection properties

isInitialConnection - whether this is the initial connection

connectFunc - the downstream connect function

Returns:

the established connection

Throws:

java.sql.SQLException