Acerca De MariaDB Connector/J

MariaDB Connector/J es usado para conectar desarrollo de aplicaciones en Java para MariaDB y MySQL bases de datos usando el estandar JDBC API. La libreria es LGPL licensed.

Acerca De MariaDB Connector/J

MariaDB el Conector/J es un Tipo 4 conductor JDBC. Fue desarrollado expresamente como un peso ligero JDBC el conector para el empleo con MariaDB y servidores de base de datos MySQL. Estaba al principio basado en la Llovizna JDBC el código con numerosas adiciones y correcciones de errores.

Obtención del driver

MariaDB el código original de Conector/J tarballs puede ser descargado de : https://downloads.mariadb.org/connector-java/

Pre-construccion archivos .jar pueden ser descargados desde: https://mariadb.com/my_portal/download/java-client

Instalación del driver

La instalación de la biblioteca de cliente es muy simple. El archivo jar debería ser guardado en un lugar apropiado para su uso y el classpath de su aplicacion uso cambiado para incluir Conector/J MariaDB más bien que su corriente conector.

Usando maven :

<dependency>
    <groupId>org.mariadb.jdbc</groupId>
    <artifactId>mariadb-java-client</artifactId>
    <version>xxx</version>
</dependency>

Requerimientos

• com.sun.JNA es usado por algunas funciones de biblioteca y un jar está disponible en https://github.com/twall/jna
  • sólo necesario cuando conecta al servidor con socket unix o ventanas memoria compartida
• A MariaDB or MySQL Server
• maven (Sólo si desea crear desde el origen)

Código fuente

El código fuente está disponible en GitHub: https://github.com/MariaDB/mariadb-connector-j Y el desarrollo más reciente Se puede obtener mediante el siguiente comando:

git clone https://github.com/MariaDB/mariadb-connector-j.git

Licencia

Licencia Pública General Menor GNU publicada por la Free Software Foundation; Ya sea la versión 2.1 de la Licencia, o (a su elección) cualquier versión posterior.

Construcción y prueba del driver

Esta sección trata de construir el conector desde la fuente y probarlo. Si Usted ha descargado un conector preparado, en un archivo .jar, entonces esta sección Pueden omitirse.

MariaDB Client Library para aplicaciones Java utiliza maven para la creación. Tú primero Necesita asegurarse de que tiene tanto java como maven instalados en su servidor antes de Puede construir el controlador.

Para ejecutar la prueba de unidad, necesitará un servidor MariaDB o MySQL Localhost (en el puerto TCP predeterminado 3306) y una base de datos llamada 'testj', y el usuario 'Root' con una contraseña vacía

git clone https://github.com/MariaDB/mariadb-connector-j.git #  Or, unpack the source distribution tarball
cd mariadb-connector-j
# For the unit test run, start local mysqld mysqld, 
# ensure that user root with empty password can login
mvn package
# If you want to build without running unit  tests, use
# mvn -Dmaven.test.skip=true package

After that, you should have JDBC jar mariadb-java-client-x.y.z.jar in the 'target' subdirectory

Uso del controlador

Las subsecciones siguientes muestran el formato de cadenas de conexión JDBC para MariaDB y servidores de bases de datos MySQL. Además, se proporciona código de ejemplo que muestra cómo conectarse a uno de estos servidores y crear una tabla.

Obteniendo una nueva conexión

Existen dos formas estándar para obtener una conexión:

Uso de DriverManager

La forma preferida de conectarse es usarhttps:docs.oracle.com/javase/7/docs/api/java/sql/DriverManager.html. Las aplicaciones diseñadas para utilizar el gestor de controladores para localizar el punto de entrada necesitan No más configuración. MariaDB Connector / J Ser cargado automáticamente y utilizado de la manera que cualquier conductor anterior de MySQL Ha estado.

Ejemplo:

Connection connection = DriverManager.getConnection("jdbc:mariadb://localhost:3306/DB?user=root&password=myPassword");

The legacy way of loading a JDBC driver (using Class.forName("org.mariadb.jdbc.Driver")) still works.

Uso de la piscina externa

Cuando se utiliza un grupo de conexiones externo, se debe configurar la clase de controlador mariadb org.mariadb.jdbc.Driver .

Ejemplo usando hikariCP JDBC connection pool:

        final HikariDataSource ds = new HikariDataSource();
        ds.setMaximumPoolSize(20);
        ds.setDriverClassName("org.mariadb.jdbc.Driver");
        ds.setJdbcUrl("jdbc:mariadb://localhost:3306/db");
        ds.addDataSourceProperty("user", "root");
        ds.addDataSourceProperty("password", "myPassword");
        ds.setAutoCommit(false);

Tenga en cuenta que la clase de controlador proporcionada por MariaDB Connector / J no es com.mysql.jdbc.Driver peroorg.mariadb.jdbc.Driver!

La org.mariadb.jdbc.MariaDbDataSource Class se puede utilizar cuando la configuración de datasource de la agrupación sólo permite la implementación de java.sql.Datasource.

Cadenas de conexión

El formato de la cadena de conexión JDBC es

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

HostDescription:

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

El host debe ser un nombre DNS o una dirección IP. En caso de ipv6 y simple host Descripción, la dirección IP debe escribirse entre paréntesis. El puerto predeterminado Es 3306 . El tipo predeterminado es master . Si replication failover está establecido, de forma predeterminada el primer host es maestro y los demás son esclavos.

Ejemplos:

• localhost:3306
• [2001:0660:7401:0200:0000:0000:0edf:bdd7]:3306
• somehost.com:3306
• address=(host=localhost)(port=3306)(type=master)

Parámetros de conmutación por error

La conmutación por error se introdujo en Connector/J 1.2.0.

Ver failover description para mas informacion.

Parámetros URL opcionales

Observación general: Se aceptan opciones desconocidas y se ignoran en silencio.

Actualmente se admiten las siguientes opciones.

Opciones esenciales

TLS (SSL)

mas informacion en Using TLS/SSL con MariaDB java connector

Conectarse

utilizan con poca frecuencia

parámetros de conmutación por error / Alta disponibilidad URL

JDBC notas de implementación de la API

"LOAD DATA INFILE"

La forma más rápida para cargar una gran cantidad de datos está utilizando DATOS DE CARGA INFILE.
Sin embargo, el uso de "LOAD DATA LOCAL INFILE" (es decir: la carga de un fichero desde el cliente) puede ser un problema de seguridad:

• Un "hombre en el medio" servidor proxy puede cambiar el archivo real solicitada por el servidor por lo que el cliente enviará un archivo local a este proxy.
• si alguien puede ejecutar una consulta desde el cliente, que puede tener acceso a cualquier archivo en el cliente (según los derechos del usuario que ejecuta el proceso del cliente). Una opción específica "allowLocalInfile" (por defecto a true) puede desactivar la funcionalidad del lado del cliente. La variable local_infile global puede desactivar la carga de datos LOCAL INFILE en el lado del servidor. Un método no JDBC puede permitir el uso de este tipo de consulta sin este problema de seguridad: La aplicación tiene que crear un InputStream con el archivo a cargar. Si MariaDbStatement.setLocalInfileInputStream (InputStream flujoEntrada) se establece, el flujoEntrada se enviará al servidor, reemplazando el contenido del archivo (trabajando incluso con la opción "allowLocalInfile" desactivado). Ejemplo de código:

        Statement statement = ...
        InputStream in = new FileInputStream("/file.sql");

        if (statement.isWrapperFor(MariaDbStatement.class)) {
            MariaDbStatement mariaDbStatement = statement.unwrap(MariaDbStatement.class);
            mariaDbStatement.setLocalInfileInputStream(in);
            String sql = "LOAD DATA LOCAL INFILE 'dummyFileName'"
                        + " INTO TABLE gigantic_load_data_infile "
                        + " FIELDS TERMINATED BY '\\t' ENCLOSED BY ''"
                        + " ESCAPED BY '\\\\' LINES TERMINATED BY '\\n'";
            statement.execute(sql);
        } else {
            in.close();
            throw new RuntimeException("Mariadb JDBC adaptor must be used");
        }

Desde 1.5.0, interceptores ahora puede filtrar los datos CARGA INFILE consultas locales en función de nombre de archivo. Estos interceptores deben implementar el org.mariadb.jdbc.LocalInfileInterceptor interfaz. Interceptores utilizan el ServiceLoader patrón, por lo que los interceptores se deben definir en el / los servicios / org.mariadb.jdbc.LocalInfileInterceptor archivo META-INF.
Ejemplo: Crear la META-INF / services / org.mariadb.jdbc.LocalInfileInterceptor archivo con contenido org.project.LocalInfileInterceptorImpl.

 public class LocalInfileInterceptorImpl implements LocalInfileInterceptor {
     @Override
     public boolean validate(String fileName) {
         File file = new File(fileName);
         String absolutePath = file.getAbsolutePath();
         String filePath = absolutePath.substring(0,absolutePath.lastIndexOf(File.separator));
         return filePath.equals("/var/tmp/exchanges");
     }
 }

Puede evitar definir el archivo META-INF / services usando google de auto-servicio marco Utilizando el ejemplo anterior, sólo tiene que añadir @AutoService (LocalInfileInterceptor.class), y su interceptor se definirá de forma automática.

 @AutoService(LocalInfileInterceptor.class)
 public class LocalInfileInterceptorImpl implements LocalInfileInterceptor {
     @Override
     public boolean validate(String fileName) {
         File file = new File(fileName);
         String absolutePath = file.getAbsolutePath();
         String filePath = absolutePath.substring(0,absolutePath.lastIndexOf(File.separator));
         return filePath.equals("/var/tmp/exchanges");
     }
 }

Ajuste un tiempo de espera de la consulta

Conductor sigue las especificaciones de JDBC, permitiendo Statement.setQueryTimeout () para una declaración particular. Si el objetivo es establecer un tiempo de espera para todas las consultas, desde la versión 10.1.1, MariaDB servidor permite que un [[abortingdeclaraciones / | solución para limitar el tiempo de consulta]] mediante el establecimiento de una variable del sistema max_statement_time. Esta solución se encargará de consulta tiempo de espera mejor (y más rápido) que las soluciones de Java (JPA2, "javax.persistence.query.timeout", Piscinas solución integrada como Tomcat JDBC-pool "QueryTimeout" ...). Opción "sessionVariables" permiso para establecer esta variable de sistema fácilmente: Ejemplo:

#will set a maximum query timeout of 10 seconds for this connection
jdbc:mariadb://localhost/db?user=user&sessionVariables=max_statement_time=10

conjuntos de resultados Streaming

Por defecto, << código >> Statement.executeQuery () << / >> código leerá el resultado conjunto completo desde el servidor. Con grandes conjuntos de resultados, esto requerirá grandes cantidades de memoria.
Para evitar el uso de demasiada memoria, en lugar utilizar Statement.setFetchSize (int numberOfRowInMemory) para indicar el número de filas que se almacena en la memoria
Ejemplo:
utilizando Statement.setFetchSize(1000) indicates that 1000 rows will be stored in memory.
So, when the query has executed, 1000 rows will be in memory. After 1000 ResultSet.next(), los próximos 1000 filas serán almacenados en la memoria, y así sucesivamente. Tenga en cuenta que el servidor espera por lo general los clientes para leer el conjunto de resultados con relativa rapidez. El net_write_timeout servidor variable controla este comportamiento (por defecto es 60). Si no que los resultados sean manipulados de esta cantidad de tiempo que existe la posibilidad diferente:

• Si su versión del servidor> 10.1.2, puede utilizar la consulta "sentencia SET net_write_timeout = 10000 PARA XXX" XXX con la consulta "normal". Esto indicará que específicamente para esta consulta, net_write_timeout se establece en un tiempo más largo (10 000 en este ejemplo).
• para los servidores de mayor edad, una consulta específica tendrá que establecer temporalmente net_write_timeout ( "DECLARACIÓN net_write_timeout = SET ..."), y la puso de nuevo más tarde.
• si su aplicación por lo general utiliza una gran cantidad de largas consultas con ir a buscar el tamaño, la conexión se puede establecer utilizando la opción "sessionVariables = net_write_timeout = xxx" Incluso el uso de setFetchSize, el servidor enviará los resultados al cliente. Enviar otra consulta en la misma conexión será una excepción hasta que todos los resultados no se leen. Antes de la versión 1.4.0, el único valor aceptado para ir a buscar el tamaño era Statement.setFetchSize(Integer.MIN_VALUE) (equivalent to Statement.setFetchSize(1)). This value is still accepted for compatilibity reasons but rather use Statement.setFetchSize(1) , ya que según JDBC El valor debe ser> = 0.

Declaraciones preparadas

El controlador utiliza declaraciones preparadas servidor como un estándar para comunicarse con la base de datos (ya 1.3.0). Si los "allowMultiQueries" u opciones "rewriteBatchedStatements" se establecen en true, el conductor sólo utilizará el protocolo de texto. declaraciones preparadas (parámetro de sustitución) es manejado por el conductor, en el lado del cliente.

CallableStatement

aplicación declaración exigible no tendrá que acceder a los metadatos procedimiento almacenado (mysql.proc) tabla si los dos siguientes son verdaderas

• CallableStatement.getMetadata () no se utiliza
• Los parámetros se accede mediante un índice, no por su nombre Cuando sea posible, siguiendo las dos reglas anteriores proporciona una mejor velocidad y elimina las preocupaciones sobre los privilegios SELECT en el mysql.proc mesa.

clases opcional JDBC

Las siguientes interfaces opcionales están implementadas por la clase org.mariadb.jdbc.MariaDbDataSource: javax.sql.DataSource, javax.sql.ConnectionPoolDataSource javax.sql.XADataSource cuidado: org.mariadb.jdbc.MySQLDataSource ya no existe y debe ser reemplazado con org.mariadb.jdbc.MariaDbDataSource desde v1.3.0

Ejemplos de uso

El siguiente código muestra un ejemplo básico de cómo conectarse a un servidor MySQL y MariaDB o crear una tabla.

La creación de una tabla en un servidor MariaDB o MySQL

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();