software.amazon.jdbc.dialect

Class MultiAzClusterPgDialect

java.lang.Object

software.amazon.jdbc.dialect.PgDialect

software.amazon.jdbc.dialect.MultiAzClusterPgDialect

All Implemented Interfaces:

Dialect, MultiAzClusterDialect, TopologyDialect

public class MultiAzClusterPgDialect
extends PgDialect
implements MultiAzClusterDialect

Field Summary

Fields

Modifier and Type	Field and Description
protected static java.lang.String	INSTANCE_ID_QUERY
protected static java.lang.String	IS_RDS_CLUSTER_QUERY
protected static java.lang.String	TOPOLOGY_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.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
MultiAzClusterPgDialect()

Method Summary

Modifier and Type	Method and Description
@Nullable java.util.List<java.lang.String>	getDialectUpdateCandidates()
ExceptionHandler	getExceptionHandler()
@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)

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

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

Field Detail

IS_RDS_CLUSTER_QUERY

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

Constructor Detail

MultiAzClusterPgDialect

public MultiAzClusterPgDialect()

Method Detail

isDialect

public boolean isDialect(java.sql.Connection connection)

Specified by:

isDialect in interface Dialect

Overrides:

isDialect in class PgDialect

getDialectUpdateCandidates

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

Specified by:

getDialectUpdateCandidates in interface Dialect

Overrides:

getDialectUpdateCandidates in class PgDialect

getExceptionHandler

public ExceptionHandler getExceptionHandler()

Specified by:

getExceptionHandler in interface Dialect

Overrides:

getExceptionHandler 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 MultiAzClusterDialect

Specified by:

getWriterIdQuery in interface TopologyDialect

getWriterIdColumnName

public java.lang.String getWriterIdColumnName()

Specified by:

getWriterIdColumnName in interface MultiAzClusterDialect