Java中JDBC連接池的基本原理及實現(xiàn)方式
更新時間：2021年12月20日 09:54:49 作者：小調~
本文詳細講解了Java中JDBC連接池的基本原理及實現(xiàn)方式，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧
一、 應用程序直接建立數(shù)據(jù)庫連接模型
應用程序直接每次訪問數(shù)據(jù)庫時，都建立創(chuàng)建一個數(shù)據(jù)庫的鏈接，這樣每次建立這樣的連接都需要耗費的資源，當同時有很多用戶在使用應用程序時，可能會導致應用程序崩潰。
圖為應用程序直接建立數(shù)據(jù)庫連接模型
二、使用數(shù)據(jù)庫連接池優(yōu)化模型
數(shù)據(jù)庫連接池的基本思路是，平時建立適量的數(shù)據(jù)庫的連接，放在一個集合中，當有用戶需要建立數(shù)據(jù)庫連接的時候，直接到集合中取出一個數(shù)據(jù)庫連接對象（Connection），這樣不用再需要重新創(chuàng)建，這樣會節(jié)省大量的資源，當用戶不需要在對數(shù)據(jù)庫進行訪問了，那么就將數(shù)據(jù)庫連接對象（Connection）重新放回到集合中，以便方便下次使用。
數(shù)據(jù)庫連接池優(yōu)化模型圖
1、關于連接池中的連接數(shù)量的一些規(guī)定：
- （1）最小連接數(shù):是連接池一直保持的數(shù)據(jù)庫連接,所以如果應用程序對數(shù)據(jù)庫連接的使用量不大,將會有大量的數(shù)據(jù)庫連接資源被浪費（適量）.
- （2）最大連接數(shù):是連接池能申請的最大連接數(shù),如果數(shù)據(jù)庫連接請求超過次數(shù),后面的數(shù)據(jù)庫連接請求將被加入到等待隊列中,這會影響以后的數(shù)據(jù)庫操作。通常在使用完起始集合中的連接后，會再重新創(chuàng)建一些數(shù)據(jù)庫連接對象，用來滿足用戶需求，但是這種新建并不是無限制的。
- （3）當使用完的連接對象需要重新放回到集合中以備使用，但是超過最小連接數(shù)的連接在使用完不會馬上被釋放,他將被放到連接池中等待重復使用或是超時后最終被釋放。
2、編寫數(shù)據(jù)庫連接池
簡單思路為：創(chuàng)建一個類繼承DataSource接口，在類中實現(xiàn)靜態(tài)的加載出配置文檔db.properties文檔，并創(chuàng)建最小連接量的數(shù)據(jù)庫連接對象(Connection)，添加到Linkedlist（選擇Linkedlist集合原因是便于增刪）集合中。重寫getConnection()函數(shù)，在getConnection()函數(shù)中實現(xiàn)數(shù)據(jù)庫連接對象的獲取。
db.properties文檔
driver=com.mysql.jdbc.Driver url=jdbc:mysql://127.0.0.1:3306/imooc?useUnicode=true&characterEncoding=utf-8 username=root password=tiger jdbcConnectionInitSize=10
創(chuàng)建數(shù)據(jù)庫連接池：
package JDBC;
import java.io.IOException;
import java.io.InputStream;
import java.io.PrintWriter;
import java.lang.reflect.InvocationHandler;
import java.lang.reflect.Method;
import java.lang.reflect.Proxy;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.sql.SQLFeatureNotSupportedException;
import java.util.LinkedList;
import java.util.Properties;
import java.util.logging.Logger;
import javax.sql.DataSource;
public class JdbcConnectionsPool implements DataSource {
/*
* 使用靜態(tài)塊代碼，初始化連接池，創(chuàng)建連接池的中最小鏈接數(shù)量連接，
* 創(chuàng)建linkedlist集合，將這些連接放入集合中
*/
//創(chuàng)建linkedlist集合
private static LinkedList<Connection> linkedlist1=new LinkedList<Connection>();
private static String driver;//
private static String url;//
private static String username;//數(shù)據(jù)庫登陸名
private static String password;//數(shù)據(jù)庫的登陸密碼
private static int jdbcConnectionInitSize;//最小連接數(shù)量
private static int max=1; //當前最大連接數(shù)量=max*jdbcConnectionInitSize
static{
//通過反射機制獲取訪問db.properties文件
InputStream is=JdbcConnectionsPool.class.getResourceAsStream("/db.properties");
Properties prop=new Properties();
try {
//加載db.properties文件
prop.load(is);
//獲取db.properties文件中的數(shù)據(jù)庫連接信息
driver=prop.getProperty("driver");
url=prop.getProperty("url");
username=prop.getProperty("username");
password=prop.getProperty("password");
jdbcConnectionInitSize=Integer.parseInt(prop.getProperty("jdbcConnectionInitSize"));
Class.forName("com.mysql.jdbc.Driver");
//創(chuàng)建最小連接數(shù)個數(shù)據(jù)庫連接對象以備使用
for(int i=0;i<jdbcConnectionInitSize;i++){
Connection conn=DriverManager.getConnection(url, username, password);
System.out.println("獲取到了鏈接" + conn);
//將創(chuàng)建好的數(shù)據(jù)庫連接對象添加到Linkedlist集合中
linkedlist1.add(conn);
}
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (ClassNotFoundException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
@Override
public PrintWriter getLogWriter() throws SQLException {
// TODO Auto-generated method stub
return null;
}
@Override
public void setLogWriter(PrintWriter out) throws SQLException {
// TODO Auto-generated method stub
}
@Override
public void setLoginTimeout(int seconds) throws SQLException {
// TODO Auto-generated method stub
}
@Override
public int getLoginTimeout() throws SQLException {
// TODO Auto-generated method stub
return 0;
}
@Override
public Logger getParentLogger() throws SQLFeatureNotSupportedException {
// TODO Auto-generated method stub
return null;
}
@Override
public <T> T unwrap(Class<T> iface) throws SQLException {
// TODO Auto-generated method stub
return null;
}
@Override
public boolean isWrapperFor(Class<?> iface) throws SQLException {
// TODO Auto-generated method stub
return false;
}
/*
* 實現(xiàn)數(shù)據(jù)庫連接的獲取和新創(chuàng)建
*/
@Override
public Connection getConnection() throws SQLException {
//如果集合中沒有數(shù)據(jù)庫連接對象了，且創(chuàng)建的數(shù)據(jù)庫連接對象沒有達到最大連接數(shù)量，可以再創(chuàng)建一組數(shù)據(jù)庫連接對象以備使用
if(linkedlist1.size()==0&&max<=5){
try {
Class.forName("com.mysql.jdbc.Driver");
} catch (ClassNotFoundException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
for(int i=0;i<jdbcConnectionInitSize;i++){
Connection conn=DriverManager.getConnection(url, username, password);
System.out.println("獲取到了鏈接" + conn);
//將創(chuàng)建好的數(shù)據(jù)庫連接對象添加到Linkedlist集合中
linkedlist1.add(conn);
}
max++;
}
if(linkedlist1.size()>0){
//從linkedlist集合中取出一個數(shù)據(jù)庫鏈接對象Connection使用
Connection conn1=linkedlist1.removeFirst();
System.out.println("linkedlist1數(shù)據(jù)庫連接池大小是" + linkedlist1.size());
/*返回一個Connection對象，并且設置Connection對象方法調用的限制，
*當調用connection類對象的close()方法時會將Connection對象重新收集放入linkedlist集合中。
*/
return (Connection) Proxy.newProxyInstance(conn1.getClass().getClassLoader(),//這里換成JdbcConnectionsPool.class.getClassLoader();也行
conn1.getClass().getInterfaces(), new InvocationHandler() {
@Override
public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {
if(!method.getName().equalsIgnoreCase("close")){
return method.invoke(conn1, args);
}else{
linkedlist1.add(conn1);
System.out.println(conn1+"對象被釋放，重新放回linkedlist集合中！");
System.out.println("此時Linkedlist集合中有"+linkedlist1.size()+"個數(shù)據(jù)庫連接對象！");
return null;
}
}
});
}else{
System.out.println("連接數(shù)據(jù)庫失??！");
}
return null;
}
@Override
public Connection getConnection(String username, String password) throws SQLException {
return null;
}
}
進一步封裝一些相關數(shù)據(jù)庫的類的方法
package JDBC;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
public class JdbcConnectionPoolTest {
/**
* @Field: pool
* 數(shù)據(jù)庫連接池
*/
private static JdbcConnectionsPool pool = new JdbcConnectionsPool();
/**
* @Method: getConnection
* @Description: 從數(shù)據(jù)庫連接池中獲取數(shù)據(jù)庫連接對象
* @return Connection數(shù)據(jù)庫連接對象
* @throws SQLException
*/
public static Connection getConnection() throws SQLException{
return pool.getConnection();
}
/**
* @Method: release
* @Description: 釋放資源，
* 釋放的資源包括Connection數(shù)據(jù)庫連接對象，負責執(zhí)行SQL命令的Statement對象，存儲查詢結果的ResultSet對象
* @param conn
* @param st
* @param rs
*/
public static void release(Connection conn,Statement st,ResultSet rs){
if(rs!=null){
try{
//關閉存儲查詢結果的ResultSet對象
rs.close();
}catch (Exception e) {
e.printStackTrace();
}
rs = null;
}
if(st!=null){
try{
//關閉負責執(zhí)行SQL命令的Statement對象
st.close();
}catch (Exception e) {
e.printStackTrace();
}
}
if(conn!=null){
try{
//關閉Connection數(shù)據(jù)庫連接對象
conn.close();
}catch (Exception e) {
e.printStackTrace();
}
}
}
}
調試代碼：
package JDBC;
import java.sql.Blob;
import java.sql.CallableStatement;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Types;
public class TestJdbcPool {
public static void main(String[] args) throws SQLException {
//實例化封裝了有關數(shù)據(jù)庫類方法類的對象
JdbcConnectionPoolTest jcpt=new JdbcConnectionPoolTest();
//獲得數(shù)據(jù)庫連接對象
Connection conn=jcpt.getConnection();
//下面代碼是存儲過程的調用
String s="call SP_select_nofilter6(?,?,?) ";
CallableStatement cst=conn.prepareCall(s);
cst.setInt(2, 2);
cst.registerOutParameter(1, Types.VARCHAR);
cst.registerOutParameter(3, Types.BLOB);
ResultSet rs=cst.executeQuery();
String name=cst.getString(1);
Blob b=cst.getBlob(3);
System.out.println("name:"+name+" Blob:"+b);
//關閉所有的數(shù)據(jù)庫資源
jcpt.release(conn, cst, rs);
}
}
運行結果：
獲取到了鏈接com.mysql.jdbc.Connection@5f184fc6 獲取到了鏈接com.mysql.jdbc.Connection@723279cf 獲取到了鏈接com.mysql.jdbc.Connection@4e50df2e 獲取到了鏈接com.mysql.jdbc.Connection@7cc355be 獲取到了鏈接com.mysql.jdbc.Connection@52cc8049 獲取到了鏈接com.mysql.jdbc.Connection@7530d0a 獲取到了鏈接com.mysql.jdbc.Connection@4fca772d 獲取到了鏈接com.mysql.jdbc.Connection@7cd84586 獲取到了鏈接com.mysql.jdbc.Connection@70177ecd 獲取到了鏈接com.mysql.jdbc.Connection@cc34f4d linkedlist1數(shù)據(jù)庫連接池大小是9 name:xiao Blob:com.mysql.jdbc.Blob@5197848c com.mysql.jdbc.Connection@5f184fc6對象被釋放，重新放回linkedlist集合中！ 此時Linkedlist集合中有10個數(shù)據(jù)庫連接對象！
標紅的代碼是比較重要的代碼段~，其中Proxy.newProxyInstance(ClassLoader loader, Class<?>[] interfaces, InvocationHandler h)，返回一個指定接口的代理類實例，該接口可以將方法調用指派到指定的調用處理程序，loader參數(shù)定義代理類的類加載器，interfaces - 代理類要實現(xiàn)的接口列表，h - 指派方法調用的調用處理程序 。
三、兩個開源的數(shù)據(jù)庫連接池
在使用了數(shù)據(jù)庫連接池之后，在項目的實際開發(fā)中就不需要編寫連接數(shù)據(jù)庫的代碼了，直接從數(shù)據(jù)源獲得數(shù)據(jù)庫的連接。
1、dbcp連接
（1）導入相關jar包
commons-dbcp2-2.1.1.jar
commons-pool2-2.4.2.jar
commoms-logging-1.2.jar
（2）在項目根目錄增加配置文件dbcp.properties
#連接設置 driverClassName=com.mysql.jdbc.Driver url=jdbc:mysql://localhost:3306/jdbcstudy username=root password=XDP #<!-- 初始化連接 --> initialSize=10 #最大連接數(shù)量 maxActive=50 #<!-- 最大空閑連接 --> maxIdle=20 #<!-- 最小空閑連接 --> minIdle=5 #<!-- 超時等待時間以毫秒為單位 6000毫秒/1000等于60秒 --> maxWait=60000 #JDBC驅動建立連接時附帶的連接屬性屬性的格式必須為這樣：[屬性名=property;] #注意："user" 與 "password" 兩個屬性會被明確地傳遞，因此這里不需要包含他們。 connectionProperties=useUnicode=true;characterEncoding=UTF8 #指定由連接池所創(chuàng)建的連接的自動提交（auto-commit）狀態(tài)。 defaultAutoCommit=true #driver default 指定由連接池所創(chuàng)建的連接的只讀（read-only）狀態(tài)。 #如果沒有設置該值，則“setReadOnly”方法將不被調用。（某些驅動并不支持只讀模式，如：Informix） defaultReadOnly= #driver default 指定由連接池所創(chuàng)建的連接的事務級別（TransactionIsolation）。 #可用值為下列之一：（詳情可見javadoc。）NONE,READ_UNCOMMITTED, READ_COMMITTED, REPEATABLE_READ, SERIALIZABLE defaultTransactionIsolation=READ_UNCOMMITTED
（3）程序實現(xiàn)dbcp連接
代碼演示：
數(shù)據(jù)庫對象的代理類（封裝Connection類的一些方法）
package DBCP;
import java.io.IOException;
import java.io.InputStream;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Properties;
import javax.sql.DataSource;
import org.apache.commons.dbcp.BasicDataSourceFactory;
public class DBCPUtil {
private static DataSource ds;
private static final String configFile="/dbcp.properties";
public DBCPUtil(){
//實例化properties對象用于加載配置文件
Properties prop=new Properties();
InputStream is=DBCPUtil.class.getResourceAsStream(configFile);
try {
prop.load(is);
ds=BasicDataSourceFactory.createDataSource(prop);
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
/*
* 獲取數(shù)據(jù)庫連接對象
*/
public Connection getConn(){
Connection conn=null;
if(ds!=null){
try {
conn=ds.getConnection();
conn.setAutoCommit(false);//設置禁止操作自動提交的情況
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
return conn;
}
return conn;
}
/*
* 封裝數(shù)據(jù)庫相關資源的關閉工作
*/
public void close(ResultSet rs,Statement st,Connection conn) throws SQLException{
if(rs!=null){
rs.close();
}
if(st!=null){
st.close();
}
if(conn!=null){
conn.close();
}
}
}
代碼調用：
package DBCP;
import java.sql.Blob;
import java.sql.CallableStatement;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Types;
public class DbcpTest {
public static void main(String[] args) throws SQLException {
//實例化數(shù)據(jù)庫連接的代理類
DBCPUtil dbcpUtil=new DBCPUtil();
//獲得數(shù)據(jù)庫連接對象
Connection conn=dbcpUtil.getConn();
//下面代碼是存儲過程的調用
String s="call SP_select_nofilter6(?,?,?) ";
CallableStatement cst=conn.prepareCall(s);
cst.setInt(2, 2);
cst.registerOutParameter(1, Types.VARCHAR);
cst.registerOutParameter(3, Types.BLOB);
ResultSet rs=cst.executeQuery();
String name=cst.getString(1);
Blob b=cst.getBlob(3);
System.out.println("name:"+name+" Blob:"+b);
//關閉資源
dbcpUtil.close(rs, cst, conn);
}
}
運行結果：
name:xiao Blob:com.mysql.jdbc.Blob@30946e09
2、c3p0連接池
c3p0是一個開源的JDBC連接池，它實現(xiàn)了數(shù)據(jù)源和JNDI綁定支持JDBC3和JDBC2的標準擴展
（1）導入相關的jar包
cc3p0-0.9.2-pre4.jar
mchange-commons-java-0.2.2.jar
如果是oracle數(shù)據(jù)庫還需要添加c3p0-oracle-thin-extras-0.9.2-pre1.jar
（2）在項目根目錄下增加配置文件
1）c3p0.properties
##配置除user,password,minpoolsize,maxpoolsize的參數(shù) ##[注意] 整數(shù)值不能有空格 #連接設置 driverClassName=com.mysql.jdbc.Driver url=jdbc:mysql://127.0.0.1:3306/imooc?useUnicode=true&characterEncoding=utf-8 username=root password=tiger #初始化時獲取三個連接，取值應在minPoolSize與maxPoolSize之間。Default: 3 c3p0.initialPoolSize=10 #當連接池中的連接耗盡的時候c3p0一次同時獲取的連接數(shù)。Default: 3 c3p0.acquireIncrement=3 #最大空閑時間,60秒內未使用則連接被丟棄。若為0則永不丟棄。Default: 0 #maxIdleTime應該小于MySQL的wait_timeout的值 c3p0.maxIdleTime=600 #定義在從數(shù)據(jù)庫獲取新連接失敗后重復嘗試的次數(shù)。Default: 30 c3p0.acquireRetryAttempts=5 #兩次連接中間隔時間，單位毫秒。Default: 1000 c3p0.acquireRetryDelay=1000 #連接關閉時默認將所有未提交的操作回滾。Default: false c3p0.autoCommitOnClose=false #c3p0將建一張名為Test的空表，并使用其自帶的查詢語句進行測試。如果定義了這個參數(shù)那么 #屬性preferredTestQuery將被忽略。你不能在這張Test表上進行任何操作，它將只供c3p0測試 #使用。Default: null #c3p0.automaticTestTable= #獲取連接失敗將會引起所有等待連接池來獲取連接的線程拋出異常。但是數(shù)據(jù)源仍有效 #保留，并在下次調用getConnection()的時候繼續(xù)嘗試獲取連接。如果設為true，那么在嘗試 #獲取連接失敗后該數(shù)據(jù)源將申明已斷開并永久關閉。Default: false #c3p0.breakAfterAcquireFailure=false #當連接池用完時客戶端調用getConnection()后等待獲取新連接的時間，超時后將拋出 #SQLException,如設為0則無限期等待。單位毫秒。Default: 0 c3p0.checkoutTimeout=10000 #每60秒檢查所有連接池中的空閑連接。Default: 0 c3p0.idleConnectionTestPeriod=600 #JDBC的標準參數(shù)，用以控制數(shù)據(jù)源內加載的PreparedStatements數(shù)量。但由于預緩存的statements #屬于單個connection而不是整個連接池。所以設置這個參數(shù)需要考慮到多方面的因素。 #如果maxStatements與maxStatementsPerConnection均為0，則緩存被關閉。Default: 0 c3p0.maxStatements=100 #maxStatementsPerConnection定義了連接池內單個連接所擁有的最大緩存statements數(shù)。Default: 0 c3p0.maxStatementsPerConnection=0 #c3p0是異步操作的，緩慢的JDBC操作通過幫助進程完成。擴展這些操作可以有效的提升性能 #通過多線程實現(xiàn)多個操作同時被執(zhí)行。Default: 3 c3p0.numHelperThreads=3
2）c3p0-config.xml文檔
<?xml version="1.0" encoding="UTF-8"?>
<!--
c3p0-config.xml必須位于類路徑下面
private static ComboPooledDataSource ds;
static{
try {
ds = new ComboPooledDataSource("MySQL");
} catch (Exception e) {
throw new ExceptionInInitializerError(e);
}
}
-->
<c3p0-config>
<!--
C3P0的缺省(默認)配置，
如果在代碼中“ComboPooledDataSource ds = new ComboPooledDataSource();”這樣寫就表示使用的是C3P0的缺省(默認)配置信息來創(chuàng)建數(shù)據(jù)源
-->
<default-config>
<property name="driverClass">com.mysql.jdbc.Driver</property>
<property name="jdbcUrl">jdbc:mysql://127.0.0.1:3306/imooc?useUnicode=true&characterEncoding=utf-8</property>
<property name="user">root</property>
<property name="password">tiger</property>
<property name="acquireIncrement">5</property>
<property name="initialPoolSize">10</property>
<property name="minPoolSize">5</property>
<property name="maxPoolSize">20</property>
</default-config>
<!--
C3P0的命名配置，
如果在代碼中“ComboPooledDataSource ds = new ComboPooledDataSource("MySQL");”這樣寫就表示使用的是name是MySQL的配置信息來創(chuàng)建數(shù)據(jù)源
-->
<named-config name="MySQL">
<property name="driverClass">com.mysql.jdbc.Driver</property>
<property name="jdbcUrl">jdbc:mysql://127.0.0.1:3306/imooc?useUnicode=true&characterEncoding=utf-8</property>
<property name="user">root</property>
<property name="password">tiger</property>
<property name="acquireIncrement">5</property>
<property name="initialPoolSize">10</property>
<property name="minPoolSize">5</property>
<property name="maxPoolSize">20</property>
</named-config>
</c3p0-config>
（3）編寫類文件，創(chuàng)建連接池
1）c3p0.properties配置文件情況下
數(shù)據(jù)庫對象的代理類（封裝Connection類的一些方法）
package C3P0;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import com.mchange.v2.c3p0.ComboPooledDataSource;
public class C3P0Util {
private static ComboPooledDataSource ds=new ComboPooledDataSource();
/*
* 獲取數(shù)據(jù)庫連接對象
*/
public static Connection getConnection() throws SQLException{
return ds.getConnection();
}
/*
* 封裝數(shù)據(jù)庫相關資源的關閉工作
*/
public void close(ResultSet rs,Statement st,Connection conn) throws SQLException{
if(rs!=null){
rs.close();
}
if(st!=null){
st.close();
}
if(conn!=null){
conn.close();
}
}
}
代碼調用：
package C3P0;
import java.sql.Blob;
import java.sql.CallableStatement;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Types;
public class C3P0Test {
public static void main(String[] args) throws SQLException {
C3P0Util c3p0Util=new C3P0Util();
Connection conn=c3p0Util.getConnection();
//下面代碼是存儲過程的調用
String s="call SP_select_nofilter6(?,?,?) ";
CallableStatement cst=conn.prepareCall(s);
cst.setInt(2, 2);
cst.registerOutParameter(1, Types.VARCHAR);
cst.registerOutParameter(3, Types.BLOB);
ResultSet rs=cst.executeQuery();
String name=cst.getString(1);
Blob b=cst.getBlob(3);
System.out.println("name:"+name+" Blob:"+b);
//關閉資源
c3p0Util.close(rs, cst, conn);
}
}
運行結果：
二月 14, 2017 7:36:12 下午 com.mchange.v2.log.MLog
信息: MLog clients using java 1.4+ standard logging.
二月 14, 2017 7:36:13 下午 com.mchange.v2.c3p0.C3P0Registry
信息: Initializing c3p0-0.9.5.2 [built 08-December-2015 22:06:04 -0800; debug? true; trace: 10]
二月 14, 2017 7:36:13 下午 com.mchange.v2.c3p0.impl.AbstractPoolBackedDataSource
信息: Initializing c3p0 pool... com.mchange.v2.c3p0.ComboPooledDataSource [ acquireIncrement -> 3, acquireRetryAttempts -> 5, acquireRetryDelay -> 1000, autoCommitOnClose -> false, automaticTestTable -> null, breakAfterAcquireFailure -> false, checkoutTimeout -> 10000, connectionCustomizerClassName -> null, connectionTesterClassName -> com.mchange.v2.c3p0.impl.DefaultConnectionTester, contextClassLoaderSource -> caller, dataSourceName -> 2y4pm69mgrekqw18rvmvn|7aec35a, debugUnreturnedConnectionStackTraces -> false, description -> null, driverClass -> com.mysql.jdbc.Driver, extensions -> {}, factoryClassLocation -> null, forceIgnoreUnresolvedTransactions -> false, forceSynchronousCheckins -> false, forceUseNamedDriverClass -> false, identityToken -> 2y4pm69mgrekqw18rvmvn|7aec35a, idleConnectionTestPeriod -> 600, initialPoolSize -> 10, jdbcUrl -> jdbc:mysql://127.0.0.1:3306/imooc?useUnicode=true&characterEncoding=utf-8, maxAdministrativeTaskTime -> 0, maxConnectionAge -> 0, maxIdleTime -> 600, maxIdleTimeExcessConnections -> 0, maxPoolSize -> 15, maxStatements -> 100, maxStatementsPerConnection -> 0, minPoolSize -> 3, numHelperThreads -> 3, preferredTestQuery -> null, privilegeSpawnedThreads -> false, properties -> {user=******, password=******}, propertyCycle -> 0, statementCacheNumDeferredCloseThreads -> 0, testConnectionOnCheckin -> false, testConnectionOnCheckout -> false, unreturnedConnectionTimeout -> 0, userOverrides -> {}, usesTraditionalReflectiveProxies -> false ]
name:xiao Blob:com.mysql.jdbc.Blob@31b7dea0
2）c3p0-config.xml配置文檔情況下
數(shù)據(jù)庫對象的代理類（封裝Connection類的一些方法）
package C3P0;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import com.mchange.v2.c3p0.ComboPooledDataSource;
public class C3P0Util1 {
private static ComboPooledDataSource ds;
/*
* 獲取數(shù)據(jù)庫連接對象
*/
public static Connection getConnection() throws SQLException{
//通過代碼創(chuàng)建C3P0數(shù)據(jù)庫連接池
/*ds = new ComboPooledDataSource();
ds.setDriverClass("com.mysql.jdbc.Driver");
ds.setJdbcUrl("jdbc:mysql://localhost:3306/jdbcstudy");
ds.setUser("root");
ds.setPassword("XDP");
ds.setInitialPoolSize(10);
ds.setMinPoolSize(5);
ds.setMaxPoolSize(20);*/
//通過讀取C3P0的xml配置文件創(chuàng)建數(shù)據(jù)源，C3P0的xml配置文件c3p0-config.xml必須放在src目錄下
//ds = new ComboPooledDataSource();//使用C3P0的默認配置來創(chuàng)建數(shù)據(jù)源
ds = new ComboPooledDataSource("MySQL");//使用C3P0的命名配置來創(chuàng)建數(shù)據(jù)源
return ds.getConnection();
}
/*
* 封裝數(shù)據(jù)庫相關資源的關閉工作
*/
public void close(ResultSet rs,Statement st,Connection conn) throws SQLException{
if(rs!=null){
rs.close();
}
if(st!=null){
st.close();
}
if(conn!=null){
conn.close();
}
}
}
代碼調用：
package C3P0;
import java.sql.Blob;
import java.sql.CallableStatement;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Types;
public class C3P0Test1 {
public static void main(String[] args) throws SQLException {
C3P0Util1 c3p0Util1=new C3P0Util1();
Connection conn=c3p0Util1.getConnection();
//下面代碼是存儲過程的調用
String s="call SP_select_nofilter6(?,?,?) ";
CallableStatement cst=conn.prepareCall(s);
cst.setInt(2, 2);
cst.registerOutParameter(1, Types.VARCHAR);
cst.registerOutParameter(3, Types.BLOB);
ResultSet rs=cst.executeQuery();
String name=cst.getString(1);
Blob b=cst.getBlob(3);
System.out.println("name:"+name+" Blob:"+b);
//關閉資源
c3p0Util1.close(rs, cst, conn);
}
}
運行結果：
二月 14, 2017 8:06:03 下午 com.mchange.v2.log.MLog
信息: MLog clients using java 1.4+ standard logging.
二月 14, 2017 8:06:03 下午 com.mchange.v2.c3p0.C3P0Registry
信息: Initializing c3p0-0.9.5.2 [built 08-December-2015 22:06:04 -0800; debug? true; trace: 10]
二月 14, 2017 8:06:03 下午 com.mchange.v2.c3p0.impl.AbstractPoolBackedDataSource
信息: Initializing c3p0 pool... com.mchange.v2.c3p0.ComboPooledDataSource [ acquireIncrement -> 5, acquireRetryAttempts -> 5, acquireRetryDelay -> 1000, autoCommitOnClose -> false, automaticTestTable -> null, breakAfterAcquireFailure -> false, checkoutTimeout -> 10000, connectionCustomizerClassName -> null, connectionTesterClassName -> com.mchange.v2.c3p0.impl.DefaultConnectionTester, contextClassLoaderSource -> caller, dataSourceName -> MySQL, debugUnreturnedConnectionStackTraces -> false, description -> null, driverClass -> com.mysql.jdbc.Driver, extensions -> {}, factoryClassLocation -> null, forceIgnoreUnresolvedTransactions -> false, forceSynchronousCheckins -> false, forceUseNamedDriverClass -> false, identityToken -> 2y4pm69mgsgybs1qf3g8s|6e5e91e4, idleConnectionTestPeriod -> 600, initialPoolSize -> 10, jdbcUrl -> jdbc:mysql://127.0.0.1:3306/imooc?useUnicode=true&characterEncoding=utf-8, maxAdministrativeTaskTime -> 0, maxConnectionAge -> 0, maxIdleTime -> 600, maxIdleTimeExcessConnections -> 0, maxPoolSize -> 20, maxStatements -> 100, maxStatementsPerConnection -> 0, minPoolSize -> 5, numHelperThreads -> 3, preferredTestQuery -> null, privilegeSpawnedThreads -> false, properties -> {user=******, password=******}, propertyCycle -> 0, statementCacheNumDeferredCloseThreads -> 0, testConnectionOnCheckin -> false, testConnectionOnCheckout -> false, unreturnedConnectionTimeout -> 0, userOverrides -> {}, usesTraditionalReflectiveProxies -> false ]
name:xiao Blob:com.mysql.jdbc.Blob@c39f790
總結：其實不管配置文件是c3p0.properties還是c3p0-config.xml，其代碼實現(xiàn)部分沒有多大區(qū)別，唯一區(qū)別可能就是c3p0-config.xml情況下可以調用含參的ComboPooledDataSource(String s)構造函數(shù)，兩個都可以調用其默認的無參構造函數(shù)。
3、dbcp和c3p0不同之處
| dbcp | c3p0 |
|---|---|
| spring組織推薦使用 | Hibernate組織推薦使用 |
| 強制關閉連接或者數(shù)據(jù)庫重啟后無法自動重連 | 強制關閉連接或者數(shù)據(jù)庫重啟可以自動連接 |
| 沒有自動的去回收空閑連接的功能 | 自動回收空閑的功能 |
| DBCP提供最大連接數(shù) |
c3p0提供最大空閑時間 |
| dbcp并沒用相應功能 | c3p0可以控制數(shù)據(jù)源加載的prepareedstatement數(shù)量，并且可以設置幫助線程的數(shù)量來提升JDBC操作速度 |
以上所述是小編給大家介紹的Java中JDBC連接池的基本原理及實現(xiàn)方式，希望對大家有所幫助。在此也非常感謝大家對腳本之家網站的支持！
相關文章
隨著互聯(lián)網的蓬勃發(fā)展，越來越多的互聯(lián)網企業(yè)面臨著用戶量膨脹而帶來的并發(fā)安全問題。這篇文章主要給大家介紹了關于Java中自旋鎖的相關資料，文中通過示例代碼介紹的非常詳細，對大家學習或者使用Java具有一定的參考學習價值，需要的朋友們下面來一起學習學習吧2019-05-05
mybatis-plus mapper中foreach循環(huán)操作代碼詳解(新增或修改)
這篇文章主要介紹了mybatis-plus mapper中foreach循環(huán)操作代碼詳解(新增或修改),本文通過實例代碼給大家介紹的非常詳細，對大家的學習或工作具有一定的參考借鑒價值，需要的朋友可以參考下2020-11-11
這篇文章主要介紹了解決@Value注解不能注入static修飾的屬性問題，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2022-07-07
這篇文章主要介紹了java中@SuppressWarnings注解用法詳解，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧2021-02-02
SpringMVC @DeleteMapping注解無法獲取參數(shù)值問題及解決
這篇文章主要介紹了SpringMVC @DeleteMapping注解無法獲取參數(shù)值問題及解決方案，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2023-01-01
這篇文章主要介紹了Java寫入寫出Excel操作源碼分享，具有一定借鑒價值，需要的朋友可以參考下。2017-12-12
Java 垃圾回收機制詳解(動力節(jié)點Java學院整理)
在系統(tǒng)運行過程中，會產生一些無用的對象，這些對象占據(jù)著一定的內存，如果不對這些對象清理回收無用對象的內存，可能會導致內存的耗盡，所以垃圾回收機制回收的是內存。下面通過本文給大家詳細介紹java垃圾回收機制，一起學習吧2017-02-02
IoC是一種讓服務消費者不直接依賴于服務提供者的組件設計方式，是一種減少類與類之間依賴的設計原則。下面通過本文給大家分享spring中ioc的概念，感興趣的朋友一起看看吧2021-09-09
spring 自動注入AutowiredAnnotationBeanPostProcessor源碼解析
這篇文章主要介紹了spring自動注入AutowiredAnnotationBeanPostProcessor源碼解析，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進步，早日升職加薪2023-03-03
這篇文章主要為大家詳細介紹了如何簡單實現(xiàn)Java通訊錄系統(tǒng)，文中示例代碼介紹的非常詳細，具有一定的參考價值，感興趣的小伙伴們可以參考一下2018-02-02