software.amazon.jdbc.plugin.readwritesplitting.resolver

Class EndpointReaderResolver

java.lang.Object

software.amazon.jdbc.plugin.readwritesplitting.resolver.EndpointReaderResolver

All Implemented Interfaces:

ReaderResolver

public class EndpointReaderResolver
extends java.lang.Object
implements ReaderResolver

ReaderResolver that connects to the configured read endpoint, optionally verifying the connection role. Ports the legacy SimpleReadWriteSplittingPlugin.initializeReaderConnection. Fails fast at construction if the endpoint is missing/blank.

Constructor Summary

Constructors

Constructor and Description
EndpointReaderResolver(java.lang.String readEndpoint, boolean verifyNewConnections, EndpointConnectionVerifier verifier)
EndpointReaderResolver(java.lang.String readEndpoint, boolean verifyNewConnections, EndpointConnectionVerifier verifier, boolean queryLevelLoadBalancing)

Method Summary

Modifier and Type	Method and Description
boolean	isPerQuery() Whether this resolver performs query-level load balancing (a fresh reader is selected on each read-routing decision rather than a single sticky reader being reused).
void	switchToReader(RwSplitContext ctx) Establishes a fresh reader connection (selecting a candidate, connecting, binding, and switching the current connection to it).

Methods inherited from class java.lang.Object

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

Methods inherited from interface software.amazon.jdbc.plugin.readwritesplitting.resolver.ReaderResolver

closeStaleReaderIfNecessary

Constructor Detail

EndpointReaderResolver

public EndpointReaderResolver(java.lang.String readEndpoint,
                              boolean verifyNewConnections,
                              EndpointConnectionVerifier verifier)

EndpointReaderResolver

public EndpointReaderResolver(java.lang.String readEndpoint,
                              boolean verifyNewConnections,
                              EndpointConnectionVerifier verifier,
                              boolean queryLevelLoadBalancing)

Method Detail

isPerQuery

public boolean isPerQuery()

Description copied from interface: ReaderResolver

Whether this resolver performs query-level load balancing (a fresh reader is selected on each read-routing decision rather than a single sticky reader being reused). No-op by default; false keeps the sticky-reader behavior.

Specified by:

isPerQuery in interface ReaderResolver

Returns:

true for per-query reader balancing; false (default) for sticky

switchToReader

public void switchToReader(RwSplitContext ctx)
                    throws java.sql.SQLException

Description copied from interface: ReaderResolver

Establishes a fresh reader connection (selecting a candidate, connecting, binding, and switching the current connection to it). Mirrors the legacy initializeReaderConnection.

Specified by:

switchToReader in interface ReaderResolver

Parameters:

ctx - the read/write splitting context

Throws:

java.sql.SQLException