Форум программистов [Powered by Invision Power Board]

Код


        public static Connection con = null;
        public static void OpenConnectionBD()
        {
            if (con == null)
            {
                try {
                    try {
                        Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");
                    } catch (ClassNotFoundException eс) {
                        return ;
                    }
                    con= DriverManager.getConnection("jdbc:odbc:база","логин","пароль");
                } catch (SQLException e1) {
                    return ;
                }
            }else{
                try {
                    if (con.isClosed()) {
                        try {
                            try {
                                Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");
                            } catch (ClassNotFoundException eс) {
                                return;
                            }
                        con= DriverManager.getConnection("jdbc:odbc:база","логин","пароль");
                        } catch (SQLException e1) {
                            return;
                        }
                    }
                } catch (SQLException ex) {
                    ex.printStackTrace();
                }
            }
        }
        public static void CloseConnectionDB()
        {
            try {
                if (con!= null && !con.isClosed()) {
                    try {
                        con.close();
                    } catch (SQLException e3) {
                    }
                }
            } catch (SQLException ex) {
                ex.printStackTrace();
            }
        }

Код


import java.io.*;
 import java.sql.*;
 import java.util.*;

import org.apache.commons.dbcp.*;
import org.apache.commons.pool.ObjectPool;
import org.apache.commons.pool.impl.*;


public class ConnectionPool {
    protected GenericObjectPool connectionPool=null;

   public void initConnectionPool( String driver, String dbURL, String dbUser, String dbPswd )
   {
     try
     {
       Class.forName( driver ).newInstance();//создаем новый объект класса драйвера,
       //тем самым инициализируя его

       connectionPool = new GenericObjectPool( null );//создаем GenericObjectPool
       //создаем connection factory ("фабрика соединений" - объект который будет создавать соединения)
       ConnectionFactory connectionFactory = new DriverManagerConnectionFactory( dbURL, dbUser, dbPswd );

       //создаем PoolableConnectionFactory
       PoolableConnectionFactory pcf=new PoolableConnectionFactory( connectionFactory, connectionPool, null, "SELECT 1", false, true );

       PoolingDataSource pds=new PoolingDataSource( connectionPool);
       connectionPool.setMaxIdle( 20 );//устанавливаем максимальное кол-во простаивающих соединений
       connectionPool.setMaxActive( 200 );//устанавилваем макс. кол-во активных соединений
     }
     catch( Exception ex )
     {
        ex.printStackTrace();
     }
   }
   public final Connection getConnection()
   {
     try
     {
       if( connectionPool.getMaxActive() <= connectionPool.getNumActive() )
       {
          //System.err.println( "Connections limit is over!!!" );
           int y=0;
       }

       Connection con = (Connection)connectionPool.borrowObject();
       return con;
     }
     catch( Exception ex )
     {
       ex.printStackTrace();
       return null;
     }
   }

   /**
    * Функция возвращения connection в пул
    */
   public final void returnConnection( Connection con )
   {
     if( con == null )
     {
       return;
     }

     try
     {
       connectionPool.returnObject( con );
     }
     catch( Exception ex )
     {
     }
   }

   public static void mainm()
   {
     //создаем наш объект ConnectionPool
     ConnectionPool pool = new ConnectionPool();
     //единожды инициализируем его указав класс драйвера, URL базы данных, а также логин и пароль к базе данных
     pool.initConnectionPool( "sun.jdbc.odbc.JdbcOdbcDriver", "jdbc:odbc:база", "логин", "пароль" );

     //получаем connection
     Connection con = pool.getConnection();

     //что нибудь делаем
     PreparedStatement ps = null;
        try {
            ps = con.prepareStatement("SELECT * FROM USERS");
        } catch (SQLException ex) {
            ex.printStackTrace();
        }
        String s="";
        ResultSet rs = null;
        try {
            rs = ps.executeQuery();
        } catch (SQLException ex) {
            ex.printStackTrace();
        }
        try {
            while (rs.next()) {
                s+=rs.getString("ID_US")+"***";
            }
        } catch (SQLException ex) {
            ex.printStackTrace();
        }
        try {
            ps.close();
        } catch (SQLException ex) {
            ex.printStackTrace();
        }

     //возвращаем соединение в пул
     pool.returnConnection( con );
     s="";
   }
}