software.amazon.jdbc.hostlistprovider

Class RdsMultiAzDbClusterListProvider

java.lang.Object

software.amazon.jdbc.hostlistprovider.RdsHostListProvider

software.amazon.jdbc.hostlistprovider.RdsMultiAzDbClusterListProvider

All Implemented Interfaces:

HostListProvider, DynamicHostListProvider

public class RdsMultiAzDbClusterListProvider
extends RdsHostListProvider

Field Summary

Fields inherited from class software.amazon.jdbc.hostlistprovider.RdsHostListProvider

CLUSTER_ID, CLUSTER_INSTANCE_HOST_PATTERN, CLUSTER_TOPOLOGY_REFRESH_RATE_MS, clusterId, clusterInstanceTemplate, connectionUrlParser, isInitialized, isPrimaryClusterId, primaryClusterIdCache, suggestedPrimaryClusterIdCache, topologyCache

Constructor Summary

Constructors

Constructor and Description
RdsMultiAzDbClusterListProvider(java.util.Properties properties, java.lang.String originalUrl, HostListProviderService hostListProviderService, java.lang.String topologyQuery, java.lang.String nodeIdQuery, java.lang.String isReaderQuery, java.lang.String fetchWriterNodeQuery, java.lang.String fetchWriterNodeQueryHeader)

Method Summary

Modifier and Type	Method and Description
protected java.util.List<HostSpec>	queryForTopology(java.sql.Connection conn) Obtain a cluster topology from database.

Methods inherited from class software.amazon.jdbc.hostlistprovider.RdsHostListProvider

clear, clearAll, forceRefresh, forceRefresh, getCachedTopology, getHostRole, getRdsUrlType, getTopology, identifyConnection, init, logCache, refresh, refresh, suggestPrimaryCluster

Methods inherited from class java.lang.Object

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

Constructor Detail

RdsMultiAzDbClusterListProvider

public RdsMultiAzDbClusterListProvider(java.util.Properties properties,
                                       java.lang.String originalUrl,
                                       HostListProviderService hostListProviderService,
                                       java.lang.String topologyQuery,
                                       java.lang.String nodeIdQuery,
                                       java.lang.String isReaderQuery,
                                       java.lang.String fetchWriterNodeQuery,
                                       java.lang.String fetchWriterNodeQueryHeader)

Method Detail

queryForTopology

protected java.util.List<HostSpec> queryForTopology(java.sql.Connection conn)
                                             throws java.sql.SQLException

Obtain a cluster topology from database.

Overrides:

queryForTopology in class RdsHostListProvider

Parameters:

conn - A connection to database to fetch the latest topology.

Returns:

a list of HostSpec objects representing the topology

Throws:

java.sql.SQLException - if errors occurred while retrieving the topology.