在数据库应用中,数据库连接过程需要较长的时间。
而且,频繁的连接数据库会增加数据库系统的压力。
所以,最好在项目中使用数据库连接池来减少数据库连接的数量提高数据库访问效率。
DBCP是Apache的一个开源项目:
commons.dbcp
http://jakarta.apache.org/commons/dbcp/index.html
DBCP依赖Apache的另外2个开源项目
commons.collections
和
commons.pool
下载这些包并将这些包的路径添加到classpath中就可以使用dbcp做为项目中的数据库连接池使用了。
下面是一段示例代码,简单说说dbcp的使用方法:
import org.apache.commons.pool.ObjectPool;
import org.apache.commons.pool.impl.GenericObjectPool;
import org.apache.commons.dbcp.ConnectionFactory;
import org.apache.commons.dbcp.PoolingDriver;
import org.apache.commons.dbcp.PoolableConnectionFactory;
import org.apache.commons.dbcp.DriverManagerConnectionFactory;
![使用dbcp做为数据库连接池 使用dbcp做为数据库连接池](https://image.shishitao.com:8440/aHR0cHM6Ly93d3cuaXRkYWFuLmNvbS9pbWdzLzUvMS8wLzIvMTYvNjgxMDM1NWMyZjc4YzEyZTkxYjc5OTdhOGU4YzU4M2EuanBl.jpe?w=700&webp=1)
![使用dbcp做为数据库连接池 使用dbcp做为数据库连接池](https://image.shishitao.com:8440/aHR0cHM6Ly93d3cuaXRkYWFuLmNvbS9pbWdzLzEvMy8zLzIvMzAvYTQxOTU0YTI3ZDZhZDk2ZmEyYzJjZjgxNmU2Nzc0NDguanBl.jpe?w=700&webp=1)
public class DaoUtil ...{
![使用dbcp做为数据库连接池 使用dbcp做为数据库连接池](https://image.shishitao.com:8440/aHR0cHM6Ly93d3cuaXRkYWFuLmNvbS9pbWdzLzkvMi81LzUvMTgvMzdjOGJmNjhjZGMzY2M4MTc1OWMzNDE2MDc3NmJjNTMuanBl.jpe?w=700&webp=1)
/** *//**
* 数据库连接池
* @see http://jakarta.apache.org/commons/dbcp/index.html
*/
private static PoolingDriver driver = null;
![使用dbcp做为数据库连接池 使用dbcp做为数据库连接池](https://image.shishitao.com:8440/aHR0cHM6Ly93d3cuaXRkYWFuLmNvbS9pbWdzLzkvMi81LzUvMTgvMzdjOGJmNjhjZGMzY2M4MTc1OWMzNDE2MDc3NmJjNTMuanBl.jpe?w=700&webp=1)
/** *//**
* 设置一个数据库连接池
*
* @param name 连接池的名称
* @param url 数据源
* @throws SQLException
*/
![使用dbcp做为数据库连接池 使用dbcp做为数据库连接池](https://image.shishitao.com:8440/aHR0cHM6Ly93d3cuaXRkYWFuLmNvbS9pbWdzLzkvMi81LzUvMTgvMzdjOGJmNjhjZGMzY2M4MTc1OWMzNDE2MDc3NmJjNTMuanBl.jpe?w=700&webp=1)
private static void setUpDriverPool(String name, String url) throws SQLException...{
![使用dbcp做为数据库连接池 使用dbcp做为数据库连接池](https://image.shishitao.com:8440/aHR0cHM6Ly93d3cuaXRkYWFuLmNvbS9pbWdzLzkvMi81LzUvMTgvMzdjOGJmNjhjZGMzY2M4MTc1OWMzNDE2MDc3NmJjNTMuanBl.jpe?w=700&webp=1)
if ((driver == null) || driver.getPoolNames().length < 2) ...{
![使用dbcp做为数据库连接池 使用dbcp做为数据库连接池](https://image.shishitao.com:8440/aHR0cHM6Ly93d3cuaXRkYWFuLmNvbS9pbWdzLzkvMi81LzUvMTgvMzdjOGJmNjhjZGMzY2M4MTc1OWMzNDE2MDc3NmJjNTMuanBl.jpe?w=700&webp=1)
try ...{
![使用dbcp做为数据库连接池 使用dbcp做为数据库连接池](https://image.shishitao.com:8440/aHR0cHM6Ly93d3cuaXRkYWFuLmNvbS9pbWdzLzkvMi81LzUvMTgvMzdjOGJmNjhjZGMzY2M4MTc1OWMzNDE2MDc3NmJjNTMuanBl.jpe?w=700&webp=1)
/** *//**
* 首先创建一个对象池来保存数据库连接
*
* 使用 commons.pool 的 GenericObjectPool对象
*/
ObjectPool connectionPool = new GenericObjectPool();
![使用dbcp做为数据库连接池 使用dbcp做为数据库连接池](https://image.shishitao.com:8440/aHR0cHM6Ly93d3cuaXRkYWFuLmNvbS9pbWdzLzkvMi81LzUvMTgvMzdjOGJmNjhjZGMzY2M4MTc1OWMzNDE2MDc3NmJjNTMuanBl.jpe?w=700&webp=1)
/** *//**
* 创建一个 DriverManagerConnectionFactory对象
* 连接池将用它来获取一个连接
*/
ConnectionFactory connectionFactory = new DriverManagerConnectionFactory(url, null);
![使用dbcp做为数据库连接池 使用dbcp做为数据库连接池](https://image.shishitao.com:8440/aHR0cHM6Ly93d3cuaXRkYWFuLmNvbS9pbWdzLzkvMi81LzUvMTgvMzdjOGJmNjhjZGMzY2M4MTc1OWMzNDE2MDc3NmJjNTMuanBl.jpe?w=700&webp=1)
/** *//**
* 创建一个PoolableConnectionFactory 对象。
*/
PoolableConnectionFactory poolableConnectionFactory =
new PoolableConnectionFactory(connectionFactory,connectionPool,null,null,false,true);
![使用dbcp做为数据库连接池 使用dbcp做为数据库连接池](https://image.shishitao.com:8440/aHR0cHM6Ly93d3cuaXRkYWFuLmNvbS9pbWdzLzkvMi81LzUvMTgvMzdjOGJmNjhjZGMzY2M4MTc1OWMzNDE2MDc3NmJjNTMuanBl.jpe?w=700&webp=1)
/** *//**
* 注册PoolingDriver。
*/
Class.forName("org.apache.commons.dbcp.PoolingDriver");
driver = (PoolingDriver) DriverManager.getDriver("jdbc:apache:commons:dbcp:");
driver.registerPool(name, connectionPool);
}
![使用dbcp做为数据库连接池 使用dbcp做为数据库连接池](https://image.shishitao.com:8440/aHR0cHM6Ly93d3cuaXRkYWFuLmNvbS9pbWdzLzkvMi81LzUvMTgvMzdjOGJmNjhjZGMzY2M4MTc1OWMzNDE2MDc3NmJjNTMuanBl.jpe?w=700&webp=1)
catch (ClassNotFoundException e) ...{
throw new RuntimeException(e);
}
}
}
![使用dbcp做为数据库连接池 使用dbcp做为数据库连接池](https://image.shishitao.com:8440/aHR0cHM6Ly93d3cuaXRkYWFuLmNvbS9pbWdzLzkvMi81LzUvMTgvMzdjOGJmNjhjZGMzY2M4MTc1OWMzNDE2MDc3NmJjNTMuanBl.jpe?w=700&webp=1)
/** *//**
* 关闭所有数据库连接池
*
*/
![使用dbcp做为数据库连接池 使用dbcp做为数据库连接池](https://image.shishitao.com:8440/aHR0cHM6Ly93d3cuaXRkYWFuLmNvbS9pbWdzLzkvMi81LzUvMTgvMzdjOGJmNjhjZGMzY2M4MTc1OWMzNDE2MDc3NmJjNTMuanBl.jpe?w=700&webp=1)
public static void shutDownDriver() ...{
![使用dbcp做为数据库连接池 使用dbcp做为数据库连接池](https://image.shishitao.com:8440/aHR0cHM6Ly93d3cuaXRkYWFuLmNvbS9pbWdzLzkvMi81LzUvMTgvMzdjOGJmNjhjZGMzY2M4MTc1OWMzNDE2MDc3NmJjNTMuanBl.jpe?w=700&webp=1)
try ...{
PoolingDriver driver = (PoolingDriver)DriverManager.getDriver("jdbc:apache:commons:dbcp:");
![使用dbcp做为数据库连接池 使用dbcp做为数据库连接池](https://image.shishitao.com:8440/aHR0cHM6Ly93d3cuaXRkYWFuLmNvbS9pbWdzLzkvMi81LzUvMTgvMzdjOGJmNjhjZGMzY2M4MTc1OWMzNDE2MDc3NmJjNTMuanBl.jpe?w=700&webp=1)
for (int i = 0; i < poolNames.length; i++) ...{
driver.closePool("pool");
}
}
![使用dbcp做为数据库连接池 使用dbcp做为数据库连接池](https://image.shishitao.com:8440/aHR0cHM6Ly93d3cuaXRkYWFuLmNvbS9pbWdzLzkvMi81LzUvMTgvMzdjOGJmNjhjZGMzY2M4MTc1OWMzNDE2MDc3NmJjNTMuanBl.jpe?w=700&webp=1)
catch (SQLException sqle) ...{
throw new RuntimeException(sqle);
}
}
![使用dbcp做为数据库连接池 使用dbcp做为数据库连接池](https://image.shishitao.com:8440/aHR0cHM6Ly93d3cuaXRkYWFuLmNvbS9pbWdzLzAvOC8yLzUvNTMvNmE5YzA3MWEwOGYxZGFlMmQzZTFjNTEyMDAwZWVmNDEuanBl.jpe?w=700&webp=1)
![使用dbcp做为数据库连接池 使用dbcp做为数据库连接池](https://image.shishitao.com:8440/aHR0cHM6Ly93d3cuaXRkYWFuLmNvbS9pbWdzLzkvMi81LzUvMTgvMzdjOGJmNjhjZGMzY2M4MTc1OWMzNDE2MDc3NmJjNTMuanBl.jpe?w=700&webp=1)
/** *//**
* 取得一个数据库连接对象。
*
* 因为可能使用两个不同的数据库,
* 所以依据report的值来确定使用那个数据库。
*
* @param report
* @return
*/
![使用dbcp做为数据库连接池 使用dbcp做为数据库连接池](https://image.shishitao.com:8440/aHR0cHM6Ly93d3cuaXRkYWFuLmNvbS9pbWdzLzkvMi81LzUvMTgvMzdjOGJmNjhjZGMzY2M4MTc1OWMzNDE2MDc3NmJjNTMuanBl.jpe?w=700&webp=1)
public static Connection getConnection() ...{
Connection con = null;
![使用dbcp做为数据库连接池 使用dbcp做为数据库连接池](https://image.shishitao.com:8440/aHR0cHM6Ly93d3cuaXRkYWFuLmNvbS9pbWdzLzkvMi81LzUvMTgvMzdjOGJmNjhjZGMzY2M4MTc1OWMzNDE2MDc3NmJjNTMuanBl.jpe?w=700&webp=1)
try ...{
//装载mysql的jdbc驱动
String driver = "com.mysql.jdbc.Driver";
String url = "jdbc:mysql://server/db?user=root";
String poolName = "pool";
Class.forName(driver);
setUpDriverPool(poolName, url);
![使用dbcp做为数据库连接池 使用dbcp做为数据库连接池](https://image.shishitao.com:8440/aHR0cHM6Ly93d3cuaXRkYWFuLmNvbS9pbWdzLzAvOC8yLzUvNTMvNmE5YzA3MWEwOGYxZGFlMmQzZTFjNTEyMDAwZWVmNDEuanBl.jpe?w=700&webp=1)
con = DriverManager.getConnection("jdbc:apache:commons:dbcp:" + poolName);
return con;
}
![使用dbcp做为数据库连接池 使用dbcp做为数据库连接池](https://image.shishitao.com:8440/aHR0cHM6Ly93d3cuaXRkYWFuLmNvbS9pbWdzLzkvMi81LzUvMTgvMzdjOGJmNjhjZGMzY2M4MTc1OWMzNDE2MDc3NmJjNTMuanBl.jpe?w=700&webp=1)
catch (ClassNotFoundException cnfe) ...{
throw new RuntimeException("无法装入数据库引擎") ;
}
![使用dbcp做为数据库连接池 使用dbcp做为数据库连接池](https://image.shishitao.com:8440/aHR0cHM6Ly93d3cuaXRkYWFuLmNvbS9pbWdzLzkvMi81LzUvMTgvMzdjOGJmNjhjZGMzY2M4MTc1OWMzNDE2MDc3NmJjNTMuanBl.jpe?w=700&webp=1)
catch (SQLException sqle) ...{
throw new RuntimeException("无法打开数据库连接");
}
}
![使用dbcp做为数据库连接池 使用dbcp做为数据库连接池](https://image.shishitao.com:8440/aHR0cHM6Ly93d3cuaXRkYWFuLmNvbS9pbWdzLzkvMi81LzUvMTgvMzdjOGJmNjhjZGMzY2M4MTc1OWMzNDE2MDc3NmJjNTMuanBl.jpe?w=700&webp=1)
/** *//**
* 执行清理过程
*
* <li>关闭数据库连接</li>
* <li>关闭语句对象</li>
* <li>关闭结果集</li>
*
* @param con
* @param s
* @param rs
*/
![使用dbcp做为数据库连接池 使用dbcp做为数据库连接池](https://image.shishitao.com:8440/aHR0cHM6Ly93d3cuaXRkYWFuLmNvbS9pbWdzLzkvMi81LzUvMTgvMzdjOGJmNjhjZGMzY2M4MTc1OWMzNDE2MDc3NmJjNTMuanBl.jpe?w=700&webp=1)
public static void closeAll(Connection con, Statement s, ResultSet rs) ...{
![使用dbcp做为数据库连接池 使用dbcp做为数据库连接池](https://image.shishitao.com:8440/aHR0cHM6Ly93d3cuaXRkYWFuLmNvbS9pbWdzLzkvMi81LzUvMTgvMzdjOGJmNjhjZGMzY2M4MTc1OWMzNDE2MDc3NmJjNTMuanBl.jpe?w=700&webp=1)
try ...{
![使用dbcp做为数据库连接池 使用dbcp做为数据库连接池](https://image.shishitao.com:8440/aHR0cHM6Ly93d3cuaXRkYWFuLmNvbS9pbWdzLzkvMi81LzUvMTgvMzdjOGJmNjhjZGMzY2M4MTc1OWMzNDE2MDc3NmJjNTMuanBl.jpe?w=700&webp=1)
if (rs != null) ...{
rs.close();
rs = null;
}
![使用dbcp做为数据库连接池 使用dbcp做为数据库连接池](https://image.shishitao.com:8440/aHR0cHM6Ly93d3cuaXRkYWFuLmNvbS9pbWdzLzkvMi81LzUvMTgvMzdjOGJmNjhjZGMzY2M4MTc1OWMzNDE2MDc3NmJjNTMuanBl.jpe?w=700&webp=1)
if (s != null) ...{
s.close();
s = null;
}
![使用dbcp做为数据库连接池 使用dbcp做为数据库连接池](https://image.shishitao.com:8440/aHR0cHM6Ly93d3cuaXRkYWFuLmNvbS9pbWdzLzkvMi81LzUvMTgvMzdjOGJmNjhjZGMzY2M4MTc1OWMzNDE2MDc3NmJjNTMuanBl.jpe?w=700&webp=1)
if (con != null) ...{
con.close();
con = null;
}
}
![使用dbcp做为数据库连接池 使用dbcp做为数据库连接池](https://image.shishitao.com:8440/aHR0cHM6Ly93d3cuaXRkYWFuLmNvbS9pbWdzLzkvMi81LzUvMTgvMzdjOGJmNjhjZGMzY2M4MTc1OWMzNDE2MDc3NmJjNTMuanBl.jpe?w=700&webp=1)
catch (SQLException sqle) ...{
//nothing to do, forget it;
}
}
}