|
|
| jakarta commons-dbcp |
作者：未知
文章来源：www.jspcn.net
访问次数：1946次
加入时间：2005年01月19日
|
|
jakarta commons-dbcp
1.DBCP简介
网络程序的设计，很多都涉及到和关系型数据库的交互操作，一般的操作方式都是使用的时候创建到数据库的连
接，然后进行各种操作，这种简单的操作方式带来的问题便是数据库的频繁的打开和关闭，以及Transtion的执
行，这是一种很耗费时间和资源的操作。于是数据库缓冲池DBCP就出现了，这个包是从pool包发展出来的。
2.DBCP实现的基本流程
1.创建enericObjectPool实例
GenericObjectPool pool = new GenericObjectPool(null);
2.创建PoolableConnectionFactory
DriverManagerConnectionFactory cf =
new DriverManagerConnectionFactory(
"jdbc:mysql://host/db", "username", "password");
PoolableConnectionFactory pcf =
new PoolableConnectionFactory(
CF, pool, null, "SELECT * FROM mysql.db", false, true);
3.创建和注册PoolingDriver
new PoolingDriver().registerPool("myPool", pool);
到此为止,数据库缓冲池就创建完毕了.
3.DataSource的实现过程
DataSource在众多的jsp容器和应用程序中都已经实现，在容器或者应用服务器启动的时候，他会读取相关的
配置文件，自动完成DataSource的创建工作，我们一般只需要在服务器的配置文件中指定就可以了，这里贴出
实现的过程，便于大家理解它内部的实现机制，便于编程参考。
import javax.sql.DataSource;
import java.sql.Connection;
import java.sql.Statement;
import java.sql.ResultSet;
import java.sql.SQLException;
import org.apache.commons.dbcp.BasicDataSource;
public class BasicDataSourceExample {
public static void main(String[] args) {
// 创建BasicDataSource
System.out.println("Setting up data source.");
DataSource dataSource = setupDataSource(args[0]);
System.out.println("Done.");
//创建JDBC数据源
Connection conn = null;
Statement stmt = null;
ResultSet rset = null;
try {
System.out.println("Creating connection.");
conn = dataSource.getConnection();
System.out.println("Creating statement.");
stmt = conn.createStatement();
System.out.println("Executing statement.");
rset = stmt.executeQuery(args[1]);
System.out.println("Results:");
int numcols = rset.getMetaData().getColumnCount();
while(rset.next()) {
for(int i=1;i<=numcols;i++) {
System.out.print(" " + rset.getString(i));
}
System.out.println("");
}
} catch(SQLException e) {
e.printStackTrace();
} finally {
try { rset.close(); } catch(Exception e) { }
try { stmt.close(); } catch(Exception e) { }
try { conn.close(); } catch(Exception e) { }
}
}
//创建数据源
public static DataSource setupDataSource(String connectURI) {
BasicDataSource ds = new BasicDataSource();
ds.setDriverClassName("oracle.jdbc.driver.OracleDriver");
ds.setUsername("scott");
ds.setPassword("tiger");
ds.setUrl(connectURI);
return ds;
}
//提示数据源状态
public static void printDataSourceStats(DataSource ds) throws SQLException {
BasicDataSource bds = (BasicDataSource) ds;
System.out.println("NumActive: " + bds.getNumActive());
System.out.println("NumIdle: " + bds.getNumIdle());
}
//关闭数据源
public static void shutdownDataSource(DataSource ds) throws SQLException {
BasicDataSource bds = (BasicDataSource) ds;
bds.close();
}
}
例子比较简单，不再多说了~
4.tomcat中DBCP的配置
这里是以Mysql作为数据库进行说明。
使用DBCP，在 server.xml 中需要设置相关的连接及 dbcp 的参数值.
<Context path="/MysqlTest" docBase="MysqlTest"
debug="5" reloadable="true" crossContext="true">
<Logger className="org.apache.catalina.logger.FileLogger"
prefix="localhost_MysqlTest_log." suffix=".txt"
timestamp="true"/>
<Resource name="jdbc/TestDB" auth="Container" type="javax.sql.DataSource"/>
<ResourceParams name="jdbc/TestDB">
<parameter>
<name>factory</name>
<value>org.apache.commons.dbcp.BasicDataSourceFactory</value>
</parameter>
<parameter>
<name>maxActive</name>
<value>100</value>
</parameter>
<parameter>
<name>maxIdle</name>
<value>30</value>
</parameter>
<parameter>
<name>maxWait</name>
<value>10000</value>
</parameter>
<parameter>
<name>username</name>
<value>root</value>
</parameter>
<parameter>
<name>password</name>
<value>admin</value>
</parameter>
<parameter>
<name>driverClassName</name>
<value>org.gjt.mm.mysql.Driver</value>
</parameter>
<parameter>
<name>url</name>
<value>jdbc:mysql://localhost:3306/javatest?autoReconnect=true</value>
</parameter>
</ResourceParams>
</Context>
我们可以看到他使用的 dbcp factory 就是 org.apache.commons.dbcp.BasicDataSourceFactory
5.参数说明
*dataSource:要连接的 datasource (通常我们不会定义在 server.xml)
*defaultAutoCommit:对于事务是否 autoCommit, 默认值为 true
*defaultReadOnly:对于数据库是否只能读取, 默认值为 false
*driverClassName:连接数据库所用的 JDBC Driver Class,
*maxActive:最大连接数据库连接数,设 0 为没有限制
*maxIdle:最大等待连接中的数量,设 0 为没有限制
*maxWait:最大等待秒数, 单位为 ms, 超过时间会?G出错误信息
*password:登陆数据库所用的密码
*url:连接数据库的 URL
*username:登陆数据库所用的帐号
*validationQuery:验证连接是否成功, SQL SELECT 指令至少要返回一行
*removeAbandoned:是否自我中断, 默认是 false
*removeAbandonedTimeout:几秒后会自我中断, removeAbandoned 必须为 true
*logAbandoned:是否记录中断事件, 默认为 false
6.总结
DBCP一般应用在数据库的使用非常频繁的情况下使用，它可以处理大量的数据库的连接请求，不失为做大型站
点的首选数据库配置
7.参考资料
*jakarta commons
http://jakarta.apache.org/commons/
*jakarta commons-dbcp
http://jakarta.apache.org/commons/dbcp
*jakarta commons-dbcp api
http://jakarta.apache.org/commons/dbcp/apidocs/index.html
*CVS资料
http://cvs.apache.org/viewcvs.cgi/jakarta-commons/dbcp/doc/
本文版权所有，未经允许，不得转载，如许转载，请联系：topojuly@tom.com
|
|
|
