程序師世界是廣大編程愛好者互助、分享、學習的平台,程序師世界有你更精彩!
首頁
編程語言
C語言|JAVA編程
Python編程
網頁編程
ASP編程|PHP編程
JSP編程
數據庫知識
MYSQL數據庫|SqlServer數據庫
Oracle數據庫|DB2數據庫
 程式師世界 >> 數據庫知識 >> MYSQL數據庫 >> MySQL綜合教程 >> MySql數據庫連接池

MySql數據庫連接池

編輯:MySQL綜合教程

MySql數據庫連接池


1.傳統鏈接(如下為示意圖)

\

注意:

(1).傳統方式找DriverManager要連接,數目是有限的。

(2).傳統方式的close(),並沒有將Connection重用,只是切斷應用程序和數據庫的橋梁,即無發送到SQL命令到數據庫端執行

(3).項目中,對於Connection不說,不會直接使用DriverManager取得,而使用連接池方式。

2.采用連接池(示意圖)

\

3.開源數據庫連接池

(1).現在很多Web服務器(Weblogic, WebSphere, Tomcat)都提供了DataSoruce的實現,即連接池的實現。通常我們把DataSource的實現,按其英文含義稱之為數據源,數據源中都包含了數據庫連接池的實現。
(2).也有一些開源組織提供了數據源的獨立實現:
DBCP 數據庫連接池(tomcat)
C3P0 數據庫連接池(hibernate)
(3).實際應用時不需要編寫連接數據庫代碼,直接從數據源獲得數據庫的連接。程序員編程時也應盡量使用這些數據源的實現,以提升程序的數據庫訪問性能。

4.C3P0的使用:
(1).在classpath的路徑下配置xml文件,即src的文件下而且這個文件名必須是c3p0-config.xml

原始的c3p0-config.xml的文件參數:

<c3p0-config>
	<default-config>
		<!-- 當連接池中的連接耗盡的時候c3p0一次同時獲取的連接數。Default: 3 -->
		<property name="acquireIncrement">3</property>

		<!-- 定義在從數據庫獲取新連接失敗後重復嘗試的次數。Default: 30 -->
		<property name="acquireRetryAttempts">30</property>

		<!-- 兩次連接中間隔時間,單位毫秒。Default: 1000 -->
		<property name="acquireRetryDelay">1000</property>

		<!-- 連接關閉時默認將所有未提交的操作回滾。Default: false -->
		<property name="autoCommitOnClose">false</property>

		<!--
			c3p0將建一張名為Test的空表,並使用其自帶的查詢語句進行測試。如果定義了這個參數那麼
			屬性preferredTestQuery將被忽略。你不能在這張Test表上進行任何操作,它將只供c3p0測試 使用。Default:
			null
		-->
		<property name="automaticTestTable">Test</property>

		<!--
			獲取連接失敗將會引起所有等待連接池來獲取連接的線程拋出異常。但是數據源仍有效
			保留,並在下次調用getConnection()的時候繼續嘗試獲取連接。如果設為true,那麼在嘗試
			獲取連接失敗後該數據源將申明已斷開並永久關閉。Default: false
		-->
		<property name="breakAfterAcquireFailure">false</property>

		<!--
			當連接池用完時客戶端調用getConnection()後等待獲取新連接的時間,超時後將拋出
			SQLException,如設為0則無限期等待。單位毫秒。Default: 0
		-->
		<property name="checkoutTimeout">100</property>

		<!--
			通過實現ConnectionTester或QueryConnectionTester的類來測試連接。類名需制定全路徑。 Default:
			com.mchange.v2.c3p0.impl.DefaultConnectionTester
		-->
		<property name="connectionTesterClassName"></property>

		<!--
			指定c3p0 libraries的路徑,如果(通常都是這樣)在本地即可獲得那麼無需設置,默認null即可 Default: null
		-->
		<property name="factoryClassLocation">null</property>

		<!--
			Strongly disrecommended. Setting this to true may lead to subtle and
			bizarre bugs. (文檔原文)作者強烈建議不使用的一個屬性
		-->
		<property name="forceIgnoreUnresolvedTransactions">false</property>

		<!-- 每60秒檢查所有連接池中的空閒連接。Default: 0 -->
		<property name="idleConnectionTestPeriod">60</property>

		<!-- 初始化時獲取三個連接,取值應在minPoolSize與maxPoolSize之間。Default: 3 -->
		<property name="initialPoolSize">3</property>

		<!-- 最大空閒時間,60秒內未使用則連接被丟棄。若為0則永不丟棄。Default: 0 -->
		<property name="maxIdleTime">60</property>

		<!-- 連接池中保留的最大連接數。Default: 15 -->
		<property name="maxPoolSize">15</property>

		<!--
			JDBC的標准參數,用以控制數據源內加載的PreparedStatements數量。但由於預緩存的statements
			屬於單個connection而不是整個連接池。所以設置這個參數需要考慮到多方面的因素。
			如果maxStatements與maxStatementsPerConnection均為0,則緩存被關閉。Default: 0
		-->
		<property name="maxStatements">100</property>

		<!--
			maxStatementsPerConnection定義了連接池內單個連接所擁有的最大緩存statements數。Default: 0
		-->
		<property name="maxStatementsPerConnection"></property>

		<!--
			c3p0是異步操作的,緩慢的JDBC操作通過幫助進程完成。擴展這些操作可以有效的提升性能
			通過多線程實現多個操作同時被執行。Default: 3
		-->
		<property name="numHelperThreads">3</property>

		<!--
			當用戶調用getConnection()時使root用戶成為去獲取連接的用戶。主要用於連接池連接非c3p0 的數據源時。Default:
			null
		-->
		<property name="overrideDefaultUser">root</property>

		<!-- 與overrideDefaultUser參數對應使用的一個參數。Default: null-->
		<property name="overrideDefaultPassword">password</property>

		<!-- 密碼。Default: null-->
		<property name="password"></property>

		<!--
			定義所有連接測試都執行的測試語句。在使用連接測試的情況下這個一顯著提高測試速度。注意:
			測試的表必須在初始數據源的時候就存在。Default: null
		-->
		<property name="preferredTestQuery">select id from test where id=1
		</property>

		<!-- 用戶修改系統配置參數執行前最多等待300秒。Default: 300 -->
		<property name="propertyCycle">300</property>

		<!--
			因性能消耗大請只在需要的時候使用它。如果設為true那麼在每個connection提交的
			時候都將校驗其有效性。建議使用idleConnectionTestPeriod或automaticTestTable
			等方法來提升連接測試的性能。Default: false
		-->
		<property name="testConnectionOnCheckout">false</property>

		<!-- 如果設為true那麼在取得連接的同時將校驗連接的有效性。Default: false -->
		<property name="testConnectionOnCheckin">true</property>

		<!-- 用戶名。Default: null-->
		<property name="user">root</property>

		<!--
			早期的c3p0版本對JDBC接口采用動態反射代理。在早期版本用途廣泛的情況下這個參數允許用戶恢復到動態反射代理以解決不穩定的故障。最新的非反射代理更快並且已經開始廣泛的被使用,所以這個參數未必有用。現在原先的動態反射與新的非反射代理同時受到支持,但今後可能的版本可能不支持動態反射代理。Default:
			false。
		-->
		<property name="usesTraditionalReflectiveProxies">false</property>
		<property name="automaticTestTable">con_test</property>
		<property name="checkoutTimeout">30000</property>
		<property name="idleConnectionTestPeriod">30</property>
		<property name="initialPoolSize">10</property>
		<property name="maxIdleTime">30</property>
		<property name="maxPoolSize">25</property>
		<property name="minPoolSize">10</property>
		<property name="maxStatements">0</property>
		<user-overrides user="swaldman">
		</user-overrides>
	</default-config>
	<named-config name="dumbTestConfig">
		<property name="maxStatements">200</property>
		<user-overrides user="poop">
			<property name="maxStatements">300</property>
		</user-overrides>
	</named-config>
</c3p0-config>
實戰練習:
1>.首先配置c3p0-config.xml文件
<?xml version="1.0" encoding="UTF-8"?>
<c3p0-config>
	<default-config>
		<property name="driverClass">com.mysql.jdbc.Driver</property>
		<property name="user">root</property>
		<property name="password">wwh</property>
		<property name="jdbcUrl">jdbc:mysql://127.0.0.1:3306/jdbctest</property>
	</default-config>
</c3p0-config>
2>.代碼操作連接(TestC3P0.java)
package cn.wwh.www.java.jdbc.datasource;

import java.sql.Connection;

import com.mchange.v2.c3p0.ComboPooledDataSource;

/**
 *類的作用:
 *
 *
 *@author 一葉扁舟
 *@version 1.0
 *@創建時間: 2014-9-2   上午12:02:13
 */

//測試連接池C3P0的用法
public class TestC3P0 {
	public static void main(String[] args) throws Exception {
		long begin = System.currentTimeMillis();
		//創建C3P0連接池,並加載c3p0-config.xml文件
		ComboPooledDataSource dataSource = new ComboPooledDataSource();
		for(int i=1;i<=1000000;i++){
			Connection conn = dataSource.getConnection();
			if(conn!=null){
				System.out.println("獲取連接第"+i+"個");
				conn.close();
			}
		}
		long end = System.currentTimeMillis();
		System.out.println("用了" + (end-begin)/1000+"秒");
	}
}

5.DBCP的使用:
(1).采用類加載的方式,文件名是:dbcp.properties

driverClassName=com.mysql.jdbc.Driver
url=jdbc:mysql://127.0.0.1:3306/jdbctest
username=root
password=wwh
(2).在代碼中使用(TestDBCP.java)
package cn.wwh.www.java.jdbc.datasource;

import java.io.InputStream;
import java.sql.Connection;
import java.util.Properties;

import javax.sql.DataSource;

import org.apache.commons.dbcp.BasicDataSourceFactory;

/**
 *類的作用:采用DBCP連接池的方式去獲取數據庫的鏈接,並測試他的時間
 *
 *
 *@author 一葉扁舟
 *@version 1.0
 *@創建時間: 2014-9-1   下午09:27:59
 */

//測試連接池DBCP的用法
public class TestDBCP {
	public static void main(String[] args) throws Exception {
		long begin = System.currentTimeMillis();
		//加載屬性文件
		InputStream is = TestDBCP.class.getClassLoader().getResourceAsStream("cn/wwh/www/java/jdbc/config/dbcp.properties");
		Properties props = new Properties();
		props.load(is);
		//創建DBCP連接池工廠
		BasicDataSourceFactory factory = new BasicDataSourceFactory(); 
		//創建數據源,即連接池
		DataSource ds = factory.createDataSource(props);
		for(int i=1;i<=1000000;i++){
			//從連接池中取得一個空閒的連接對象
			Connection conn = ds.getConnection();
			if(conn!=null){
				System.out.println("獲取連接第"+i+"個");
			}
			//將連接對象還回給連接池
			conn.close();
		}
		long end = System.currentTimeMillis();
		System.out.println("用了" + (end-begin)/1000+"秒");
	}
}
第一的測試時間為18秒,第二個的測試時間為13秒,不同的機器性能不一樣,測試的時間快慢也不可能。但是理論上C3P0的速度應該更快,但是我測試的數據卻恰恰相反,很是奇怪。

總結:

1>DBCP和C3P0,都是Java開源的,都必須直接或間接實現javax.sql.DataSource接口
2>DBCP連接池需要dbcp.properties文件,同時需加入3個對應的jar包
3>C3P0連接池需要在/WEB-INF/classes/目錄下存放c3p0-config.xml文件,該類ComboPooledDataSource在創建時
會自動在指定的目錄下找xml文件,並加載默認設置

4>tomcat用的也是c3p0

6.導入的jar包

commons-dbcp.jar:DBCP實現要導入的jar

commons-pool.jar: 連接池實現的依賴類

commons-collections.jar :連接池實現的集合類

c3p0-0.9.1.2.jar :C3P0實現要導入的jar包

  1. 上一頁:
  2. 下一頁:
Copyright © 程式師世界 All Rights Reserved