C3P0连接池

  　　　　①加载数据库驱动程序(Class.forName("数据库驱动类");)   　　　　②连接数据库(Connection con  = DriverManager.getConnection();)   　　　　③操作数据库(PreparedStatement stat = con.prepareStatement(sql);stat.executeQuery();)   　　　　④关闭数据库，释放连接(con.close();) 　　也就是说，所有的用户都需要经过此四步进行操作，但是这四步之中有三步(①加载数据库驱动程序、②连接数据库、④关闭数据库，释放连接)对所有人都是一样的，而所有人只有在操作数据库上是不一样，那么这就造成了性能的损耗。 　　那么最好的做法是，准备出一个空间，此空间里专门保存着全部的数据库连接，以后用户用数据库操作的时候不用再重新加载驱动、连接数据库之类的，而直接从此空间中取走连接，关闭的时候直接把连接放回到此空间之中。

      那么此空间就可以称为连接池（保存所有的数据库连接）

主流连接池：

DBCP C3P0 阿里巴巴的druid

使用c3p0需要导包:C3P0.jar

写一个工具类：

public class DBUtils {  
       
    private static String url = null;  
       
    private static String username = null;  
       
    private static String pwd = null;  
       
    private static DataSource ds_pooled;  
    /**  
     *  加载数据库连接的配置文件和驱动 
     */  
    static{  
        FileInputStream fis = null;  
           
        Properties env = new Properties();  
        try {  
            fis = new FileInputStream("dbconfig.properties");  
            //加载属性文件中的数据库配置信息  
            //以=左边作为key值，右边作为value值  
            env.load(fis);   
               
            //1. 加载驱动类  
            Class.forName(env.getProperty("jdbc.driver"));  
               
            url = env.getProperty("jdbc.url");  
            username = env.getProperty("jdbc.username");  
            pwd = env.getProperty("jdbc.pwd");  
               
            //设置连接数据库的配置信息  
            DataSource ds_unpooled = DataSources  
                    .unpooledDataSource(url, username, pwd);  
               
            Map pool_conf = new HashMap();  
            //设置最大连接数  
            pool_conf.put("maxPoolSize", 10);  
            ds_pooled = DataSources.pooledDataSource(ds_unpooled,  
                    pool_conf);  
        } catch (FileNotFoundException e) {  
            e.printStackTrace();  
        } catch (IOException e) {  
            e.printStackTrace();  
        } catch (ClassNotFoundException e) {  
            e.printStackTrace();  
        } catch (SQLException e) {  
            e.printStackTrace();  
        }  
    }  
       
    /** 
     *  获取连接对象 
     */  
    public static Connection getConnection() throws SQLException {  
        // 2. 设置连接的url,username,pwd  
//      return DriverManager.getConnection(url, username, pwd);  
        return ds_pooled.getConnection();  
    }  
       
    /** 
     * 释放连接池资源 
     */  
    public static void clearup(){  
        if(ds_pooled != null){  
            try {  
                DataSources.destroy(ds_pooled);  
            } catch (SQLException e) {  
                e.printStackTrace();  
            }  
        }  
    }  
       
       
    /** 
     * 资源关闭 
     *  
     * @param rs 
     * @param stmt 
     * @param conn 
     */  
    public static void close(ResultSet rs, Statement stmt  
            , Connection conn) {  
        if (rs != null) {  
            try {  
                rs.close();  
            } catch (SQLException e) {  
                e.printStackTrace();  
            }  
        }  
   
        if (stmt != null) {  
            try {  
                stmt.close();  
            } catch (SQLException e) {  
                e.printStackTrace();  
            }  
        }  
   
        if (conn != null) {  
            try {  
                conn.close();  
            } catch (SQLException e) {  
                e.printStackTrace();  
            }  
        }  
    }  
} 

 

测试代码：

public class TestMySQLConnection {  
    private static Integer counter = 0;  
   
    public static void main(String[] args){  
        for (int i = 1; i