software.amazon.jdbc.plugin.readwritesplitting.resolver

Class EndpointWriterResolver

java.lang.Object

software.amazon.jdbc.plugin.readwritesplitting.resolver.EndpointWriterResolver

All Implemented Interfaces:

WriterResolver

public class EndpointWriterResolver
extends java.lang.Object
implements WriterResolver

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

Constructor Summary

Constructors

Constructor and Description
EndpointWriterResolver(java.lang.String writeEndpoint, boolean verifyNewConnections, EndpointConnectionVerifier verifier)

Method Summary

Modifier and Type	Method and Description
WriterResolution	resolveWriter(RwSplitContext ctx) Resolves the writer target.

Methods inherited from class java.lang.Object

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

Constructor Detail

EndpointWriterResolver

public EndpointWriterResolver(java.lang.String writeEndpoint,
                              boolean verifyNewConnections,
                              EndpointConnectionVerifier verifier)

Method Detail

resolveWriter

public WriterResolution resolveWriter(RwSplitContext ctx)
                               throws java.sql.SQLException

Description copied from interface: WriterResolver

Resolves the writer target. The returned WriterResolution is either WriterResolution.Kind.CONNECTED (a writer connection was established) or WriterResolution.Kind.STAY (remain on the current reader connection, e.g. Global Write Forwarding).

Specified by:

resolveWriter in interface WriterResolver

Parameters:

ctx - the read/write splitting context

Returns:

the writer resolution

Throws:

java.sql.SQLException