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

数据库连接池的好处是不言而喻的，现在大部分的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() {

(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

为何要使用HiKariCP？这要先从BoneCP说起：

什么？不是有C3P0/DBCP这些成熟的数据库连接池吗？一直用的好好的，为什么又搞出一个BoneCP来？因为，传说中BoneCP在快速这个特点上做到了极致，官方数据是C3P0等的25倍左右。不相信？其实我也不怎么信。可是，有图有真相啊（图片来自BoneCP官网：

关于可靠性方面，也是有实验和数据支持的。对于数据库连接中断的情况，通过测试getConnection()，各种CP的不相同处理方法如下：

（所有CP都配置了跟connectionTimeout类似的参数为5秒钟）

HikariCP：等待5秒钟后，如果连接还是没有恢复，则抛出一个SQLExceptions 异常；后续的getConnection()也是一样处理；

C3P0：完全没有反应，没有提示，也不会在“CheckoutTimeout”配置的时长超时后有任何通知给调用者；然后等待2分钟后终于醒来了，返回一个error；

Tomcat：返回一个connection，然后……调用者如果利用这个无效的connection执行SQL语句……结果可想而知；大约55秒之后终于醒来了，这时候的getConnection()终于可以返回一个error，但没有等待参数配置的5秒钟，而是立即返回error；

BoneCP：跟Tomcat的处理方法一样；也是大约55秒之后才醒来，有了正常的反应，并且终于会等待5秒钟之后返回error了；

上述都是在网上找得到的，你直接搜关键字就可以看到的。

tomcat连接池的方法

1:连接池所要解决的问题：

应用程序每一次与数据库的连接都会由于网络传输和执行数据库查询而严重降低了程序的执行效率，因此我们需要用到连接池将将我们经常要用到的数据保存在连接池中，这样就减少了网络传输和因查询而给程序执行效率带来的影响。

2：连接池的本质：用一个集合保存查询出来的数据。

3：连接池的实现原理：

我们要使用Connect pool,首先要做的是访问datasource（所有的要访问的数据都放在这里面）。datasource数据源是通过LDAP(light directory access protocal)软件进行管理的（其本质就是将数据源以树状结构进行存储，这样的话，方便查询（树状结构的查询效率是最快的），java通过JNDI（java naming directory interface）访问LDAP里面的数据。

4:在tomcat种配置连接池：

1）打开tomcat目录下的conf/context.cfg:在里面加入如下配置

Xml代码

其中：maxActive:代表的是要配置的最大连接数。

type:资源类型

2)通过应用程序执行上述连接：

Java代码

<%@page contentType="text/html" %>

<%@page import="java.sql.*"%>

<%@page import="javax.sql.*"%>

<%@page import="javax.naming.*"%>

<html>

<body>

<% Context ctx=new InitialContext()

DataSource ds=(DataSource)ctx.lookup("java:comp/env/ds")//必须要

Connection con=ds.getConnection()

out.println("<h1>connection succeeful</h1>")

con.close()

</body>

</html>

<%@page contentType="text/html" %>

<%@page import="java.sql.*"%>

<%@page import="javax.sql.*"%>

<%@page import="javax.naming.*"%>

<html>

<body>

<% Context ctx=new InitialContext()

DataSource ds=(DataSource)ctx.lookup("java:comp/env/ds")//必须要

Connection con=ds.getConnection()

out.println("<h1>connection succeeful</h1>")

con.close()

</body>

</html>

conn.close()：连接池是被覆盖了的，本质上的含义，把连接池借过来的连接还回去。

从零开始学java web 开发书上的例子

以sql server 2005为例，讲解tomcat6.0上的配置。

下载sqljdbc.jar放在tomcat的lib目录，tomcat/conf/context.xml文件，<Context></Context>中加入配置代码。

web.xml

<?xml version="1.0" encoding="UTF-8"?>

<web-app version="2.4" xmlns="http://java.sun.com/xml/ns/j2ee"

xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

xsi:schemaLocation="http://java.sun.com/xml/ns/j2ee

http://java.sun.com/xml/ns/j2ee/web-app_2_4.xsd">

<welcome-file-list>

<welcome-file>index.jsp</welcome-file>

</welcome-file-list>

<resource-ref>

<description>SQL Server 2005 DataSource</description>

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

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

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

</resource-ref>

</web-app>

showUsers.jsp

<%@ page language="java" import="java.sql.*,javax.sql.*,javax.naming.*"

pageEncoding="GB2312"%>

<html>

<head>

<title>全部注册用户信息</title>

</head>

<body>

try {

DataSource ds = null

InitialContext ctx = new InitialContext()//建立上下文对象

ds = (DataSource) ctx.lookup("java:comp/env/jdbc/dbpooling")//通过JNDI查找数据连接池

Connection conn = ds.getConnection()//获得数据库连接对象

PreparedStatement pstate = conn

.prepareStatement("select * from [User]")

ResultSet rs = pstate.executeQuery()

out.println("<table border=1>")

out.println("<tr><td>用户名</td><td>密码</td></tr>")

while (rs.next()) {

out.println("<tr><td>")

out.println(rs.getString(2))

out.println("</td><td>")

out.println(rs.getString(3))

out.println("</td></tr>")

}

out.println("</table>")

} catch (SQLException e) {

out.println(e)

}

</body>

</html>

欢迎分享，转载请注明来源：内存溢出

原文地址: http://outofmemory.cn/sjk/6692073.html

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

发表评论

评论列表（0条）