software.amazon.jdbc.dialect

Class GlobalAuroraMysqlDialect

java.lang.Object

software.amazon.jdbc.dialect.MysqlDialect

software.amazon.jdbc.dialect.AuroraMysqlDialect

software.amazon.jdbc.dialect.GlobalAuroraMysqlDialect

All Implemented Interfaces:

BlueGreenDialect, Dialect, GlobalAuroraTopologyDialect, TopologyDialect

public class GlobalAuroraMysqlDialect
extends AuroraMysqlDialect
implements GlobalAuroraTopologyDialect

Field Summary

Fields

Modifier and Type	Field and Description
protected static java.lang.String	GLOBAL_INSTANCE_STATUS_EXISTS_QUERY
protected static java.lang.String	GLOBAL_STATUS_TABLE_EXISTS_QUERY
protected static java.lang.String	GLOBAL_TOPOLOGY_QUERY
protected RdsUtils	rdsUtils
protected static java.lang.String	REGION_BY_INSTANCE_ID_QUERY
protected static java.lang.String	REGION_COUNT_QUERY

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

AURORA_VERSION_EXISTS_QUERY, BG_STATUS_QUERY, BG_TOPOLOGY_EXISTS_QUERY, INSTANCE_ID_QUERY, IS_READER_QUERY, TOPOLOGY_QUERY, 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
GlobalAuroraMysqlDialect()

Method Summary

Modifier and Type	Method and Description
java.util.List<HostSpec>	filterAvailableHosts(@NonNull java.util.List<HostSpec> hosts, @Nullable java.util.Set<java.lang.String> accessibleRegions) Filters the provided list of hosts by the set of accessible AWS regions.
java.util.List<java.lang.String>	getDialectUpdateCandidates()
HostListProviderSupplier	getHostListProviderSupplier()
java.lang.String	getRegionByInstanceIdQuery()
java.lang.String	getTopologyQuery()
boolean	isDialect(java.sql.Connection connection)

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

getBlueGreenStatusQuery, getHostId, getHostRole, getWriterIdQuery, isBlueGreenStatusAvailable

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.TopologyDialect

getWriterIdQuery

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

getDefaultPort, getExceptionHandler, getFailoverRestrictions, getHostAliasQuery, getHostId, getHostRole, getServerVersionQuery, prepareConnectProperties

Field Detail

rdsUtils

protected final RdsUtils rdsUtils

GLOBAL_STATUS_TABLE_EXISTS_QUERY

protected static final java.lang.String GLOBAL_STATUS_TABLE_EXISTS_QUERY

See Also:

Constant Field Values

GLOBAL_INSTANCE_STATUS_EXISTS_QUERY

protected static final java.lang.String GLOBAL_INSTANCE_STATUS_EXISTS_QUERY

See Also:

Constant Field Values

GLOBAL_TOPOLOGY_QUERY

protected static final java.lang.String GLOBAL_TOPOLOGY_QUERY

See Also:

Constant Field Values

REGION_COUNT_QUERY

protected static final java.lang.String REGION_COUNT_QUERY

See Also:

Constant Field Values

REGION_BY_INSTANCE_ID_QUERY

protected static final java.lang.String REGION_BY_INSTANCE_ID_QUERY

See Also:

Constant Field Values

Constructor Detail

GlobalAuroraMysqlDialect

public GlobalAuroraMysqlDialect()

Method Detail

isDialect

public boolean isDialect(java.sql.Connection connection)

Specified by:

isDialect in interface Dialect

Overrides:

isDialect in class AuroraMysqlDialect

getDialectUpdateCandidates

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

Specified by:

getDialectUpdateCandidates in interface Dialect

Overrides:

getDialectUpdateCandidates in class AuroraMysqlDialect

getHostListProviderSupplier

public HostListProviderSupplier getHostListProviderSupplier()

Specified by:

getHostListProviderSupplier in interface Dialect

Overrides:

getHostListProviderSupplier in class AuroraMysqlDialect

getTopologyQuery

public java.lang.String getTopologyQuery()

Specified by:

getTopologyQuery in interface TopologyDialect

Overrides:

getTopologyQuery in class AuroraMysqlDialect

getRegionByInstanceIdQuery

public java.lang.String getRegionByInstanceIdQuery()

Specified by:

getRegionByInstanceIdQuery in interface GlobalAuroraTopologyDialect

filterAvailableHosts

public java.util.List<HostSpec> filterAvailableHosts(@NonNull java.util.List<HostSpec> hosts,
                                                     @Nullable java.util.Set<java.lang.String> accessibleRegions)

Description copied from interface: Dialect

Filters the provided list of hosts by the set of accessible AWS regions. Implementations that do not support multi-region clusters should return the original list unchanged. Dialects supporting multi-region clusters (e.g., Global Aurora) should restrict the host list to nodes in accessible regions.

Specified by:

filterAvailableHosts in interface Dialect

Parameters:

hosts - the list of hosts to filter

accessibleRegions - the set of accessible AWS regions (lowercase), or null for no restriction

Returns:

the filtered list of hosts, or the original list if no filtering is applied