software.amazon.jdbc

Class DriverConnectionProvider

java.lang.Object

software.amazon.jdbc.DriverConnectionProvider

All Implemented Interfaces:

ConnectionProvider, StateSnapshotProvider

public class DriverConnectionProvider
extends java.lang.Object
implements ConnectionProvider

This class is a basic implementation of ConnectionProvider interface. It creates and returns a connection provided by a target driver or a data source.

Constructor Summary

Constructors

Constructor and Description
DriverConnectionProvider(java.sql.Driver driver)

Method Summary

Modifier and Type	Method and Description
boolean	acceptsStrategy(@Nullable HostRole role, @NonNull java.lang.String strategy) Indicates whether the selection strategy is supported by the connection provider.
boolean	acceptsUrl(@NonNull java.lang.String protocol, @NonNull HostSpec hostSpec, @NonNull java.util.Properties props) Indicates whether this ConnectionProvider can provide connections for the given host and properties.
@NonNull ConnectionInfo	connect(@NonNull java.lang.String protocol, @NonNull Dialect dialect, @NonNull TargetDriverDialect targetDriverDialect, @NonNull HostSpec hostSpec, @NonNull java.util.Properties props) Called once per connection that needs to be created.
@Nullable HostSpec	getHostSpecByStrategy(@NonNull java.util.List<HostSpec> hosts, @Nullable HostRole role, @NonNull java.lang.String strategy, @Nullable java.util.Properties props) Return a reader or a writer node using the specified strategy.
java.util.List<Pair<java.lang.String,java.lang.Object>>	getSnapshotState()
java.lang.String	getTargetName()

Methods inherited from class java.lang.Object

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

Constructor Detail

DriverConnectionProvider

public DriverConnectionProvider(java.sql.Driver driver)

Method Detail

acceptsUrl

public boolean acceptsUrl(@NonNull java.lang.String protocol,
                          @NonNull HostSpec hostSpec,
                          @NonNull java.util.Properties props)

Indicates whether this ConnectionProvider can provide connections for the given host and properties. Some ConnectionProvider implementations may not be able to handle certain URL types or properties.

Specified by:

acceptsUrl in interface ConnectionProvider

Parameters:

protocol - The connection protocol (example "jdbc:mysql://")

hostSpec - The HostSpec containing the host-port information for the host to connect to

props - The Properties to use for the connection

Returns:

true if this ConnectionProvider can provide connections for the given URL, otherwise return false

acceptsStrategy

public boolean acceptsStrategy(@Nullable HostRole role,
                               @NonNull java.lang.String strategy)

Description copied from interface: ConnectionProvider

Indicates whether the selection strategy is supported by the connection provider.

Specified by:

acceptsStrategy in interface ConnectionProvider

Parameters:

role - determines if the connection provider should return a reader host or a writer host. Null value means no preferences on host role.

strategy - the selection strategy to use

Returns:

whether the strategy is supported

getHostSpecByStrategy

public @Nullable HostSpec getHostSpecByStrategy(@NonNull java.util.List<HostSpec> hosts,
                                                @Nullable HostRole role,
                                                @NonNull java.lang.String strategy,
                                                @Nullable java.util.Properties props)
                                         throws java.sql.SQLException

Description copied from interface: ConnectionProvider

Return a reader or a writer node using the specified strategy. This method should raise an UnsupportedOperationException if the specified strategy is unsupported.

Specified by:

getHostSpecByStrategy in interface ConnectionProvider

Parameters:

hosts - the list of HostSpec to select from

role - determines if the connection provider should return a writer or a reader

strategy - the strategy determining how the HostSpec should be selected, e.g., random or round-robin

props - any properties that are required by the provided strategy to select a host

Returns:

the HostSpec selected using the specified strategy, or null if no host matches

Throws:

java.sql.SQLException - if an error occurred while returning the hosts

connect

public @NonNull ConnectionInfo connect(@NonNull java.lang.String protocol,
                                       @NonNull Dialect dialect,
                                       @NonNull TargetDriverDialect targetDriverDialect,
                                       @NonNull HostSpec hostSpec,
                                       @NonNull java.util.Properties props)
                                throws java.sql.SQLException

Called once per connection that needs to be created.

Specified by:

connect in interface ConnectionProvider

Parameters:

protocol - The connection protocol (example "jdbc:mysql://")

dialect - The database dialect

targetDriverDialect - The target driver dialect

hostSpec - The HostSpec containing the host-port information for the host to connect to

props - The Properties to use for the connection

Returns:

ConnectionInfo resulting from the given connection information

Throws:

java.sql.SQLException - if an error occurs

getTargetName

public java.lang.String getTargetName()

Specified by:

getTargetName in interface ConnectionProvider

getSnapshotState

public java.util.List<Pair<java.lang.String,java.lang.Object>> getSnapshotState()

Specified by:

getSnapshotState in interface StateSnapshotProvider