Pool DBCP[RESOLVIDO]

laudenpower wrote:Então se eu configurei o pool para deixar pelo menos uma conexão aberta e essa conexão estourou o tempo de ociosidade a mesma é fechada de "verdade" pelo pool, enquanto isso ele mantém ela aberta?

Não me lembro se é o C3P0 ou o DBCP. Mas um deles abre uma nova conexão e então fecha a ociosa. Então, por um breve momento de tempo, vc tem uma conexão a mais. O outro mantém a conexão aberta.

O fato é que o número mínimo de conexões abertas sempre vai estar lá.

This message was edited 1 time. Last update was at 23/09/2010 16:52:29

Cara to quase desistindo desse carinha aqui...
Tipo eu setei o pool inicial para 10 conexões da seguinte forma:

Mas quando mando listar o número de conexões ativas ele lista apenas uma (a do meu dao), será que eu fiz alguma coisa errada?
Tipo quero usar essa api em um projeto que tenho aqui, mas se eu não tiver certeza de como fazer a coisa posso fazer 30 pessoas pararem de trabalhar de uma hora pra outra

(alias já fiz isso uma vez e não é nada legal...)

ERRATA: Meu inglês não é tão bom quanto o do google translator... o correto é configurar o pool antes de chamar o getConnection()

A documentação diz justamente o contrário, que vc deve chamar o método antes de inicializar o pool.

Note: this method currently has no effect once the pool has been initialized. The pool is initialized the first time one of the following methods is invoked: getConnection, setLogwriter, setLoginTimeout, getLoginTimeout, getLogWriter.

Nota: Esse método atualmente não tem efeito uma vez que o pool tenha sido inicializado. O pool é inicializado pela primeira vez quando um dos seguintes métodos são invocados: getConnection, setLogwriter, setLoginTimeout, getLoginTimeout, getLogWriter

JavaEvangelist Membro desde: 28/12/2008 21:00:08 Mensagens: 349 Offline

Bom depois dessa aula sobre pools segue o código:

package dao;

import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.Properties;
import org.apache.commons.dbcp.BasicDataSource;
import util.ArquivosUtil;//Classe de uso interno (colocar sua classe de log no lugar)
import util.DiversosUtil;//Classe de uso interno (possui um método para pegar o stakestrace da exception)

/**
 * Arquivo criado em: 23/09/2010
 * @author Laudelino Martins Cardoso Neto
 */
public class PoolConnectionDB {
    
    private Properties props;

private BasicDataSource dataSource;

public PoolConnectionDB() {
        this.carregarConfiguracoesBd();
        this.configurarDataSourceRAC();
    }

/**
     * Método que carrega os dados de acesso ao banco a partir de um
     * arquivo properties
     */
    private void carregarConfiguracoesBd(){
        try{
            String caminhoBanco = ArquivosUtil.getCaminhoAplicacao()+"/conexao.properties";
            File file = new File(caminhoBanco);
            FileInputStream fis = null;
            this.props = new Properties();
            fis = new FileInputStream(file);
            props.load(fis);
        }catch(IOException ex){
            System.out.println(ex.getMessage());
            ex.printStackTrace();
        }
    }

/**
     * Método que configura um BaseDataSource com uma conexão ativa (pode ser aumentado)
     */
    private void configurarDataSourceRAC(){
        this.dataSource = new BasicDataSource();
        this.dataSource.setDriverClassName(props.getProperty("nome_da_classe_oracle"));
        this.dataSource.setUsername(props.getProperty("usuario_siprod"));
        this.dataSource.setPassword(props.getProperty("senha_siprod"));
        this.dataSource.setUrl(props.getProperty("conexao_siprod"));
        this.dataSource.setInitialSize(1);//Seta o pool para apenas uma conexão ativa
    }

/**
     * Método que retorna uma conexão do BasicDataSource.
     * Nesse caso ele verifica se existe uma conexão pronta, senão existir verifica
     * se o número de conexões está abaixo do que foi estabelecido, se estiver cria
     * a conexão e devolve.
     * @return Uma conexão do pool
     */
    public Connection getConexaoRAC(){

try{
            return dataSource.getConnection();
        }catch (SQLException sqle){
            sqle.printStackTrace();
            ArquivosUtil.gravarLog(DiversosUtil.getMensagemExcecao(sqle), ArquivosUtil.LOG_TIPO_ERRO);
        }catch (Exception e){
            e.printStackTrace();
            ArquivosUtil.gravarLog(DiversosUtil.getMensagemExcecao(e), ArquivosUtil.LOG_TIPO_ERRO);
        }

return null;

}

/**
     * Mostra informações do DataSource
     */
    public void showStatusDataSource(){
        System.out.println("Conexões ativas: "+dataSource.getNumActive());
        System.out.println("Conexões inativas: "+dataSource.getNumIdle());
    }

/**
     * Fecha tudo o que foi usado pelos DAO's incluindo a conexão.
     * Nesse caso a conexão não é fechada de fato como no JDCB puro, e sim devolvida
     * ao pool de conexão (BasicDataSource)
     * @param rs ResultSet
     * @param ps PreparedStatement
     * @param conn Connection (oriunda do BasicDataSource, mas pode ser a do JDBC também)
     */
    public static void liberarRecursosBD(ResultSet rs, PreparedStatement ps, Connection conn){
        try{
            if (ps != null)
            ps.close();
            if (rs != null)
                rs.close();
            if (conn != null)
                conn.close();
        }catch (SQLException sqle){
            sqle.printStackTrace();
            ArquivosUtil.gravarLog(DiversosUtil.getMensagemExcecao(sqle), ArquivosUtil.LOG_TIPO_ERRO);
        }catch (Exception e){
            e.printStackTrace();
            ArquivosUtil.gravarLog(DiversosUtil.getMensagemExcecao(e), ArquivosUtil.LOG_TIPO_ERRO);
        }

}

}//Fim da classe PoolConnectionDB

Vinny se possível de uma olhada nos meus comentários nos métodos e se algo tiver erradome corrija caso contrário, faça uma pequena consideração final pra mim colocar resolvido no tópico.

Muito obrigado meu colega, me ajudasse muito e me coloco a disposição para poder um dia fazer o mesmo por você

Lembre-se de definir também o setMinIdle para 1.

Assim vc diz que obrigatoriamente deve haver uma conexão aberta.
O initial size é só o tamanho inicial. Se a conexão ficar ociosa, o banco pode fechar essa conexão.

Outras propriedades que talvez vc queira verificar é o setTestOnReturn. Ele precisa que vc use também o setValidationQuery. Coloque ali uma query ultra-simples, só para testar se o banco funciona. Algo como "SELECT 1" já serve.

JavaEvangelist Membro desde: 28/12/2008 21:00:08 Mensagens: 349 Offline

Segue o código corrigido pelo Vinny, espero que ajude muitas pessoas

package dao;

import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.Properties;
import org.apache.commons.dbcp.BasicDataSource;
import util.ArquivosUtil;//Classe de uso interno (realiza o log. colocar sua classe de log no lugar)
import util.DiversosUtil;//Classe de uso interno (possui um método para pegar o stakestrace da exception)

/**
 * Arquivo criado em: 23/09/2010
 * @author Laudelino Martins Cardoso Neto
 */
public class PoolConnectionDB {
    
    private Properties props;

private BasicDataSource dataSource;

public PoolConnectionDB() {
        this.carregarConfiguracoesBd();//Carrega as configs do bd a partir de arquivos
        this.configurarDataSourceRAC();//Configura o BasicDataSource
    }

/**
     * Método que carrega os dados de acesso ao banco a partir de um
     * arquivo properties
     */
    private void carregarConfiguracoesBd(){
        try{
            String caminhoBanco = ArquivosUtil.getCaminhoAplicacao()+"/conexao.properties";
            File file = new File(caminhoBanco);
            FileInputStream fis = null;
            this.props = new Properties();
            fis = new FileInputStream(file);
            props.load(fis);
        }catch(IOException ex){
            System.out.println(ex.getMessage());
            ex.printStackTrace();
        }
    }

/**
     * Método que configura um BaseDataSource com uma conexão ativa (pode ser aumentado)
     */
    private void configurarDataSourceRAC(){
        this.dataSource = new BasicDataSource();
        this.dataSource.setDriverClassName(props.getProperty("nome_driver"));
        this.dataSource.setUsername(props.getProperty("usuario"));
        this.dataSource.setPassword(props.getProperty("senha"));
        this.dataSource.setUrl(props.getProperty("url_conexao"));
        this.dataSource.setInitialSize(1);//Seta o pool para apenas uma conexão ativa
        this.dataSource.setMinIdle(1);//Obriga o pool a ter pelo menos uma conexão sempre ativa
        this.dataSource.setTestOnReturn(true);//Habilita o teste da conexão antes de retorná-la
        this.dataSource.setValidationQuery("SELECT sysdate FROM dual");//Query que serve para atestar conectividade (para oracle)
    }

/**
     * Método que retorna uma conexão do BasicDataSource.
     * Nesse caso ele verifica se existe uma conexão pronta, senão existir verifica
     * se o número de conexões está abaixo do que foi estabelecido, se estiver cria
     * a conexão e devolve.
     * @return Uma conexão do pool
     */
    public Connection getConexaoRAC(){

try{            
            return dataSource.getConnection();
        }catch (SQLException sqle){
            sqle.printStackTrace();
            ArquivosUtil.gravarLog(DiversosUtil.getMensagemExcecao(sqle), ArquivosUtil.LOG_TIPO_ERRO);
        }catch (Exception e){
            e.printStackTrace();
            ArquivosUtil.gravarLog(DiversosUtil.getMensagemExcecao(e), ArquivosUtil.LOG_TIPO_ERRO);
        }

return null;

}

/**
     * Mostra informações do DataSource
     */
    public void showStatusDataSource(){
        System.out.println("Conexões ativas: "+dataSource.getNumActive());
        System.out.println("Conexões inativas: "+dataSource.getNumIdle());
    }

/**
     * Fecha tudo o que foi usado pelos DAO's incluindo a conexão.
     * Nesse caso a conexão não é fechada de fato como no JDCB puro, e sim devolvida
     * ao pool de conexão (BasicDataSource)
     * @param rs ResultSet
     * @param ps PreparedStatement
     * @param conn Connection (oriunda do BasicDataSource, mas pode ser a do JDBC também)
     */
    public static void liberarRecursosBD(ResultSet rs, PreparedStatement ps, Connection conn){
        try{
            if (ps != null)
            ps.close();
            if (rs != null)
                rs.close();
            if (conn != null)
                conn.close();
        }catch (SQLException sqle){
            sqle.printStackTrace();
            ArquivosUtil.gravarLog(DiversosUtil.getMensagemExcecao(sqle), ArquivosUtil.LOG_TIPO_ERRO);
        }catch (Exception e){
            e.printStackTrace();
            ArquivosUtil.gravarLog(DiversosUtil.getMensagemExcecao(e), ArquivosUtil.LOG_TIPO_ERRO);
        }

}

}//Fim da classe PoolConnectionDB

Novamente agradeço pelo Vinny pela ajuda

laudenpower wrote:Segue o código corrigido pelo Vinny, espero que ajude muitas pessoas

package dao; import java.io.File; import java.io.FileInputStream; import java.io.IOException; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import java.util.Properties; import org.apache.commons.dbcp.BasicDataSource; import util.ArquivosUtil;//Classe de uso interno (realiza o log. colocar sua classe de log no lugar) import util.DiversosUtil;//Classe de uso interno (possui um método para pegar o stakestrace da exception) /** * Arquivo criado em: 23/09/2010 * @author Laudelino Martins Cardoso Neto */ public class PoolConnectionDB { private Properties props; private BasicDataSource dataSource; public PoolConnectionDB() { this.carregarConfiguracoesBd();//Carrega as configs do bd a partir de arquivos this.configurarDataSourceRAC();//Configura o BasicDataSource } /** * Método que carrega os dados de acesso ao banco a partir de um * arquivo properties */ private void carregarConfiguracoesBd(){ try{ String caminhoBanco = ArquivosUtil.getCaminhoAplicacao()+"/conexao.properties"; File file = new File(caminhoBanco); FileInputStream fis = null; this.props = new Properties(); fis = new FileInputStream(file); props.load(fis); }catch(IOException ex){ System.out.println(ex.getMessage()); ex.printStackTrace(); } } /** * Método que configura um BaseDataSource com uma conexão ativa (pode ser aumentado) */ private void configurarDataSourceRAC(){ this.dataSource = new BasicDataSource(); this.dataSource.setDriverClassName(props.getProperty("nome_driver")); this.dataSource.setUsername(props.getProperty("usuario")); this.dataSource.setPassword(props.getProperty("senha")); this.dataSource.setUrl(props.getProperty("url_conexao")); this.dataSource.setInitialSize(1);//Seta o pool para apenas uma conexão ativa this.dataSource.setMinIdle(1);//Obriga o pool a ter pelo menos uma conexão sempre ativa this.dataSource.setTestOnReturn(true);//Habilita o teste da conexão antes de retorná-la this.dataSource.setValidationQuery("SELECT sysdate FROM dual");//Query que serve para atestar conectividade (para oracle) } /** * Método que retorna uma conexão do BasicDataSource. * Nesse caso ele verifica se existe uma conexão pronta, senão existir verifica * se o número de conexões está abaixo do que foi estabelecido, se estiver cria * a conexão e devolve. * @return Uma conexão do pool */ public Connection getConexaoRAC(){ try{ return dataSource.getConnection(); }catch (SQLException sqle){ sqle.printStackTrace(); ArquivosUtil.gravarLog(DiversosUtil.getMensagemExcecao(sqle), ArquivosUtil.LOG_TIPO_ERRO); }catch (Exception e){ e.printStackTrace(); ArquivosUtil.gravarLog(DiversosUtil.getMensagemExcecao(e), ArquivosUtil.LOG_TIPO_ERRO); } return null; } /** * Mostra informações do DataSource */ public void showStatusDataSource(){ System.out.println("Conexões ativas: "+dataSource.getNumActive()); System.out.println("Conexões inativas: "+dataSource.getNumIdle()); } /** * Fecha tudo o que foi usado pelos DAO's incluindo a conexão. * Nesse caso a conexão não é fechada de fato como no JDCB puro, e sim devolvida * ao pool de conexão (BasicDataSource) * @param rs ResultSet * @param ps PreparedStatement * @param conn Connection (oriunda do BasicDataSource, mas pode ser a do JDBC também) */ public static void liberarRecursosBD(ResultSet rs, PreparedStatement ps, Connection conn){ try{ if (ps != null) ps.close(); if (rs != null) rs.close(); if (conn != null) conn.close(); }catch (SQLException sqle){ sqle.printStackTrace(); ArquivosUtil.gravarLog(DiversosUtil.getMensagemExcecao(sqle), ArquivosUtil.LOG_TIPO_ERRO); }catch (Exception e){ e.printStackTrace(); ArquivosUtil.gravarLog(DiversosUtil.getMensagemExcecao(e), ArquivosUtil.LOG_TIPO_ERRO); } } }//Fim da classe PoolConnectionDB

Novamente agradeço pelo Vinny pela ajuda

laudenpower, Muito obrigado meu jovem... estou correndo atras desta solução tem tempo! vou tentar implementar...

só uma dúvida, essa classe pode ser usada em conjunto com o hibernate? como seria para passar a conexão para ele?

Abraço

What is classpath? Membro desde: 31/03/2011 19:54:43 Mensagens: 9 Offline

Olá bom dia,

estou com problemas com o C3P0, rodo uma aplicação Java + Hibernate + Swing + Postgre num servidor windows server 2003, problema é que o sistema está abrindo conexões várias e não está elimiando as mesmas só quando o programa é fechado, que libera aquela conexão, nos metodos de consulta fiz sempre assim:

e no .properties está assim agora:

Será que alguém poderia me dar uma ajuda, ou um caminho para mim seguir.

Obrigado.

Você não está abrindo várias conexões feito eu não? tipo, para cada usuário que loga no sistema, ao inves dele buscar a conexão no pool, ele abrir uma conexão com o usuário e senha propio dele? estava fazendo isso ao inves de usar a conexao do pool e por isos o meu nao estava funcionando.

What is classpath? Membro desde: 31/03/2011 19:54:43 Mensagens: 9 Offline

Eu estou usando hibernate e com isso fiz uma classe chamada HibernateUtil como abaixo:

package br.com.projeto_gerencial.hibernate_util;
/**
 *
 * @author AdilsonBad
 */
import java.io.FileInputStream;
import java.util.Properties;
import javax.swing.JOptionPane;
import org.hibernate.Session;
import org.hibernate.SessionFactory;
import org.hibernate.cfg.Configuration;
import org.jasypt.encryption.pbe.StandardPBEStringEncryptor;
import org.jasypt.properties.EncryptableProperties;

public class HibernateUtil {

private static SessionFactory FabricaSessoes;
    static
    {
        try
        {
             StandardPBEStringEncryptor encryptor = new StandardPBEStringEncryptor();
             encryptor.setPassword("SGC_DataBase");
             //
             Properties props = new EncryptableProperties(encryptor);
             //
             props.load(new FileInputStream("hibernate.properties"));
             //
             props.setProperty("hibernate.connection.password", props.getProperty("hibernate.connection.password"));
             //
             FabricaSessoes = new Configuration().setProperties(props).configure().buildSessionFactory();
        }
        catch (Exception erro)
        {
            JOptionPane.showMessageDialog(null, "Erro na fabrica de sessões.: " + erro);
            FabricaSessoes = null;
        }
    }

/*
     * Cria Método que retorna uma Sessão
     */
    public static Session getSession()
    {
        return FabricaSessoes.openSession();
    }
}

Em todos os metodos que faço consulta no BD eu chamo eles assim:

Eu chamo o HibernateUtil.getSession();

agora não sei se isso ele está pegando uma sessão, pq parece que ele está criando uma conexão.

Notícias, artigos e o maior fórum brasileiro sobre Java