public class MultiAzTopologyUtils extends TopologyUtils
| Modifier and Type | Field and Description |
|---|---|
protected MultiAzClusterDialect |
dialect |
DEFAULT_QUERY_TIMEOUT_MS, hostSpecBuilder, networkTimeoutExecutor| Constructor and Description |
|---|
MultiAzTopologyUtils(MultiAzClusterDialect dialect,
HostSpecBuilder hostSpecBuilder) |
| Modifier and Type | Method and Description |
|---|---|
protected HostSpec |
createHost(java.sql.ResultSet rs,
HostSpec initialHostSpec,
HostSpec instanceTemplate,
@Nullable java.lang.String writerId) |
protected @Nullable java.util.List<HostSpec> |
getHosts(java.sql.Connection conn,
java.sql.ResultSet rs,
HostSpec initialHostSpec,
HostSpec instanceTemplate) |
protected @Nullable java.lang.String |
getWriterId(java.sql.Connection connection) |
boolean |
isWriterInstance(java.sql.Connection connection)
Evaluate whether the given connection is to a writer instance.
|
createHost, createHost, queryForTopology, setNetworkTimeout, verifyWriterprotected final MultiAzClusterDialect dialect
public MultiAzTopologyUtils(MultiAzClusterDialect dialect, HostSpecBuilder hostSpecBuilder)
protected @Nullable java.util.List<HostSpec> getHosts(java.sql.Connection conn, java.sql.ResultSet rs, HostSpec initialHostSpec, HostSpec instanceTemplate) throws java.sql.SQLException
getHosts in class TopologyUtilsjava.sql.SQLExceptionpublic boolean isWriterInstance(java.sql.Connection connection)
throws java.sql.SQLException
TopologyUtilsisWriterInstance in class TopologyUtilsconnection - the connection to evaluate.java.sql.SQLException - if an exception occurs when querying the database or processing the database response.protected @Nullable java.lang.String getWriterId(java.sql.Connection connection)
throws java.sql.SQLException
java.sql.SQLException