pool de conexiones netbeans

POOL DE CONEXIONES

1. Que es?

2. Archivos .jar necesarios

3. Configuración

4. Clases para manejar el pool

Que es

El pool de conexiones nos permite administrar eficientemente las conexiones de nuestra aplicación a una base de datos. Cuando necesitemos interactuar con la base de datos simplemente lo hacemos a través del pool, este creara una sola conexión a la base de datos , a la que podemos acceder.

Archivos .jar necesarios

Dependiendo de la base de datos que usemos, debemos obtener los .jar jdbc y copiarlos dentro:

netbeans_home\enterprise2\jakarta-tomcat-5.5.7\common\lib

Configuración

1. Para configurar el pool, buscamos el archivo context.xml, ubicado dentro de la carpeta META-INF de nuestro proyecto. Indicamos la configuración para el pool, colocando el nombre para el pool, el driver jdbc, la base datos, el usuario y password.

name="jdbc/avbravo"

type="javax.sql.DataSource"

driverClassName="org.postgresql.Driver"

password="postgres"

maxIdle="2"

maxWait="5000"

username="postgres"

url="jdbc:postgresql://localhost:5432/academicoazuero"

maxActive="4"/>

Figura del context.xml

2. Configurar el archivo web.xml, para permitir a nuestras clases java, usar el pool. Añadimos eñ resource-ref.

jdbc/avbravo

javax.sql.DataSource

Container

3. Clases que usan el pool.

Definimos una clase que se encargue de manejar la conexión con el pool, y ejecutar las sentencias sql.

Crear el paquete com.avbravo.basedatos para la clase conexión y el paquete com.avbravo.usuarios para almacenar la clase del usuario.

/*

* conexion.java

*

* Created on 17 de noviembre de 2005, 08:58 AM

*

* To change this template, choose Tools | Template Manager

* and open the template in the editor.

*/

package com.avbravo.basedatos;

/**

*

* @author aristides

*/

import java.sql.Connection;

import java.sql.PreparedStatement;

import java.sql.ResultSet;

import java.sql.SQLException;

import javax.naming.Context;

import javax.naming.InitialContext;

import javax.naming.NamingException;

import javax.sql.DataSource;

import java.util.logging.Level;

import java.util.logging.Logger;

import java.sql.Statement;

public class conexion {

private Connection conn;

private Statement stmt;

private ResultSet rs;

private String myError="";

private Logger logger = Logger.getLogger("com.avbravo.basedatos");

/** Creates a new instance of conexion */

//PROPERTY myError

public String getError() {

return this.myError;

}

//PROPERTY: rs

public ResultSet getResultSet() {

return this.rs;

}

//carga el pool de conexiones

public boolean conectarPool(){

try{

Context ctx = new InitialContext();

if (ctx == null) {

this.myError ="No initial context";

return false;

}

DataSource ds = (DataSource) ctx.lookup("java:comp/env/jdbc/avbravo");

if (ds == null) {

this.myError= "No data source";

return false;

}

conn = ds.getConnection();

if (conn == null){

this.myError = "No connection";

return false;

}

return true;

}catch (SQLException ex) {

this.myError = "SQLException " + ex.getMessage();

logger.log(Level.SEVERE, "loginAction", ex);

return false;

} catch (NamingException ex) {

this.myError = "NamingException " + ex.getMessage();

logger.log(Level.SEVERE, "loginAction", ex);

return false;

} catch (Exception ex) {

this.myError = "Exception " + ex.getMessage();

logger.log(Level.SEVERE, "loginAction", ex);

return false;

}

}//conectarPool()

//ejecutarQuery(String)

//ejecuta una sentencia sql

public boolean ejecutarQuery(String sql) {

try{

if (sql.equals("")){

this.myError ="Sentencia sql vacia";

return false;

}

if (conectarPool() == false)

return false;

else {

stmt = conn.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_UPDATABLE);

rs = stmt.executeQuery(sql);

return true;

}

}catch (SQLException ex) {

this.myError = "SQLException " + ex.getMessage();

logger.log(Level.SEVERE, "loginAction", ex);

return false;

} catch (Exception ex) {

this.myError = "Exception " + ex.getMessage();

logger.log(Level.SEVERE, "loginAction", ex);

return false;

}

}//ejecutarQuery

//ejecutarUpdate(String)

//ejecuta una sentencia sql

public boolean ejecutarUpdate(String sql) {

try{

if (sql.equals("")){

this.myError ="Sentencia sql vacia";

return false;

}

if (conectarPool() == false)

return false;

else {

stmt = conn.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_UPDATABLE);

stmt.executeUpdate(sql);

return true;

}

}catch (SQLException ex) {

this.myError = "SQLException " + ex.getMessage();

logger.log(Level.SEVERE, "loginAction", ex);

return false;

} catch (Exception ex) {

this.myError = "Exception " + ex.getMessage();

logger.log(Level.SEVERE, "loginAction", ex);

return false;

}

}//ejecutarQuery

//cerrarPool()

//cierra el pool de conexiones

public void cerrarPool() {

try{

conn.close();

}catch (SQLException ex) {

this.myError = "SQLException " + ex.getMessage();

logger.log(Level.SEVERE, "loginAction", ex);

} catch (Exception ex) {

this.myError = "Exception " + ex.getMessage();

logger.log(Level.SEVERE, "loginAction", ex);

}

}

}//class

clase usuarios.

/*

* usuarios.java

*

* Created on 17 de noviembre de 2005, 09:02 AM

*