software.amazon.jdbc.plugin.readwritesplitting.signal

Class CompositeSignal

java.lang.Object

software.amazon.jdbc.plugin.readwritesplitting.signal.CompositeSignal

All Implemented Interfaces:

RoutingSignal

public class CompositeSignal
extends java.lang.Object
implements RoutingSignal

Composes a primary and a fallback RoutingSignal. The primary is consulted first; when it returns TargetRole.NO_DECISION, the fallback is consulted. This lets the auto plugin route primarily on SQL (at prepare time) while still honoring setReadOnly.

Constructor Summary

Constructors

Constructor and Description
CompositeSignal(RoutingSignal primary, RoutingSignal fallback)

Method Summary

Modifier and Type	Method and Description
java.util.Set<java.lang.String>	extraSubscribedMethods() Extra JDBC method names this signal needs subscribed beyond the plugin's defaults (e.g.
TargetRole	resolve(RwSplitContext ctx, java.lang.String methodName, @Nullable java.lang.Object[] args) Resolves the desired role for this call.
TargetRole	resolveForBoundStatement(RwSplitContext ctx) Resolves the desired role for an already-bound plain Statement from the parsed SQL, used only for the optional statement-rebinding path.

Methods inherited from class java.lang.Object

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

Constructor Detail

CompositeSignal

public CompositeSignal(RoutingSignal primary,
                       RoutingSignal fallback)

Method Detail

extraSubscribedMethods

public java.util.Set<java.lang.String> extraSubscribedMethods()

Description copied from interface: RoutingSignal

Extra JDBC method names this signal needs subscribed beyond the plugin's defaults (e.g. the statement-creation and execute methods for SQL routing).

Specified by:

extraSubscribedMethods in interface RoutingSignal

Returns:

an unmodifiable set of method names; empty by default

resolve

public TargetRole resolve(RwSplitContext ctx,
                          java.lang.String methodName,
                          @Nullable java.lang.Object[] args)
                   throws java.sql.SQLException

Description copied from interface: RoutingSignal

Resolves the desired role for this call. TargetRole.NO_DECISION means the method is not a routing trigger for this signal (the signal abstains).

Specified by:

resolve in interface RoutingSignal

Parameters:

ctx - the read/write splitting context

methodName - the JDBC method being invoked

args - the method arguments (may be null)

Returns:

the desired target role

Throws:

java.sql.SQLException

resolveForBoundStatement

public TargetRole resolveForBoundStatement(RwSplitContext ctx)
                                    throws java.sql.SQLException

Description copied from interface: RoutingSignal

Resolves the desired role for an already-bound plain Statement from the parsed SQL, used only for the optional statement-rebinding path. Returns TargetRole.NO_DECISION by default (signals that do not route on SQL do not reroute bound statements).

Specified by:

resolveForBoundStatement in interface RoutingSignal

Parameters:

ctx - the read/write splitting context

Returns:

the desired role, or TargetRole.NO_DECISION if this signal does not apply

Throws:

java.sql.SQLException