public class AuroraTopologyUtils extends TopologyUtils
DEFAULT_QUERY_TIMEOUT_MS, dialect, hostSpecBuilder, networkTimeoutExecutor| Constructor and Description |
|---|
AuroraTopologyUtils(TopologyDialect dialect,
HostSpecBuilder hostSpecBuilder) |
| Modifier and Type | Method and Description |
|---|---|
protected HostSpec |
createHost(java.sql.ResultSet rs,
HostSpec initialHostSpec,
HostSpec instanceTemplate) |
protected @Nullable java.util.List<HostSpec> |
getHosts(java.sql.Connection conn,
java.sql.ResultSet rs,
HostSpec initialHostSpec,
HostSpec instanceTemplate) |
boolean |
isWriterInstance(java.sql.Connection connection)
Evaluate whether the given connection is to a writer instance.
|
createHost, createHost, queryForTopology, setNetworkTimeout, verifyWriterpublic AuroraTopologyUtils(TopologyDialect 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.