software.amazon.jdbc.dialect

Class GlobalAuroraPgDialect

java.lang.Object

software.amazon.jdbc.dialect.PgDialect

software.amazon.jdbc.dialect.AuroraPgDialect

software.amazon.jdbc.dialect.GlobalAuroraPgDialect

All Implemented Interfaces:

AuroraLimitlessDialect, BlueGreenDialect, Dialect, GlobalAuroraTopologyDialect, TopologyDialect

public class GlobalAuroraPgDialect
extends AuroraPgDialect
implements GlobalAuroraTopologyDialect

Field Summary

Fields

Modifier and Type	Field and Description
protected static java.lang.String	GLOBAL_INSTANCE_STATUS_FUNC_EXISTS_QUERY
protected static java.lang.String	GLOBAL_STATUS_FUNC_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.AuroraPgDialect

AURORA_UTILS_EXIST_QUERY, BG_STATUS_QUERY, BG_TOPOLOGY_EXISTS_QUERY, INSTANCE_ID_QUERY, LIMITLESS_ROUTER_ENDPOINT_QUERY, TOPOLOGY_EXISTS_QUERY, TOPOLOGY_QUERY, WRITER_ID_QUERY

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

dialectUtils, HOST_ALIAS_QUERY, HOST_ID_EXPRESSION, HOST_ID_QUERY, IS_READER_QUERY, PG_PROC_EXISTS_QUERY, VERSION_QUERY

Constructor Summary

Constructors

Constructor and Description
GlobalAuroraPgDialect()

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

getBlueGreenStatusQuery, getHostId, getLimitlessRouterEndpointQuery, getWriterIdQuery, isBlueGreenStatusAvailable

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

getDefaultPort, getExceptionHandler, getFailoverRestrictions, getHostAliasQuery, getHostRole, 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_FUNC_EXISTS_QUERY

protected static final java.lang.String GLOBAL_STATUS_FUNC_EXISTS_QUERY

See Also:

Constant Field Values

GLOBAL_INSTANCE_STATUS_FUNC_EXISTS_QUERY

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

GlobalAuroraPgDialect

public GlobalAuroraPgDialect()

Method Detail

isDialect

public boolean isDialect(java.sql.Connection connection)

Specified by:

isDialect in interface Dialect

Overrides:

isDialect in class AuroraPgDialect

getDialectUpdateCandidates

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

Specified by:

getDialectUpdateCandidates in interface Dialect

Overrides:

getDialectUpdateCandidates in class AuroraPgDialect

getHostListProviderSupplier

public HostListProviderSupplier getHostListProviderSupplier()

Specified by:

getHostListProviderSupplier in interface Dialect

Overrides:

getHostListProviderSupplier in class AuroraPgDialect

getTopologyQuery

public java.lang.String getTopologyQuery()

Specified by:

getTopologyQuery in interface TopologyDialect

Overrides:

getTopologyQuery in class AuroraPgDialect

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