software.amazon.jdbc.plugin.readwritesplitting.updater

Class VerifiedEndpointUpdatePolicy

java.lang.Object

software.amazon.jdbc.plugin.readwritesplitting.updater.VerifiedEndpointUpdatePolicy

All Implemented Interfaces:

ConnectionUpdatePolicy

public class VerifiedEndpointUpdatePolicy
extends java.lang.Object
implements ConnectionUpdatePolicy

Endpoint (Simple) ConnectionUpdatePolicy: adopt the current connection as the cached writer/reader only when it is a new connection matching the endpoint role, optionally verifying the role via the database. Ports the legacy SimpleReadWriteSplittingPlugin.shouldUpdate*Connection.

Constructor Summary

Constructors

Constructor and Description
VerifiedEndpointUpdatePolicy(RoleClassifier roleClassifier, boolean verifyNewConnections)

Method Summary

Modifier and Type	Method and Description
boolean	shouldUpdateReader(RwSplitContext ctx, java.sql.Connection currentConnection, HostSpec currentHost)
boolean	shouldUpdateWriter(RwSplitContext ctx, java.sql.Connection currentConnection, HostSpec currentHost)

Methods inherited from class java.lang.Object

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

Constructor Detail

VerifiedEndpointUpdatePolicy

public VerifiedEndpointUpdatePolicy(RoleClassifier roleClassifier,
                                    boolean verifyNewConnections)

Method Detail

shouldUpdateWriter

public boolean shouldUpdateWriter(RwSplitContext ctx,
                                  java.sql.Connection currentConnection,
                                  HostSpec currentHost)
                           throws java.sql.SQLException

Specified by:

shouldUpdateWriter in interface ConnectionUpdatePolicy

Throws:

java.sql.SQLException

shouldUpdateReader

public boolean shouldUpdateReader(RwSplitContext ctx,
                                  java.sql.Connection currentConnection,
                                  HostSpec currentHost)
                           throws java.sql.SQLException

Specified by:

shouldUpdateReader in interface ConnectionUpdatePolicy

Throws:

java.sql.SQLException