software.amazon.jdbc.plugin.readwritesplitting

Class SimpleReadWriteSplittingPlugin

java.lang.Object

software.amazon.jdbc.plugin.AbstractConnectionPlugin

software.amazon.jdbc.plugin.readwritesplitting.UnifiedReadWriteSplittingPlugin

software.amazon.jdbc.plugin.readwritesplitting.SimpleReadWriteSplittingPlugin

All Implemented Interfaces:

CanReleaseResources, ConnectionPlugin, RwSplitContext, StateSnapshotProvider

Direct Known Subclasses:

AutoSimpleReadWriteSplittingPlugin, GdbSimpleReadWriteSplittingPlugin

public class SimpleReadWriteSplittingPlugin
extends UnifiedReadWriteSplittingPlugin

Simple (endpoint-based) read/write splitting plugin (srw): routes on setReadOnly between a configured write endpoint and read endpoint, without relying on cluster topology, with optional connection-role verification.

Field Summary

Fields

Modifier and Type	Field and Description
static AwsWrapperProperty	SRW_CONNECT_RETRY_INTERVAL_MS
static AwsWrapperProperty	SRW_CONNECT_RETRY_TIMEOUT_MS
static AwsWrapperProperty	SRW_READ_ENDPOINT
static AwsWrapperProperty	SRW_WRITE_ENDPOINT
static AwsWrapperProperty	VERIFY_INITIAL_CONNECTION_TYPE
static AwsWrapperProperty	VERIFY_NEW_SRW_CONNECTIONS

Fields inherited from class software.amazon.jdbc.plugin.readwritesplitting.UnifiedReadWriteSplittingPlugin

ALLOW_STATEMENT_RECREATION_ON_CONNECTION_SWITCH, ASSUME_WRITE_TRANSACTION, CACHED_READER_KEEP_ALIVE_TIMEOUT, helpers, hostListProviderService, inReadWriteSplit, isReaderConnFromInternalPool, isWriterConnFromInternalPool, LOAD_BALANCING_INCLUDE_WRITER, pluginService, properties, QUERY_LEVEL_LOAD_BALANCING, readerCacheItem, readerHostSpec, writerConnection, writerHostSpec

Constructor Summary

Constructors

Modifier	Constructor and Description
	SimpleReadWriteSplittingPlugin(PluginService pluginService, java.util.Properties properties)
protected	SimpleReadWriteSplittingPlugin(PluginService pluginService, java.util.Properties properties, RwSplitHelpers helpers) Constructor for subclasses that supply their own helper assembly.

Method Summary

Modifier and Type	Method and Description
protected static RwSplitHelpers	endpointHelpers(java.util.Properties props, RoutingSignal routingSignal, SwitchGate switchGate, NoOpTopologyRefresher topologyRefresher) Shared endpoint assembly builder, parameterized by routing signal and switch gate so the SQL-routed variant can reuse it.
protected static RwSplitHelpers	simple(java.util.Properties props) Builds the endpoint-based assembly with setReadOnly routing.

Methods inherited from class software.amazon.jdbc.plugin.readwritesplitting.UnifiedReadWriteSplittingPlugin

bindReader, bindWriter, closeReaderConnectionIfIdle, closeWriterConnectionIfIdle, connect, connect, currentConnection, currentHostSpec, enterReadWriteSplit, execute, getReaderConnection, getSnapshotState, getSubscribedMethods, getWriterConnection, hostListProviderService, initHostProvider, isConnectionUsable, isInReadWriteSplit, isReaderFromPool, isWriterFromPool, logAndThrow, logAndThrow, markReaderFromPool, markWriterFromPool, notifyConnectionChanged, pluginService, properties, readerConnection, readerHostSpec, readerLoadBalancer, releaseResources, setWriterHostSpec, switchCurrentConnectionTo, writerConnection, writerHostSpec

Methods inherited from class software.amazon.jdbc.plugin.AbstractConnectionPlugin

acceptsStrategy, forceConnect, getHostSpecByStrategy, getHostSpecByStrategy, notifyNodeListChanged

Methods inherited from class java.lang.Object

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

Field Detail

SRW_READ_ENDPOINT

public static final AwsWrapperProperty SRW_READ_ENDPOINT

SRW_WRITE_ENDPOINT

public static final AwsWrapperProperty SRW_WRITE_ENDPOINT

VERIFY_NEW_SRW_CONNECTIONS

public static final AwsWrapperProperty VERIFY_NEW_SRW_CONNECTIONS

SRW_CONNECT_RETRY_TIMEOUT_MS

public static final AwsWrapperProperty SRW_CONNECT_RETRY_TIMEOUT_MS

SRW_CONNECT_RETRY_INTERVAL_MS

public static final AwsWrapperProperty SRW_CONNECT_RETRY_INTERVAL_MS

VERIFY_INITIAL_CONNECTION_TYPE

public static final AwsWrapperProperty VERIFY_INITIAL_CONNECTION_TYPE

Constructor Detail

SimpleReadWriteSplittingPlugin

public SimpleReadWriteSplittingPlugin(PluginService pluginService,
                                      java.util.Properties properties)

SimpleReadWriteSplittingPlugin

protected SimpleReadWriteSplittingPlugin(PluginService pluginService,
                                         java.util.Properties properties,
                                         RwSplitHelpers helpers)

Constructor for subclasses that supply their own helper assembly.

Method Detail

simple

protected static RwSplitHelpers simple(java.util.Properties props)

Builds the endpoint-based assembly with setReadOnly routing.

endpointHelpers

protected static RwSplitHelpers endpointHelpers(java.util.Properties props,
                                                RoutingSignal routingSignal,
                                                SwitchGate switchGate,
                                                NoOpTopologyRefresher topologyRefresher)

Shared endpoint assembly builder, parameterized by routing signal and switch gate so the SQL-routed variant can reuse it. Fails fast when a required endpoint is missing.