public class RdsMysqlDialect extends MysqlDialect implements BlueGreenDialect
| Modifier and Type | Field and Description |
|---|---|
protected static java.lang.String |
BG_STATUS_QUERY |
protected static java.lang.String |
INSTANCE_ID_QUERY |
protected static java.lang.String |
REPORT_HOST_EXISTS_QUERY |
protected static java.lang.String |
TOPOLOGY_TABLE_EXISTS_QUERY |
dialectUtils, HOST_ALIAS_QUERY, HOST_ID_EXPRESSION, HOST_ID_QUERY, IS_READER_QUERY, VERSION_QUERY| Constructor and Description |
|---|
RdsMysqlDialect() |
| Modifier and Type | Method and Description |
|---|---|
java.lang.String |
getBlueGreenStatusQuery() |
java.util.List<java.lang.String> |
getDialectUpdateCandidates() |
@Nullable Pair<java.lang.String,java.lang.String> |
getHostId(java.sql.Connection connection) |
boolean |
isBlueGreenStatusAvailable(java.sql.Connection connection) |
boolean |
isDialect(java.sql.Connection connection) |
getDefaultPort, getExceptionHandler, getFailoverRestrictions, getHostAliasQuery, getHostListProviderSupplier, getHostRole, getServerVersionQuery, prepareConnectPropertiesclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitfilterAvailableHostsprotected static final java.lang.String REPORT_HOST_EXISTS_QUERY
protected static final java.lang.String TOPOLOGY_TABLE_EXISTS_QUERY
protected static final java.lang.String INSTANCE_ID_QUERY
protected static final java.lang.String BG_STATUS_QUERY
public boolean isDialect(java.sql.Connection connection)
isDialect in interface DialectisDialect in class MysqlDialectpublic java.util.List<java.lang.String> getDialectUpdateCandidates()
getDialectUpdateCandidates in interface DialectgetDialectUpdateCandidates in class MysqlDialectpublic boolean isBlueGreenStatusAvailable(java.sql.Connection connection)
isBlueGreenStatusAvailable in interface BlueGreenDialectpublic java.lang.String getBlueGreenStatusQuery()
getBlueGreenStatusQuery in interface BlueGreenDialectpublic @Nullable Pair<java.lang.String,java.lang.String> getHostId(java.sql.Connection connection) throws java.sql.SQLException
getHostId in interface DialectgetHostId in class MysqlDialectjava.sql.SQLException