software.amazon.jdbc.dialect

Class MultiAzClusterMysqlDialect

java.lang.Object

software.amazon.jdbc.dialect.MysqlDialect

software.amazon.jdbc.dialect.MultiAzClusterMysqlDialect

All Implemented Interfaces:

Dialect, MultiAzClusterDialect, TopologyDialect

public class MultiAzClusterMysqlDialect
extends MysqlDialect
implements MultiAzClusterDialect

Field Summary

Fields

Modifier and Type	Field and Description
protected static java.lang.String	INSTANCE_ID_QUERY
protected RdsUtils	rdsUtils
protected static java.lang.String	REPORT_HOST_EXISTS_QUERY
protected static java.lang.String	TOPOLOGY_QUERY
protected static java.lang.String	TOPOLOGY_TABLE_EXISTS_QUERY
protected static java.lang.String	WRITER_ID_QUERY
protected static java.lang.String	WRITER_ID_QUERY_COLUMN_NAME

Fields inherited from class software.amazon.jdbc.dialect.MysqlDialect

dialectUtils, HOST_ALIAS_QUERY, HOST_ID_EXPRESSION, HOST_ID_QUERY, IS_READER_QUERY, VERSION_QUERY

Constructor Summary

Constructors

Constructor and Description
MultiAzClusterMysqlDialect()

Method Summary

Modifier and Type	Method and Description
@Nullable java.util.List<java.lang.String>	getDialectUpdateCandidates()
java.util.EnumSet<FailoverRestriction>	getFailoverRestrictions()
@Nullable Pair<java.lang.String,java.lang.String>	getHostId(java.sql.Connection connection)
HostListProviderSupplier	getHostListProviderSupplier()
java.lang.String	getTopologyQuery()
java.lang.String	getWriterIdColumnName()
java.lang.String	getWriterIdQuery()
boolean	isDialect(java.sql.Connection connection)
void	prepareConnectProperties(@NonNull java.util.Properties connectProperties, @NonNull java.lang.String protocol, @NonNull HostSpec hostSpec)

Methods inherited from class software.amazon.jdbc.dialect.MysqlDialect

getDefaultPort, getExceptionHandler, getHostAliasQuery, getHostRole, getServerVersionQuery

Methods inherited from class java.lang.Object

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

Methods inherited from interface software.amazon.jdbc.dialect.Dialect

filterAvailableHosts, getDefaultPort, getExceptionHandler, getHostAliasQuery, getHostRole, getServerVersionQuery

Field Detail

REPORT_HOST_EXISTS_QUERY

protected static final java.lang.String REPORT_HOST_EXISTS_QUERY

See Also:

Constant Field Values

TOPOLOGY_TABLE_EXISTS_QUERY

protected static final java.lang.String TOPOLOGY_TABLE_EXISTS_QUERY

See Also:

Constant Field Values

TOPOLOGY_QUERY

protected static final java.lang.String TOPOLOGY_QUERY

See Also:

Constant Field Values

INSTANCE_ID_QUERY

protected static final java.lang.String INSTANCE_ID_QUERY

See Also:

Constant Field Values

WRITER_ID_QUERY

protected static final java.lang.String WRITER_ID_QUERY

See Also:

Constant Field Values

WRITER_ID_QUERY_COLUMN_NAME

protected static final java.lang.String WRITER_ID_QUERY_COLUMN_NAME

See Also:

Constant Field Values

rdsUtils

protected final RdsUtils rdsUtils

Constructor Detail

MultiAzClusterMysqlDialect

public MultiAzClusterMysqlDialect()

Method Detail

isDialect

public boolean isDialect(java.sql.Connection connection)

Specified by:

isDialect in interface Dialect

Overrides:

isDialect in class MysqlDialect

getDialectUpdateCandidates

public @Nullable java.util.List<java.lang.String> getDialectUpdateCandidates()

Specified by:

getDialectUpdateCandidates in interface Dialect

Overrides:

getDialectUpdateCandidates in class MysqlDialect

getHostListProviderSupplier

public HostListProviderSupplier getHostListProviderSupplier()

Specified by:

getHostListProviderSupplier in interface Dialect

Overrides:

getHostListProviderSupplier in class MysqlDialect

prepareConnectProperties

public void prepareConnectProperties(@NonNull java.util.Properties connectProperties,
                                     @NonNull java.lang.String protocol,
                                     @NonNull HostSpec hostSpec)

Specified by:

prepareConnectProperties in interface Dialect

Overrides:

prepareConnectProperties in class MysqlDialect

getFailoverRestrictions

public java.util.EnumSet<FailoverRestriction> getFailoverRestrictions()

Specified by:

getFailoverRestrictions in interface Dialect

Overrides:

getFailoverRestrictions in class MysqlDialect

getTopologyQuery

public java.lang.String getTopologyQuery()

Specified by:

getTopologyQuery in interface TopologyDialect

getHostId

public @Nullable Pair<java.lang.String,java.lang.String> getHostId(java.sql.Connection connection)
                                                            throws java.sql.SQLException

Specified by:

getHostId in interface Dialect

Overrides:

getHostId in class MysqlDialect

Throws:

java.sql.SQLException

getWriterIdQuery

public java.lang.String getWriterIdQuery()

Specified by:

getWriterIdQuery in interface MultiAzClusterDialect

Specified by:

getWriterIdQuery in interface TopologyDialect

getWriterIdColumnName

public java.lang.String getWriterIdColumnName()

Specified by:

getWriterIdColumnName in interface MultiAzClusterDialect