java数据库连接池代码 java druid数据库连接池

请问那位可以给个用纯java实现数据库连接池的代码

DataSource ds=null;

网站建设哪家好，找创新互联公司！专注于网页设计、网站建设、微信开发、微信小程序开发、集团企业网站建设等服务项目。为回馈新老客户创新互联还提供了清水免费建站欢迎大家使用！

Connection con=null;

PreparedStatement ps=null;

ResultSet rs=null;

String username=null;

try{

//实现数据连接池

Context ctx=new InitialContext();

ds=(DataSource)ctx.lookup("java:comp/env/jdbc/userInfo");

}catch(NamingException ne){ne.printStackTrace();}

try{

con=ds.getConnection();

String sql="select * from guestbook order by gst_time desc";

st=con.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,

ResultSet.CONCUR_READ_ONLY);

rs=st.executeQuery(sql);

。。。。。。

。。。

}

在这段代码中

Context ctx=new InitialContext();

ds=(DataSource)ctx.lookup("java:comp/env/jdbc/userInfo");就是连接池代码。

它是读取配置文件（Context.xml）中数据的。

以下是配置文件：

Context path="/WebModule1" docBase="E:\Home\WebModule1" reloadable="true"

Resource name="jdbc/userInfo" auth="Container" type="javax.sql.DataSource"

maxActive="100" maxIdle="30" maxWait="10000" username="sa" password="bye0406"

driverClassName="com.microsoft.jdbc.sqlserver.SQLServerDriver"

url="jdbc:microsoft:sqlserver://localhost:1433;databasename=userInfo" /

/Context

path和docBase中的路径根据自己需要配置路径。该路径是WEB应用程序的路径。driverClassName和url是连接数据库的驱动类和连接的URL，是根据你使用的哪种数据库而定。

以下是四种数据库的配制驱动：

驱动

SQL Server 2000

类名：com.microsoft.jdbc.sqlserver.SQLServerDriver

URL:jdbc:microsoft:sqlserver://localhost:1433;databasename=pubs

Oracle

类名：oracle.jdbc.driver.OracleDriver

URL:jdbc:oracle:thin:@localhost:152:ORCL

Mysql

类名:com.mysql.jdbc.Driver

URL:jdbc:mysql://localhost:3306/databasename

JDBC-ODBC

类名:sun.jdbc.odbc.JdbcOdbcDriver

URL:jdbc:odbc:datasource_name;

怎么在JAVA中创建一个数据库连接池？求实例代码

用c3po来创建数据库连接池，

1.到网络上下载c3p0-0.9.0.4.jar包，导入工程；(注意以下方法只能用于web服务)．

2.找出web服务器中conf目录下的centent.xml，在里面加上以下配置

Resource auth="Container"

description="DB Connection"

driverClass="com.mysql.jdbc.Driver"

maxPoolSize="4"

minPoolSize="2"

acquireIncrement="1"

name="jdbc/TestDB"

user="root"

password="root"

factory="org.apache.naming.factory.BeanFactory"

type="com.mchange.v2.c3p0.ComboPooledDataSource"

jdbcUrl="jdbc:mysql://localhost:3306/自己的数据库名?autoReconnect=true" /

3.java获取连接池的代码；

import java.sql.Connection;

import java.sql.SQLException;

import javax.naming.InitialContext;

import javax.naming.NamingException;

import javax.sql.DataSource;

public class DBUtils {

static InitialContext ic;

static DataSource ds;

static{

try {

ic = new InitialContext();

ds = (DataSource)ic.lookup("java:comp/env/jdbc/TestDB");

} catch (NamingException e) {

// TODO Auto-generated catch block

e.printStackTrace();

}

}

public static Connection getCon() {

try {

return ds.getConnection();

} catch (SQLException e) {

// TODO Auto-generated catch block

e.printStackTrace();

return null;

}

}

}

通过以上代码，即可获取连接池中的连接．

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

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

pool包，目前版本是1.3：，

common-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 对象。

下载地址:

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驱动程序增加连接池功能。

官方网站:

下载地址: