[Java] BasicDataSource no establece las conexiones iniciales indicadas

willy_chaos #1 May '17

Hola a todos, este finde me he propuesto mirar de como trabajar / usar un pool de conexiones a la base de datos. He usado la class BasicDataSource para ello y me encuentro que no termina de hacer caso bien bien al metodo setInitialSize https://commons.apache.org/proper/commons-dbcp/api-1.4/org/apache/commons/dbcp/BasicDataSource.html#setInitialSize(int)

Me explico, el "programa" realiza la siguiente accion:

Pide 2 conexiones a la pool
Espera 10 segundos
Ejecuta 2 insert (1 con autocommit, el otro no)
Espera 10 segundos
Hace un commit para el que no tiene autocommit.
Cierra conexiones

Esto lo hago asi, para que me de tiempo de sobras en el phpmyadmin a ver las conexiones establecidas con la base de datos, y estos son los resultados obtenidos (para el usuario desde la app)

Si le pongo 2 conexiones, en phpmyadmin veo 2 conexiones establecidas
Si le pongo 5 conexiones, en phpmyadmin veo 5 conexiones establecidas
Si le pongo 10 conexiones, en phpmyadmin veo 8! conexiones establecidas
Si le pongo >10 conexiones, en phpmyadmin veo 8! conexiones establecidas

Como puede ser esto, en teoria el setInitialSize, tal y como indica la documentacion establece las conexiones (siempre que ese metodo se llame antes de realizar el primer getConnection). Os dejo el código que tengo hecho.

PoolConnectionsManager

import java.sql.Connection;
import java.sql.SQLException;
import javax.sql.DataSource;
import org.apache.commons.dbcp2.BasicDataSource;

public class PoolConnectionsManager {

// DATABASES ADMITIDAS
public static final int ASTERISK = 0;
//public static final int LIBRA = 1;

// Singleton
private static PoolConnectionsManager singletonInstance = null;

// Array de DataSources, si solo hay una conexion, pues array de 1 posicion
protected BasicDataSource[] dataSourceArray = new BasicDataSource[1];
		
public static PoolConnectionsManager getSingletonInstance() {
	if ( singletonInstance == null ) {
		singletonInstance = new PoolConnectionsManager();
	}
	return singletonInstance;
}

public PoolConnectionsManager() {
	// Deberiamos tener un archivo databases_connections.properties
	
	BasicDataSource bds_Asterisk = new BasicDataSource();
	bds_Asterisk.setDriverClassName("com.mysql.jdbc.Driver");
	bds_Asterisk.setUsername("testdb");
	bds_Asterisk.setPassword("testdb");
	bds_Asterisk.setUrl("jdbc:mysql://192.168.1.200/testdb");
	bds_Asterisk.setInitialSize(20);
	bds_Asterisk.setValidationQuery("select 1");
	
	
	dataSourceArray[ASTERISK] = bds_Asterisk;					// Aprovechamos para ponerlo en la posicion del array equivalente a su valor

	for (int i=0; i<dataSourceArray.length; i++) {
		dataSourceArray[i].setValidationQuery("select 1");
	}
}

public Connection getConnection() throws SQLException {
	return this.getConnection(ASTERISK);
}

public Connection getConnection(int database) throws SQLException {
	switch (database) {
		case ASTERISK:
		//case LIBRA:
			return this.dataSourceArray[database].getConnection();			
		default:
			throw new SQLException("Peticion a obtener conexion con base de datos no definida");
		
	}
}

public void closeConnection(Connection connection) throws SQLException {
	connection.close();
}

public void closeConnection(Connection connection, boolean commit) throws SQLException {
	if (commit) {
		connection.commit();
	} else {
		connection.rollback();
	}
}

}

MainClass

import java.sql.SQLException;
import java.sql.Statement;

import org.apache.commons.dbcp2.BasicDataSource;

public class PoolConTest {

public static void main(String[] args) throws SQLException {
	
	
	
	java.sql.Connection conexion_01 = PoolConnectionsManager.getSingletonInstance().getConnection();
	System.out.println("ObjectID con_01:"+conexion_01.toString());
	java.sql.Connection conexion_02 = PoolConnectionsManager.getSingletonInstance().getConnection();
	System.out.println("ObjectID con_02:"+conexion_02.toString());
	
	
	
	
	conexion_01.setAutoCommit(false);
	Statement ps_01 = conexion_01.createStatement(); 
	Statement ps_02 = conexion_02.createStatement();
	
	System.out.println("Creados statements");
	try {
		Thread.sleep(10000);
	} catch (Exception e) { 
		System.out.println("No se ha podido realizar la espera");
		e.printStackTrace();
	}

	
	System.out.println("Procediendo a ejecutar statements");
	//ps_01.addBatch(sql);
	//ps_01.executeBatch();
	ps_01.executeUpdate("INSERT INTO test_table (nombre,poolnumber,descripcion) VALUES('NOMBRE_01','001','DESC_01')");
	System.out.println("Ejecutado statements 001");
	ps_02.executeUpdate("INSERT INTO test_table (nombre,poolnumber,descripcion) VALUES('NOMBRE_02','002','DESC_02')");
	System.out.println("Ejecutado statements 002");
	
	try {
		Thread.sleep(10000);
	} catch (Exception e) { 
		System.out.println("No se ha podido realizar la espera");
		e.printStackTrace();
	}
	
	ps_01.close();
	ps_02.close();
	
	PoolConnectionsManager.getSingletonInstance().closeConnection(conexion_01,true);
	PoolConnectionsManager.getSingletonInstance().closeConnection(conexion_02);
	System.out.println("Liberadas las conexiones");
}

}

sh31k #2 May '17

Has comprobado en la configuración de mysql el número de conexiones?

1 respuesta

willy_chaos #3 May '17

#2 cierto, no había caido en la configuración del mysql service...

Vale veo que hay que modificar el my.cnf el max_connections y en todo caso tambien el max_user_connections. Y si quiero limitar a ese usuario supongo que ya tengo que ponerle en los permisos a ese usuario la limitacion.

Cuando llegue a casa lo pruebo de nuevo.

Edit:

Ademas de añadirle al pool de conexiones en la configuracion las siguientes lineas.

bds_Asterisk.setMaxTotal(100);

Cosa que no me he dado cuenta hasta un rato largo viendo porque aun indicandole a la MySQL el max_user_connections = 100, no me dejaba mas de 8 conexiones establecidas para ese usuario.

1

[Java] BasicDataSource no establece las conexiones iniciales indicadas

Usuarios habituales

Tags