software.amazon.jdbc.plugin.readwritesplitting.resolver

Class TopologyReaderResolver

java.lang.Object

software.amazon.jdbc.plugin.readwritesplitting.resolver.TopologyReaderResolver

All Implemented Interfaces:

ReaderResolver

public class TopologyReaderResolver
extends java.lang.Object
implements ReaderResolver

Topology-aware ReaderResolver. Ports the legacy ReadWriteSplittingPlugin.initializeReaderConnection/openNewReaderConnection: single-host clusters fall back to the writer; otherwise a reader is selected via the LoadBalancingPolicy with a bounded per-call retry loop (local candidate removal on non-login failures, login fast-fail, writer fallback on exhaustion).

Constructor Summary

Constructors

Constructor and Description
TopologyReaderResolver(ReaderCandidateSource candidateSource, LoadBalancingPolicy loadBalancingPolicy, WriterResolver writerFallback)

Method Summary

Modifier and Type	Method and Description
void	closeStaleReaderIfNecessary(RwSplitContext ctx) Closes the cached reader connection if it is no longer valid (e.g.
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

Constructor Detail

TopologyReaderResolver

public TopologyReaderResolver(ReaderCandidateSource candidateSource,
                              LoadBalancingPolicy loadBalancingPolicy,
                              WriterResolver writerFallback)

Method Detail

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

closeStaleReaderIfNecessary

public void closeStaleReaderIfNecessary(RwSplitContext ctx)

Description copied from interface: ReaderResolver

Closes the cached reader connection if it is no longer valid (e.g. its host left the allowed host list). No-op by default; overridden by topology-aware resolvers.

Specified by:

closeStaleReaderIfNecessary in interface ReaderResolver

Parameters:

ctx - the read/write splitting context

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