锐客网

  1. 首页 > 生活百科 > it技术 > >

JAVA中连接池代码 java连接池工作原理

连接IT技术

java中建立数据库连接池，有哪几个步骤配置包括3步：1.让tomcat容器启动创建数据库连接池2.在某个项目中关联数据库连接池，3.取得数据库连接池并使用 。使用包括 ， 当拿到数据库连接后，可以通过2种方式来使用，1.使用jstl的标签 ， 2.封装成返回connection的方法 。
1.让tomcat容器启动创建数据库连接池：
配置的地方很多 ， 根据不同的需求配置在不同的位置 ， 但原理就一个，就是要配置一个Context标签下有一个resource标签 。
a.在Tomcat 6.0\conf\Catalina\localhost目录下新建一个跟项目名一样的*.xml文件
b.数据源设置的名字(JNDI) auth:表示数据源由谁管理，这儿是tomcat容器本身 type：类型
c.驱动设置，该驱动放在tomcat的lib下或者放在该站点的lib下设置连接数据库字符串，url设置连接数据库的用户名设置数据库连接的密码--
2.在某个项目中关联数据库连接池，在web.xml添加代码：
!--关联jndi数据库连接池--
3.使用jstl标签测试数据源是否配置成功
4.在jsp中通过java代码测试：
5.封装成bean对外提供得到数据库连接池连接的方式：
怎么在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 staticConnection getCon() {
try {
return ds.getConnection();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
return null;
}
}
}
通过以上代码，即可获取连接池中的连接．
Java开发常用的几个数据库连接池数据库连接池JAVA中连接池代码的好处是不言而喻的JAVA中连接池代码，现在大部分的application
server都提供自己的数据库连接池方案JAVA中连接池代码 ， 此时，只要按照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() throwsSQLException {
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;
【JAVA中连接池代码 java连接池工作原理】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驱动程序，提供了对JAVA中连接池代码你选择的其它类型的驱动程序的连接池封装 。可以非常简单的移植到现存的代码中 。完全可配置 。快速 ， 成熟 ， 健壮 。可以透明地为你现存的JDBC驱动程序增加连接池功能 。
官方网站:
下载地址:
请问那位可以给个用纯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中连接池代码的介绍就聊到这里吧，感谢你花时间阅读本站内容 ， 更多关于java连接池工作原理、JAVA中连接池代码的信息别忘了在本站进行查找喔 。

    推荐阅读


    上一篇：vb连接sqlserver有源，vb连接sql数据库代码

    下一篇：mysql web版 mysql网站模板