Skip to content

Latest commit

 

History

History
154 lines (115 loc) · 12.2 KB

Use-MariaDB-Connector-j-driver.md

File metadata and controls

154 lines (115 loc) · 12.2 KB

Using the driver

The following subsections show the formatting of JDBC connection strings for MariaDB, MySQL database servers. Additionally, sample code is provided that demonstrates how to connect to one of these servers and create a table.

Driver Manager

Applications designed to use the driver manager to locate the entry point need no further configuration, MariaDB Connector/J will automatically be loaded and used in the way any previous MySQL driver would have been.

Driver Class

Please note that the driver class provided by MariaDB Connector/J is not com.mysql.jdbc.Driver but org.mariadb.jdbc.Driver!

Connection strings

Format of the JDBC connection string is

jdbc:(mysql|mariadb):[replication:|failover:]//<hostDescription>[,<hostDescription>...]/[database][?<key1>=<value1>[&<key2>=<value2>]] 

HostDescription:

<host>[:<portnumber>]  or address=(host=<host>)[(port=<portnumber>)][(type=(master|slave))]

Host must be a DNS name or IP address. In case of ipv6 and simple host description, the IP address must be written inside brackets. The default port is ##3306##. The default type is ##master##. If ##replication## failover is set, by default the first host is master, and the others are slaves.

Examples :

  • localhost:3306
  • somehost.com:3306
  • address=(host=localhost)(port=3306)(type=master)

Failover parameters

Failover was introduced in Connector/J 1.2.0. See failover and high availability documentation for more informations.

Failover option Description
failover High availability (random picking connection initialisation) with failover support for master replication cluster (for example Galera).
Since 1.2.0
sequential Failover support for master replication cluster (for example Galera) without High availability.
the host will be connected in the order in which they were declared.

Example when using the jdbc url string "jdbc:mysql:replication:host1,host2,host3/test" :
When connecting, the driver will always try first host1, and if not available host2 and following. After a host fail, the driver will reconnect according to this order.
Since 1.3.0
replication High availability (random picking connection initialisation) with failover support for master/slaves replication cluster (one or multiple master).
Since 1.2.0
aurora High availability (random picking connection initialisation) with failover support for Amazon Aurora replication cluster.
Since 1.2.0

Optional URL parameters

General remark: Unknown options accepted and are silently ignored.

Following options are currently supported.

Option Description
user Database user name.
since 1.0.0
password Password of database user.
since 1.0.0
useFractionalSeconds Correctly handle subsecond precision in timestamps (feature available with MariaDB 5.3 and later).
May confuse 3rd party components (Hibernated).
Default: true. Since 1.0.0
allowMultiQueries Allows multiple statements in single executeQuery.
example:
insert into ab (i) values (1); insert into ab (i) values (2);
will be rewritten
insert into ab (i) values (1), (2);
Default: false. Since 1.0.0
dumpQueriesOnException If set to 'true', exception thrown during query execution contain query string.
Default: false.Since 1.1.0
useCompression allow compression in MySQL Protocol.
Default: false. Since 1.0.0
useSsl Force SSL on connection.
Alias useSSL works too for mysql compatibility
Default: false. Since 1.1.0
trustServerCertificate When using SSL, do not check server's certificate.
*Default: false. Since 1.1.1
serverSslCert Server's certificatem in DER form, or server's CA certificate.
Can be used in one of 3 forms :
* sslServerCert=/path/to/cert.pem (full path to certificate)
* sslServerCert=classpath:relative/cert.pem (relative to current classpath)
* or as verbatim DER-encoded certificate string "------BEGING CERTIFICATE-----" .
Since 1.1.3
socketFactory to use custom socket factory, set it to full name of the class that implements javax.net.SocketFactory.
Since 1.0.0
tcpNoDelay Sets corresponding option on the connection socket.
Default: true. Since 1.0.0
tcpKeepAlive Sets corresponding option on the connection socket.
Since 1.0.0
tcpAbortiveClose Sets corresponding option on the connection socket.
Since 1.1.1
tcpRcvBuf set buffer size for TCP buffer (SO_RCVBUF).
Since 1.0.0
tcpSndBuf set buffer size for TCP buffer (SO_SNDBUF).
Since 1.0.0
pipe On Windows, specify named pipe name to connect to mysqld.exe.
Since 1.1.3
tinyInt1isBit Datatype mapping flag, handle MySQL Tiny as BIT(boolean).
Default: true.
Since 1.0.0
yearIsDateType Year is date type, rather than numerical.

Default: true.
Since 1.0.0
sessionVariables = pairs separated by comma, mysql session variables, set upon establishing successfull connection.
Since 1.1.0
localSocket Allows to connect to database via Unix domain socket, if server allows it.
The value is the path of Unix domain socket (i.e "socket" database parameter : select @@socket) .
Since 1.1.4
sharedMemory Allowed to connect database via shared memory, if server allows it.
The value is base name of the shared memory.
Since 1.1.4
localSocketAddress Hostname or IP address to bind the connection socket to a local (UNIX domain) socket.
Since 1.1.7
socketTimeout Defined the network socket timeout (SO_TIMEOUT) in milliseconds.
Default: 0 milliseconds(0 disable this timeout). Since 1.1.7*
interactiveClient Session timeout is defined by the wait_timeout server variable. Setting interactiveClient to true will tell server to use the interactive_timeout server variable.
Default: false. Since 1.1.7
useOldAliasMetadataBehavior Metadata ResultSetMetaData.getTableName() return the physical table name. "useOldAliasMetadataBehavior" permit to activate the legacy code that send the table alias if set.
Default: false. Since 1.1.9
createDatabaseIfNotExist the specified database in url will be created if nonexistent.
Default: false. Since 1.1.7*
serverTimezone Defined the server time zone.
to use only if jre server as a different time implementation of the server.
(best to have the same server time zone when possible).
Since 1.1.7*
rewriteBatchedStatements rewrite batchedStatement to have only one server call.
Default: false. Since 1.1.8
useServerPrepStmts if true, preparedStatement will be prepared on server side. If not, Prepared statements (parameter substitution) is handled by the driver, on the client side.
Default: true. Since 1.3.0
connectTimeout The connect the timeout value, in milliseconds, or zero for no timeout.
Default: 0. Since 1.1.8
alwaysAutoGeneratedKeys JDBC permit to retrieve previous insert id's by the Statement.getGeneratedKeys() command.
By default id's are not retrieved. When executing query, additional parameters Statement.NO_GENERATED_KEYS or Statement.RETURN_GENERATED_KEYS indicate if id's must be retrieved, like in command Statement.executeUpdate(String sql, int autoGeneratedKeys).

When option alwaysAutoGeneratedKeys is set to true, insert id's will be retrieved even if no autoGeneratedKeys parameter or Statement.NO_GENERATED_KEYS is set.
Default: false. Since 1.3.0

Failover/High availability URL parameters

Option Description
autoReconnect With basic failover: if true, will attempt to recreate connection after a failover.

With standard failover: if true, will attempt to recreate connection even if there is a temporary solution (like using a master connection temporary until reconnect to a slave connection)

Default is false.

since 1.1.7
retriesAllDown When searching a valid host, maximum number of connection attempts before throwing an exception.

Default: 120 seconds.

since 1.2.0
failoverLoopRetries When searching silently for a valid host, maximum number of connection attempts.

This differ from "retriesAllDown" parameter, because this silent search is for example used after a disconnection of a slave connection when using the master connection

Default: 120.

since 1.2.0
validConnectionTimeout With multiple hosts, after this time in seconds has elapsed it’s verified that the connections haven’t been lost.

When 0, no verification will be done.

Default:120 seconds

since 1.2.0
loadBalanceBlacklistTimeout When a connection fails, this host will be blacklisted during the "loadBalanceBlacklistTimeout" amount of time.

When connecting to a host, the driver will try to connect to a host in the list of not blacklisted hosts and after that only on blacklisted ones if none has been found before that.

This blacklist is shared inside the classloader.

Default: 50 seconds.

since 1.2.0
assureReadOnly If true, in high availability, and switching to a read-only host, assure that this host is in read-only mode by setting session read-only.
Default to false.
Default: 50 seconds. Since 1.3.0

JDBC API Implementation Notes

Streaming result sets

By default, Statement.executeQuery() will read full result set from server before returning. With large result sets, this will require large amounts of memory. Better behavior in this case would be reading row-by-row, with ResultSet.next(), so called "streaming" feature. It is activated using Statement.setFetchSize(Integer.MIN_VALUE)

CallableStatement

Callable statement implementation won't need to access stored procedure metadata ([[mysqlproc-table|mysql.proc]]) table if both of following are true

  • CallableStatement.getMetadata() is not used
  • Parameters are accessed by index, not by name

When possible, following the two rules above provides both better speed and eliminates concerns about SELECT privileges on the [[mysqlproc-table|mysql.proc]] table.

Optional JDBC classes

Following optional interfaces are implemented by the org.mariadb.jdbc.MariaDbDataSource class : javax.sql.DataSource, javax.sql.ConnectionPoolDataSource, javax.sql.XADataSource

Usage examples

The following code provides a basic example of how to connect to a MariaDB or MySQL server and create a table.

Creating a table on a MariaDB or MySQL Server

Connection  connection = DriverManager.getConnection("jdbc:mysql://localhost:3306/test", "username", "password");
Statement stmt = connection.createStatement();
stmt.executeUpdate("CREATE TABLE a (id int not null primary key, value varchar(20))");
stmt.close();
connection.close();