software.amazon.jdbc.dialect

Class AuroraPgDialect

java.lang.Object

software.amazon.jdbc.dialect.PgDialect

software.amazon.jdbc.dialect.AuroraPgDialect

All Implemented Interfaces:

AuroraLimitlessDialect, BlueGreenDialect, Dialect, TopologyDialect

Direct Known Subclasses:

GlobalAuroraPgDialect

public class AuroraPgDialect
extends PgDialect
implements TopologyDialect, AuroraLimitlessDialect, BlueGreenDialect

Field Summary

Fields

Modifier and Type	Field and Description
protected static java.lang.String	AURORA_UTILS_EXIST_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	LIMITLESS_ROUTER_ENDPOINT_QUERY
protected static java.lang.String	TOPOLOGY_EXISTS_QUERY
protected static java.lang.String	TOPOLOGY_QUERY
protected static java.lang.String	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
AuroraPgDialect()

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()
java.lang.String	getLimitlessRouterEndpointQuery()
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.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.Dialect

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

Field Detail

AURORA_UTILS_EXIST_QUERY

protected static final java.lang.String AURORA_UTILS_EXIST_QUERY

See Also:

Constant Field Values

TOPOLOGY_EXISTS_QUERY

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

LIMITLESS_ROUTER_ENDPOINT_QUERY

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

AuroraPgDialect

public AuroraPgDialect()

Method Detail

isDialect

public boolean isDialect(java.sql.Connection connection)

Specified by:

isDialect in interface Dialect

Overrides:

isDialect in class PgDialect

getDialectUpdateCandidates

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

Specified by:

getDialectUpdateCandidates in interface Dialect

Overrides:

getDialectUpdateCandidates in class PgDialect

getHostListProviderSupplier

public HostListProviderSupplier getHostListProviderSupplier()

Specified by:

getHostListProviderSupplier in interface Dialect

Overrides:

getHostListProviderSupplier in class PgDialect

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 PgDialect

Throws:

java.sql.SQLException

getWriterIdQuery

public java.lang.String getWriterIdQuery()

Specified by:

getWriterIdQuery in interface TopologyDialect

getLimitlessRouterEndpointQuery

public java.lang.String getLimitlessRouterEndpointQuery()

Specified by:

getLimitlessRouterEndpointQuery in interface AuroraLimitlessDialect

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