software.amazon.jdbc.dialect

Class MysqlDialect

java.lang.Object

software.amazon.jdbc.dialect.MysqlDialect

All Implemented Interfaces:

Dialect

Direct Known Subclasses:

AuroraMysqlDialect, MultiAzClusterMysqlDialect, RdsMysqlDialect

public class MysqlDialect
extends java.lang.Object
implements Dialect

Field Summary

Fields

Modifier and Type	Field and Description
protected DialectUtils	dialectUtils
protected static java.lang.String	HOST_ALIAS_QUERY
protected static java.lang.String	HOST_ID_EXPRESSION
protected static java.lang.String	HOST_ID_QUERY
protected static java.lang.String	IS_READER_QUERY
protected static java.lang.String	VERSION_QUERY

Constructor Summary

Constructors

Constructor and Description
MysqlDialect()

Method Summary

Modifier and Type	Method and Description
int	getDefaultPort()
@Nullable java.util.List<java.lang.String>	getDialectUpdateCandidates()
ExceptionHandler	getExceptionHandler()
java.util.EnumSet<FailoverRestriction>	getFailoverRestrictions()
java.lang.String	getHostAliasQuery()
@Nullable Pair<java.lang.String,java.lang.String>	getHostId(java.sql.Connection connection)
HostListProviderSupplier	getHostListProviderSupplier()
HostRole	getHostRole(java.sql.Connection conn)
java.lang.String	getServerVersionQuery()
boolean	isDialect(java.sql.Connection connection)
void	prepareConnectProperties(@NonNull java.util.Properties connectProperties, @NonNull java.lang.String protocol, @NonNull HostSpec hostSpec)

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

Field Detail

VERSION_QUERY

protected static final java.lang.String VERSION_QUERY

See Also:

Constant Field Values

HOST_ID_EXPRESSION

protected static final java.lang.String HOST_ID_EXPRESSION

See Also:

Constant Field Values

HOST_ALIAS_QUERY

protected static final java.lang.String HOST_ALIAS_QUERY

See Also:

Constant Field Values

HOST_ID_QUERY

protected static final java.lang.String HOST_ID_QUERY

See Also:

Constant Field Values

IS_READER_QUERY

protected static final java.lang.String IS_READER_QUERY

See Also:

Constant Field Values

dialectUtils

protected final DialectUtils dialectUtils

Constructor Detail

MysqlDialect

public MysqlDialect()

Method Detail

isDialect

public boolean isDialect(java.sql.Connection connection)

Specified by:

isDialect in interface Dialect

getDefaultPort

public int getDefaultPort()

Specified by:

getDefaultPort in interface Dialect

getDialectUpdateCandidates

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

Specified by:

getDialectUpdateCandidates in interface Dialect

getExceptionHandler

public ExceptionHandler getExceptionHandler()

Specified by:

getExceptionHandler in interface Dialect

getHostListProviderSupplier

public HostListProviderSupplier getHostListProviderSupplier()

Specified by:

getHostListProviderSupplier in interface Dialect

prepareConnectProperties

public void prepareConnectProperties(@NonNull java.util.Properties connectProperties,
                                     @NonNull java.lang.String protocol,
                                     @NonNull HostSpec hostSpec)

Specified by:

prepareConnectProperties in interface Dialect

getFailoverRestrictions

public java.util.EnumSet<FailoverRestriction> getFailoverRestrictions()

Specified by:

getFailoverRestrictions in interface Dialect

getServerVersionQuery

public java.lang.String getServerVersionQuery()

Specified by:

getServerVersionQuery in interface Dialect

getHostRole

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

Specified by:

getHostRole in interface Dialect

Throws:

java.sql.SQLException

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

Throws:

java.sql.SQLException

getHostAliasQuery

public java.lang.String getHostAliasQuery()

Specified by:

getHostAliasQuery in interface Dialect