software.amazon.jdbc.plugin.readwritesplitting.handler

Class VerifyRoleOnConnect

java.lang.Object

software.amazon.jdbc.plugin.readwritesplitting.handler.VerifyRoleOnConnect

All Implemented Interfaces:

InitialConnectionHandler

public class VerifyRoleOnConnect
extends java.lang.Object
implements InitialConnectionHandler

Topology InitialConnectionHandler: validates the reader host-selector strategy and, for the initial connection, verifies and corrects the connection role. Ports the legacy ReadWriteSplittingPlugin.connect.

Constructor Summary

Constructors

Constructor and Description
VerifyRoleOnConnect(java.lang.String readerSelectorStrategy, boolean verifyInitialConnectionRole)

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

VerifyRoleOnConnect

public VerifyRoleOnConnect(java.lang.String readerSelectorStrategy,
                           boolean verifyInitialConnectionRole)

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