数据库连接池的使用

关于数据库连接池的使用，首先我们要明白我们为什么要用它，对应普通的数据库连接操作，通常会涉及到以下一些操作是比较耗时的：

网络通讯，涉及到网络延时及协议通讯
身份验证，涉及安全性检查
连接合法性检查，主要是检查所连接的数据库是否存在
并发控制机制
构造并初始化输出缓冲区
连接成功后的信息保存，日志存储
服务器性能
数据库配置优化
系统分配内存资源
等等~~~状况，导致数据库连接操作比较耗时，~~~而且每次都得花费0.05s～1s的时间
但是使用连接池技术，本质上就是在一个请求对应的连接，都由一个线程池来维护着，也就是说“上下文切换”的代价是线程级别（所谓的纳秒级），对于大规模的并发访问，就算以每秒几亿级别的访问量都是不成问题的。

一、在Java平台

之前一段时间曾经弄过数据库连接池，使用的是c3p0这个工具包，

简单记录下c3p0的使用，当作学习的一个巩固；

第一步导入jar包；

第二步：

把jar包导入进来：

import com.mchange.v2.c3p0.ComboPooledDataSource;
import com.mchange.v2.c3p0.DataSources;

第三步：定义变量

 

package util;

 

import java.beans.PropertyVetoException;

import java.sql.Connection;

import java.sql.PreparedStatement;

import java.sql.ResultSet;

import java.sql.SQLException;

import java.sql.Statement;

 

import com.mchange.v2.c3p0.ComboPooledDataSource;

import com.mchange.v2.c3p0.DataSources;

 

public class DbUtil {

    private static String url = "jdbc:mysql://localhost:3306/zdbang_net";

    private static String user = "root";

    private static String passwd = "admin";

    private static String driver = "com.mysql.jdbc.Driver";

    

    private ComboPooledDataSource cpds; 

    private static DbUtil db = new DbUtil();

    

    public static DbUtil getInstance() {

        return db;

    }

    

    private DbUtil() { 

        cpds = new ComboPooledDataSource();

        try {

            cpds.setDriverClass( driver);

            cpds.setJdbcUrl( url );

            cpds.setUser(user);                                  

            cpds.setPassword(passwd);  

            

            cpds.setMinPoolSize(5);                                     

            cpds.setAcquireIncrement(5);

            cpds.setMaxPoolSize(30);

            cpds.setMaxIdleTime(60);

            

        } catch (PropertyVetoException e) {

            e.printStackTrace();

        }   

    }

    

    public Connection getConn() {  

        try {

            return cpds.getConnection();

        } catch (SQLException e) {

            e.printStackTrace();

        }

        return null;

    }

    

    protected void finalize() throws Throwable {

          DataSources.destroy(cpds);

          super.finalize();

    }

    

    public static void closeConn(Connection conn) {

        try {

            if (conn != null)

                conn.close();

        } catch (SQLException e) {

            e.printStackTrace();

        }

    }

 

    public static Statement getStmt(Connection conn) {

 

        Statement stmt = null;

        try {

            stmt = conn.createStatement();

            return stmt;

        } catch (SQLException e) {

            e.printStackTrace();

        }

        return null;

    }

 

    public static void closeStmt(Statement stmt) {

        try {

            if (stmt != null)

                stmt.close();

        } catch (SQLException e) {

            e.printStackTrace();

        }

    }

 

    public static PreparedStatement getPs(Connection conn, String sql) {

        PreparedStatement ps = null;

        try {

            ps = conn.prepareStatement(sql);

            return ps;

        } catch (SQLException e) {

            e.printStackTrace();

        }

        return null;

    }

 

    public static void closePs(PreparedStatement ps) {

        try {

            if (ps != null)

                ps.close();

        } catch (SQLException e) {

            e.printStackTrace();

        }

    }

 

    public static ResultSet doQuery(Statement stmt, String sql) {

        try {

            ResultSet rs = stmt.executeQuery(sql);

            return rs;

        } catch (SQLException e) {

            e.printStackTrace();

        }

        return null;

    }

 

    public static void closeRs(ResultSet rs) {

        try {

            if (rs != null)

                rs.close();

        } catch (SQLException e) {

            e.printStackTrace();

        }

    }    

 

}

 

ComboPooledDataSource API:

http://stderr.org/doc/libc3p0-java-doc/api/com/mchange/v2/c3p0/ComboPooledDataSource.html