Java开发常用的几个数据库连接池

Python014

Java开发常用的几个数据库连接池,第1张

数据库连接池的好处是不言而喻的,现在大部分的application

server都提供自己的数据库连接池方案,此时,只要按照application server的文档说明,正确配置,即可在应用中享受到数据库连接池的好处。

但是,有些时候,我们的应用是个独立的java

application,并不是普通的WEB/J2EE应用,而且是单独运行的,不要什么application

server的配合,这种情况下,我们就需要建立自己的数据库连接池方案了。

1、 DBCP

DBCP是Apache的一个开源项目:

commons.dbcp

DBCP依赖Apache的另外2个开源项目

commons.collections和commons.pool

dbcp包,目前版本是1.2.1:http://jakarta.apache.org/commons/dbcp/

pool包,目前版本是1.3:http://jakarta.apache.org/commons/pool/,

common-collections包:http://jakarta.apache.org/commons/collections/

下载这些包并将这些包的路径添加到classpath中就可以使用dbcp做为项目中的数据库连接池使用了。

在建立我们自己的数据库连接池时,可以使用xml文件来传入需要的参数,这里只使用hard

code的方式来简单介绍,所有需要我们自己写的代码很少,只要建立一个文件如下:

import

org.apache.commons.dbcp.BasicDataSource

import

org.apache.commons.dbcp.BasicDataSourceFactory

import

java.sql.SQLException

import java.sql.Connection

import

java.util.Properties

public class ConnectionSource {

private static BasicDataSource dataSource =

null

public ConnectionSource() {

}

public static void init() {

if (dataSource != null) {

try

{

dataSource.close()

} catch (Exception e)

{

}

dataSource = null

}

try {

Properties p = new

Properties()

p.setProperty("driverClassName",

"oracle.jdbc.driver.OracleDriver")

p.setProperty("url",

"jdbc:oracle:thin:@192.168.0.1:1521:testDB")

p.setProperty("password", "scott")

p.setProperty("username",

"tiger")

p.setProperty("maxActive", "30")

p.setProperty("maxIdle", "10")

p.setProperty("maxWait",

"1000")

p.setProperty("removeAbandoned",

"false")

p.setProperty("removeAbandonedTimeout",

"120")

p.setProperty("testOnBorrow", "true")

p.setProperty("logAbandoned", "true")

dataSource = (BasicDataSource)

BasicDataSourceFactory.createDataSource(p)

} catch (Exception e) {

}

}

public static synchronized Connection

getConnection() throws SQLException {

if (dataSource == null) {

init()

}

Connection conn = null

if (dataSource != null) {

conn = dataSource.getConnection()

}

return conn

}

}

接下来,在我们的应用中,只要简单地使用ConnectionSource.getConnection()就可以取得连接池中的数据库连接,享受数据库连接带给我们的好处了。当我们使用完取得的数据库连接后,只要简单地使用connection.close()就可把此连接返回到连接池中,至于为什么不是直接关闭此连接,而是返回给连接池,这是因为dbcp使用委派模型来实现Connection接口了。

在使用Properties来创建BasicDataSource时,有很多参数可以设置,比较重要的还有:

testOnBorrow、testOnReturn、testWhileIdle,他们的意思是当是取得连接、返回连接或连接空闲时是否进行有效性验证(即是否还和数据库连通的),默认都为false。所以当数据库连接因为某种原因断掉后,再从连接池中取得的连接,实际上可能是无效的连接了,所以,为了确保取得的连接是有效的,

可以把把这些属性设为true。当进行校验时,需要另一个参数:validationQuery,对oracle来说,可以是:SELECT COUNT(*) FROM

DUAL,实际上就是个简单的SQL语句,验证时,就是把这个SQL语句在数据库上跑一下而已,如果连接正常的,当然就有结果返回了。

还有2个参数:timeBetweenEvictionRunsMillis 和

minEvictableIdleTimeMillis,

他们两个配合,可以持续更新连接池中的连接对象,当timeBetweenEvictionRunsMillis

大于0时,每过timeBetweenEvictionRunsMillis

时间,就会启动一个线程,校验连接池中闲置时间超过minEvictableIdleTimeMillis的连接对象。

还有其他的一些参数,可以参考源代码。

2、

C3P0:

C3P0是一个开放源代码的JDBC连接池,C3PO

连接池是一个优秀的连接池,推荐使用。C3PO实现了JDBC3.0规范的部分功能,因而性能更加突出,包括了实现jdbc3和jdbc2扩展规范说明的Connection 和Statement 池的DataSources 对象。

下载地址:http://sourceforge.net/projects/c3p0

package

com.systex.utils.web

import java.beans.PropertyVetoException

import

java.sql.Connection

import java.sql.SQLException

import

javax.sql.DataSource

import

com.mchange.v2.c3p0.ComboPooledDataSource

public class C3PODataSource {

private static

ComboPooledDataSource dataSource = null

private static final String driver

= "com.mysql.jdbc.Driver"

private static final String url =

"jdbc:mysql://localhost:3306/wyd"

private static final String userName =

"root"

private static final String password = "root"

public static DataSource getDataSource() {

if

(dataSource == null) {

dataSource = new ComboPooledDataSource()

try

{

dataSource.setDriverClass(driver)

} catch (PropertyVetoException

e) {

System.out.println("DataSource Load Driver

Exception!!")

e.printStackTrace()

}

dataSource.setJdbcUrl(url)

dataSource.setUser(userName)

dataSource.setPassword(password)

//

设置连接池最大连接容量

dataSource.setMaxPoolSize(20)

//

设置连接池最小连接容量

dataSource.setMinPoolSize(2)

//

设置连接池最大statements对象容量

dataSource.setMaxStatements(100)

}

return

dataSource

}

public static Connection getConnection() throws

SQLException {

return

C3PODataSource.getDataSource().getConnection()

}

}

3、 Proxool

这是一个Java SQL

Driver驱动程序,提供了对你选择的其它类型的驱动程序的连接池封装。可以非常简单的移植到现存的代码中。完全可配置。快速,成熟,健壮。可以透明地为你现存的JDBC驱动程序增加连接池功能。

官方网站: http://proxool.sourceforge.net/

下载地址:http://proxool.sourceforge.net/download.html

连接先建立一些连接,并且这些连接允许共享,因此这样就节省了每次连接的时间开销。Mysql数据库为例,连接池在Tomcat中的配置与使用。

1、创建数据库Student,表student

2、配置server.xml文件。Tomcat安装目录下conf中server.xml文件。

<GlobalNamingResources>

<Resource

name="jdbc/DBPool"

type="javax.sql.DataSource"

password=""

driverClassName="com.mysql.jdbc.Driver"

maxIdle="2"

maxWait="5000"

username="root"

url="jdbc:mysql://localhost:3306/student"

maxActive="3"

/>

</GlobalNamingResources>

name:指定连接池的名称

type:指定连接池的类,他负责连接池的事务处理

url:指定要连接的数据库

driverClassName:指定连接数据库使用的驱动程序

username:数据库用户名

password:数据库密码

maxWait:指定最大建立连接等待时间,如果超过此时间将接到异常

maxIdle:指定连接池中连接的最大空闲数

maxActive:指定连接池最大连接数

3、配置web.xml文件。

<web-app>

<resource-ref>

<description>mysql数据库连接池配置</description>

<res-ref-name>jdbc/DBPool</res-ref-name>

<res-type>javax.sql.DataSource</res-type>

<res-auth>Container</res-auth>

<res-sharing-scope>Shareable</res-sharing-scope>

</resource-ref>

</web-app>

4、配置context.xml文件

与server.xml文件所在的位置相同。

<Context>

<ResourceLink

name="jdbc/DBPool"

type="javax.sql.DataSource"

global="jdbc/DBPool"

/>

</Context>

5、测试

DataSource pool = null

Context env = null

Connection conn = null

Statement st = null

ResultSet rs = null

try{

env = (Context)new InitialContext().lookup("java:comp/env")

//检索指定的对象,返回此上下文的一个新实例

pool = (DataSource)env.lookup("jdbc/DBPool")

//获得数据库连接池

if(pool==null){out.printl("找不到指定的连接池!")}

con = pool.getConnection()

st = con.createStatement()

rs = st.executeQuery("select * from student")

}catch(Exception ex){out.printl(ne.toString())}