JAVA 入门学习之路-数据源/连接池-DBCP和C3P0。

时间:2022-08-26 13:50:20

一、DBCP:

先将需要用到的jar包放到自己项目lib目录,如果没有,请先下载DBCP需要的jar包

commons-dbcp.jar

commons-pool.jar

src目录下创建 dbcpconfig.properties 配置文件:

#连接设置
driverClassName=com.mysql.jdbc.Driver
url=jdbc:mysql://localhost/fisherman
username=chao
password=201314

#<!-- 初始化连接 -->
initialSize=10

#最大连接数量
maxActive=50

#<!-- 最大空闲连接 -->
maxIdle=20

#<!-- 最小空闲连接 -->
minIdle=5

#<!-- 超时等待时间以毫秒为单位 6000毫秒/1000等于60秒 -->
maxWait=60000


#JDBC驱动建立连接时附带的连接属性属性的格式必须为这样:[属性名=property;]
#注意:"user" 与 "password" 两个属性会被明确地传递,因此这里不需要包含他们。
connectionProperties=useUnicode=true;characterEncoding=utf8

#指定由连接池所创建的连接的自动提交(auto-commit)状态。
defaultAutoCommit=true

#driver default 指定由连接池所创建的连接的只读(read-only)状态。
#如果没有设置该值,则“setReadOnly”方法将不被调用。(某些驱动并不支持只读模式,如:Informix)
defaultReadOnly=

#driver default 指定由连接池所创建的连接的事务级别(TransactionIsolation)。
#可用值为下列之一:(详情可见javadoc。)NONE,READ_UNCOMMITTED, READ_COMMITTED, REPEATABLE_READ, SERIALIZABLE
defaultTransactionIsolation=REPEATABLE_READ

封装编写工具类代码:

package com.chao.utils;

import org.apache.commons.dbcp.BasicDataSourceFactory;
import javax.sql.DataSource;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Properties;

public class DBCPUtil {
private static DataSource ds = null;

static {
Properties prop = new Properties();
try {
prop.load(DBCPUtil.class.getClassLoader().getResourceAsStream("/dbcpconfig.properties"));//根据DBCPUtil的classes的路径,加载配置文件
ds = BasicDataSourceFactory.createDataSource(prop);//得到一个数据源
} catch (Exception e) {
throw new ExceptionInInitializerError("初始化错误,请检查配置文件");
}
}

public static Connection getConnection() {
try {
return ds.getConnection();
} catch (SQLException e) {
throw new RuntimeException("服务器忙。。。");
}
}

//关闭资源
public static void closeAll(ResultSet rs, Statement stm, Connection conn) {
if (rs != null) {
try {
rs.close();
} catch (SQLException e) {
e.printStackTrace();
}
rs = null;
}
if (stm != null) {
try {
stm.close();
} catch (SQLException e) {
e.printStackTrace();
}
stm = null;
}
if (conn != null) {
try {
conn.close();
} catch (SQLException e) {
e.printStackTrace();
}
conn = null;
}
}

}

需要 Connection时,调用获取:DBCPUtil.getConnection(); 调用关闭: DBCPUtil.closeAll(rs, ps, conn);

二、C3P0:

先将需要用到的jar包放到自己项目lib目录,如果没有,请先下载C3P0需要的jar包

c3p0-0.9.5.2.jar

src目录下新建配置文件,固定文件名:c3p0-config.xml

<?xml version="1.0" encoding="UTF-8"?>
<c3p0-config>
<default-config>
<property name="driverClass">com.mysql.jdbc.Driver</property>
<property name="jdbcUrl">jdbc:mysql://localhost:3306/fisherman</property>
<property name="user">chao</property>
<property name="password">201314</property>
<property name="initialPoolSize">10</property>
<property name="maxIdleTime">30</property>
<property name="maxPoolSize">100</property>
<property name="minPoolSize">10</property>

</default-config>
</c3p0-config>

封装编写工具类:

package com.chao.utils;

import java.beans.PropertyVetoException;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

import javax.sql.DataSource;

import com.mchange.v2.c3p0.ComboPooledDataSource;

public class C3P0Util {
//得到一个数据源
private static DataSource dataSource = new ComboPooledDataSource();

//从数据源中得到一个连接对象
public static Connection getConnection() {
try {
return dataSource.getConnection();
} catch (SQLException e) {
throw new RuntimeException("服务器错误");
}
}

//关闭资源
public static void closeAll(ResultSet rs, Statement stm, Connection conn) {
if (rs != null) {
try {
rs.close();
} catch (SQLException e) {
e.printStackTrace();
}
rs = null;
}
if (stm != null) {
try {
stm.close();
} catch (SQLException e) {
e.printStackTrace();
}
stm = null;
}
if (conn != null) {
try {
conn.close();
} catch (SQLException e) {
e.printStackTrace();
}
conn = null;
}
}

}

三、Tomcat配置连接池:

//第一步:在Tomcat的配置文件Tomcat7.0\conf\context.xml中添加信息: 需要向Tomcat lib 添加相应数据库连接jar包

<Context>
<Resource
name="jdbc/chao"
type="javax.sql.DataSource"
driverClassName="Oracle.jdbc.driver.OracleDriver"
maxIdle="2"
maxWait="5000"
username="chao"
password="201314"
url="jdbc:oracle:thin:@localhost:1521:bjpowernode"
maxActive="4"/>
</Context>

//第二步:把配置文件context.xml剪切到webRoot/META-INF中。(若是只有一个项目使用连接池的话,则剪切到使用连接池项目webRoot/META-INF中。若是多个项目都使用连接池,则不进行操作第二步。)

//第三步:则在程序中获得连接:
Context ctx=new InitialContext();

//通过JNDI查找DataSource
DataSource ds=(DataSource)ctx.lookup("java:comp/env/jdbc/chao");
conn=ds.getConnection();


其中的name属性是数据源名称,通常采取jdbc/**.
type属性是数据源方式。
driverClassName属性是驱动程序名称。(此文中是oracle驱动程序)
username,password,数据库名称和密码
url:访问的数据库路径。其中url的内容组成解析上篇博客中已经分析——Oracle安装以及测试Oracle数据库
maxActive属性是并发连接的最大数。设置为0则无限制。
maxWait属性是等待连接的最大连接的时间。
maxIdle属性是连接池中空闲的连接的个数。
上文中的设置的 maxActive="4"说明可以最大连接的个数为4个,再建立连接,则出现异常。
而maxIdle="2"说明当关闭数据库时(不是真正的断开连接,而是归还连接池中)连接池中最大可以有空闲的连接数为2个。
若是再有建立连接,此时若连接池中没有空闲的连接,但是又没有达到maxActive并发的最大连接数,则在连接池中建立连接。

需要 Connection时,调用获取:C3P0Util.getConnection(); 调用关闭: C3P0Util.closeAll(rs, ps, conn);

前提已经有jdbc的驱动包,请自行下载。

Demo下载:jsp、dbcp、c3p0、jstl、等综合案例