software.amazon.jdbc.plugin.readwritesplitting.resolver

Interface ReaderResolver

All Known Implementing Classes:

EndpointReaderResolver, TopologyReaderResolver

public interface ReaderResolver

Establishes a reader connection and switches the current connection to it ("how to reach a reader?"). The default implementation composes a ReaderCandidateSource with a LoadBalancingPolicy and applies the per-call connect/retry loop.

Method Summary

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

Method Detail

switchToReader

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

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

Parameters:

ctx - the read/write splitting context

Throws:

java.sql.SQLException

closeStaleReaderIfNecessary

default void closeStaleReaderIfNecessary(RwSplitContext ctx)

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.

Parameters:

ctx - the read/write splitting context

isPerQuery

default 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). No-op by default; false keeps the sticky-reader behavior.

Returns:

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