software.amazon.jdbc.targetdriverdialect

Class MariadbTargetDriverDialect

java.lang.Object

software.amazon.jdbc.targetdriverdialect.GenericTargetDriverDialect

software.amazon.jdbc.targetdriverdialect.MariadbTargetDriverDialect

All Implemented Interfaces:

TargetDriverDialect

public class MariadbTargetDriverDialect
extends GenericTargetDriverDialect

Field Summary

Fields inherited from class software.amazon.jdbc.targetdriverdialect.GenericTargetDriverDialect

ALLOWED_ON_CLOSED_METHODS, NETWORK_BOUND_METHODS_FOR_ENTIRE_RESULTSET

Constructor Summary

Constructors

Constructor and Description
MariadbTargetDriverDialect()

Method Summary

Modifier and Type	Method and Description
java.util.Set<java.lang.String>	getAllowedOnConnectionMethodNames()
@Nullable java.lang.String	getSQLQueryString(java.sql.PreparedStatement ps)
boolean	isDialect(java.sql.Driver driver)
boolean	isDialect(java.lang.String dataSourceClass)
boolean	isDriverRegistered()
ConnectInfo	prepareConnectInfo(@NonNull java.lang.String protocol, @NonNull HostSpec hostSpec, @NonNull java.util.Properties props)
void	prepareDataSource(@NonNull javax.sql.DataSource dataSource, @NonNull java.lang.String protocol, @NonNull HostSpec hostSpec, @NonNull java.util.Properties props)
java.lang.String	prepareTargetDataSource(@NonNull javax.sql.CommonDataSource dataSource, @NonNull java.lang.String url, @NonNull java.util.Properties props) MariaDB Connector/J data sources accept only url, user, password and loginTimeout as bean properties, so every other setting has to be expressed as a URL parameter.
void	registerDriver()

Methods inherited from class software.amazon.jdbc.targetdriverdialect.GenericTargetDriverDialect

abortConnection, findSQLQueryString, getEncryptedBytes, getNetworkBoundMethodNames, getSQLState, ping, registerDataType, setEncryptedParameter, updateInternalState

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.targetdriverdialect.TargetDriverDialect

removeHostSelectionProperties

Constructor Detail

MariadbTargetDriverDialect

public MariadbTargetDriverDialect()

Method Detail

isDialect

public boolean isDialect(java.sql.Driver driver)

Specified by:

isDialect in interface TargetDriverDialect

Overrides:

isDialect in class GenericTargetDriverDialect

isDialect

public boolean isDialect(java.lang.String dataSourceClass)

Specified by:

isDialect in interface TargetDriverDialect

Overrides:

isDialect in class GenericTargetDriverDialect

prepareConnectInfo

public ConnectInfo prepareConnectInfo(@NonNull java.lang.String protocol,
                                      @NonNull HostSpec hostSpec,
                                      @NonNull java.util.Properties props)
                               throws java.sql.SQLException

Specified by:

prepareConnectInfo in interface TargetDriverDialect

Overrides:

prepareConnectInfo in class GenericTargetDriverDialect

Throws:

java.sql.SQLException

prepareDataSource

public void prepareDataSource(@NonNull javax.sql.DataSource dataSource,
                              @NonNull java.lang.String protocol,
                              @NonNull HostSpec hostSpec,
                              @NonNull java.util.Properties props)
                       throws java.sql.SQLException

Specified by:

prepareDataSource in interface TargetDriverDialect

Overrides:

prepareDataSource in class GenericTargetDriverDialect

Throws:

java.sql.SQLException

prepareTargetDataSource

public java.lang.String prepareTargetDataSource(@NonNull javax.sql.CommonDataSource dataSource,
                                                @NonNull java.lang.String url,
                                                @NonNull java.util.Properties props)

MariaDB Connector/J data sources accept only url, user, password and loginTimeout as bean properties, so every other setting has to be expressed as a URL parameter. Two adjustments are made:

• permitMysqlScheme is added for a jdbc:mysql:// URL. The driver rejects the MySQL scheme outright ("Wrong mariaDB url") unless the URL itself carries this parameter, and it cannot be set as a bean property.
• The target-driver settings are moved into the URL: the wrapper keep-alive and timeout properties (whose names and millisecond unit match MariaDB's own options), plus every property the wrapper does not recognize, which by definition belongs to the target driver (for example allowPublicKeyRetrieval or sslMode). Without this they would be dropped, because the data source has no bean setter for them. This mirrors what the non-XA data source path does through the connection URL builder.

Credentials are deliberately kept out of the URL; they are applied through the setUser / setPassword bean setters.

Parameters:

dataSource - the target driver data source being configured.

url - the target driver URL, with AWS Wrapper parameters already removed.

props - the effective connection properties, including AWS Wrapper properties.

Returns:

the URL to apply to the target data source.

isDriverRegistered

public boolean isDriverRegistered()
                           throws java.sql.SQLException

Specified by:

isDriverRegistered in interface TargetDriverDialect

Overrides:

isDriverRegistered in class GenericTargetDriverDialect

Throws:

java.sql.SQLException

registerDriver

public void registerDriver()
                    throws java.sql.SQLException

Specified by:

registerDriver in interface TargetDriverDialect

Overrides:

registerDriver in class GenericTargetDriverDialect

Throws:

java.sql.SQLException

getAllowedOnConnectionMethodNames

public java.util.Set<java.lang.String> getAllowedOnConnectionMethodNames()

Specified by:

getAllowedOnConnectionMethodNames in interface TargetDriverDialect

Overrides:

getAllowedOnConnectionMethodNames in class GenericTargetDriverDialect

getSQLQueryString

public @Nullable java.lang.String getSQLQueryString(java.sql.PreparedStatement ps)

Specified by:

getSQLQueryString in interface TargetDriverDialect

Overrides:

getSQLQueryString in class GenericTargetDriverDialect