software.amazon.jdbc.plugin.readwritesplitting.resolver

Class TopologyWriterResolver

java.lang.Object

software.amazon.jdbc.plugin.readwritesplitting.resolver.TopologyWriterResolver

All Implemented Interfaces:

WriterResolver

public class TopologyWriterResolver
extends java.lang.Object
implements WriterResolver

WriterResolver that connects to the writer identified from the cluster topology (set by the TopologyRefresher before this runs). Ports the legacy ReadWriteSplittingPlugin.initializeWriterConnection connect step.

Constructor Summary

Constructors

Constructor and Description
TopologyWriterResolver()

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

TopologyWriterResolver

public TopologyWriterResolver()

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