software.amazon.jdbc.dialect

Class AuroraMysqlDialect

java.lang.Object

software.amazon.jdbc.dialect.MysqlDialect

software.amazon.jdbc.dialect.AuroraMysqlDialect

All Implemented Interfaces:

BlueGreenDialect, Dialect, TopologyDialect

Direct Known Subclasses:

GlobalAuroraMysqlDialect

public class AuroraMysqlDialect
extends MysqlDialect
implements TopologyDialect, BlueGreenDialect

Field Summary

Fields

Modifier and Type	Field and Description
protected static java.lang.String	AURORA_VERSION_EXISTS_QUERY
protected static java.lang.String	BG_STATUS_QUERY
protected static java.lang.String	BG_TOPOLOGY_EXISTS_QUERY
protected static java.lang.String	INSTANCE_ID_QUERY
protected static java.lang.String	IS_READER_QUERY
protected static java.lang.String	TOPOLOGY_QUERY
protected static java.lang.String	WRITER_ID_QUERY

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

dialectUtils, HOST_ALIAS_QUERY, HOST_ID_EXPRESSION, HOST_ID_QUERY, VERSION_QUERY

Constructor Summary

Constructors

Constructor and Description
AuroraMysqlDialect()

Method Summary

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)
HostListProviderSupplier	getHostListProviderSupplier()
HostRole	getHostRole(java.sql.Connection conn)
java.lang.String	getTopologyQuery()
java.lang.String	getWriterIdQuery()
boolean	isBlueGreenStatusAvailable(java.sql.Connection connection)
boolean	isDialect(java.sql.Connection connection)

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

getDefaultPort, getExceptionHandler, getFailoverRestrictions, getHostAliasQuery, getServerVersionQuery, prepareConnectProperties

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, getFailoverRestrictions, getHostAliasQuery, getServerVersionQuery, prepareConnectProperties

Field Detail

AURORA_VERSION_EXISTS_QUERY

protected static final java.lang.String AURORA_VERSION_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

IS_READER_QUERY

protected static final java.lang.String IS_READER_QUERY

See Also:

Constant Field Values

BG_TOPOLOGY_EXISTS_QUERY

protected static final java.lang.String BG_TOPOLOGY_EXISTS_QUERY

See Also:

Constant Field Values

BG_STATUS_QUERY

protected static final java.lang.String BG_STATUS_QUERY

See Also:

Constant Field Values

Constructor Detail

AuroraMysqlDialect

public AuroraMysqlDialect()

Method Detail

isDialect

public boolean isDialect(java.sql.Connection connection)

Specified by:

isDialect in interface Dialect

Overrides:

isDialect in class MysqlDialect

getDialectUpdateCandidates

public 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

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 TopologyDialect

getHostRole

public HostRole getHostRole(java.sql.Connection conn)
                     throws java.sql.SQLException

Specified by:

getHostRole in interface Dialect

Overrides:

getHostRole in class MysqlDialect

Throws:

java.sql.SQLException

isBlueGreenStatusAvailable

public boolean isBlueGreenStatusAvailable(java.sql.Connection connection)

Specified by:

isBlueGreenStatusAvailable in interface BlueGreenDialect

getBlueGreenStatusQuery

public java.lang.String getBlueGreenStatusQuery()

Specified by:

getBlueGreenStatusQuery in interface BlueGreenDialect