一、数据库连接池

开发的时候经常会需要对数据库进行一些操作，比如说常见的增删改查之类的，当数据量小的时候，可以直接进行操作，但是当数据量增多的时候，每一次连接以及释放数据库都会耗费一定的时间，这个时候，可以采用数据库连接池来保持数据库的链接，减少连接数据库对程序带来的开销，并且可以减少数据库的压力，那么数据库链接池是一个什么样的东西呢？顾名思义，它是一个池子，池子里放的是对数据库的链接，打个比方鱼塘，就是养鱼的池子，想要吃鱼可以直接去捞，不用自己去亲自的买鱼苗养鱼等，数据库连接池就是放的对于数据库的链接，统一的把所有的链接都给建立好了，用的时候就可以直接的从里面去取，用完了之后放回池子里就可以，既然用这个东西，那么我们也没必要完全自己去写代码实现，有些开源的可以直接用，常见的有三种开源的连接池，c3p0，dbcp，proxool这三种，对于c3p0、proxool这两种没用过，只是简单的用过dbcp的池子，在此讲下如何使用dbcp数据库连接池，以及使用的时候遇到的一些坑

图1、使用连接池之前

图2 使用连接池之后

如上图1所示，在使用连接池之前，需要每次都对数据库建立链接，并且需要随时进行释放，在数据量大的情况下，需要很大的连接数据库的开销，并且频繁的对数据库进行访问以及释放，也会对数据库造成很大的压力，图2为使用数据库连接池之后，将所有的链接放在池子里，不进行释放，当用的时候直接从池子里去取，用完之后放回池子里，池子保持对数据库的长链接，链接断开会进行自动重连，如果连接不够那么对应后来的用户就需要进行等待

二、使用tomcat-dbcp所使用的jar包

包含tomcat-dbcp.jar即可，剩下的都是一些基础包

三、所使用的配置

dbname.Driver=com.mysql.jdbc.Driver
dbname.Url=jdbc:mysql://<your ip>/<your dbname>?useUnicode=true&characterEncoding=UTF-8
&autoReconnect=true&failOverReadOnly=false&maxReconnects=10&autoReconnectForPools=true&zeroDateTimeBehavior=convertToNull&connectTimeout=3000
dbname.Username=<your username>
dbname.Password=<your password>
dbname.InitialSize=15
dbname.MinIdle=10
dbname.MaxIdle=20
dbname.MaxWait=5000
dbname.MaxActive=20
dbname.validationQuery=select 1

Salin selepas log masuk

其中这些配置只需要放在.properties里面即可，关于每一个的意义

其中driver，url，username，password为常见的数据库连接的配置

InitialSize为初始化建立的连接数

Salin selepas log masuk

minidle为数据库连接池中保持的最少的空闲的链接数

Salin selepas log masuk

maxidle数据库连接池中保持的最大的连接数

Salin selepas log masuk

maxwait等待数据库连接池分配连接的最长时间，超出之后报错

Salin selepas log masuk

maxactivite最大的活动链接数，如果是多线程可以设置为超出多线程个数个链接数

Salin selepas log masuk

<pre name="code" class="java">validationQuery测试是否连接是有效的sql语句

Salin selepas log masuk

三、连接池代码

public abstract class DB {

    private static HashMap<String, DataSource> dsTable = new HashMap<String, DataSource>();//此处记得用static
    private BasicDataSource ds;
    private PreparedStatement stmt = null;

    private DataSource getDataSource(String n) {
        if (dsTable.containsKey(n)) {
            return dsTable.get(n);//如果不同的数据库，多个连接池
        } else {
        	synchronized (dsTable) {
        		ds = new BasicDataSource();
                ds.setDriverClassName(DBConfig.getString("db", n.concat(".Driver")));//将<yourname>.properties的值读进来
                ds.setUrl(DBConfig.getString("db", n.concat(".Url")));
                ds.setUsername(DBConfig.getString("db", n.concat(".Username")));
                ds.setPassword(DBConfig.getString("db", n.concat(".Password")));
                ds.setInitialSize(DBConfig.getInteger("db", n.concat(".InitialSize")));
                ds.setMinIdle(DBConfig.getInteger("db", n.concat(".MinIdle")));
                ds.setMaxIdle(DBConfig.getInteger("db", n.concat(".MaxIdle")));
                ds.setMaxWait(DBConfig.getInteger("db", n.concat(".MaxWait")));
                ds.setMaxActive(DBConfig.getInteger("db", n.concat(".MaxActive")));
                ds.setValidationQuery(DBConfig.getString("db", n.concat(".validationQuery")));
                dsTable.put(n, ds);

                return ds;
			}
        }
    }

    protected Connection conn;

    public boolean open() throws SQLException {
    	BasicDataSource bds=(BasicDataSource)this.getDataSource(this.getConnectionName());
    	System.out.println("connection_number:"+bds.getNumActive()+"dsTable:"+dsTable);
        this.conn = this.getDataSource(this.getConnectionName()).getConnection();
        return true;
    }

    public void close() throws SQLException {
    	
        if (this.conn != null)
            this.conn.close();
    }

    protected abstract String getConnectionName();//此函数可以根据自己的需求，将数据库的名字传进来即可

    public void prepareStatement(String sql) throws SQLException {
        this.stmt = this.conn.prepareStatement(sql);
    }

    public void setObject(int index, Object value, int type) throws SQLException {
        this.stmt.setObject(index, value, type);
    }

    public void setObject(int index, Object value) throws SQLException {
        this.stmt.setObject(index, value);
    }

    public int execute() throws SQLException {
        return this.stmt.executeUpdate();
    }
}

Salin selepas log masuk

上述是线程池使用的时候所用到的代码，只是给出了大概的写法，具体的DBDAO部分需要根据自己的需求去自己实现，比如批处理，查询，更新等函数，可以根据个人的需求去进行修改，那么如何判断你所创建的链接是你想要的呢？有两种办法可以检验

1、建立一个空的数据库，查看链接个数

2、在linux下面查看链接个数

得到processid