您好,登錄后才能下訂單哦!
這篇文章給大家分享的是有關在Spring中使用數據源DBCP、C3P0、JNDI的示例的內容。小編覺得挺實用的,因此分享給大家做個參考,一起跟隨小編過來看看吧。
在 Spring 中,有以下三種方式來創建數據源:
通過 JNDI 獲取應用服務器中的數據源;
在 Spring 容器中配置數據源;
通過代碼來創建數據源,這種方式適用于無容器依賴的單元測試。
1 配置數據源
Spring 在第三方依賴包中包含了 2 種數據源的實現包 一個是 Apache 的 DBCP;另一個是 C3P0。 我們可以在 Spring 配置文件中直接配置這些數據源 。
1.1 DBCP
DBCP (Database Connection Pool)是一個依賴 Jakarta commons-pool 對象池機制的數據庫連接池,所以在類路徑下還必須包括 commons-pool.jar。 下面是使用 DBCP 配置 MySql 數據源的配置片段:
<bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close"> <property name="driverClassName" value="com.mysql.jdbc.Driver" /> <property name="url" value="jdbc:mysql://localhost:3309/db" /> <property name="username" value="root" /> <property name="password" value="xxxxxx" /> </bean>
BasicDataSource 提供了 close() 方法用于關閉數據源,所以必須設定 destroy-method=”close”, 以便 Spring 容器關閉時,能夠正常關閉數據源。
除以上必須的數據源屬性外,還有一些常用的屬性。
事務屬性:
屬性 | 默認值 | 說明 |
---|---|---|
defaultAutoCommit | true | 連接默認為 auto-commit 狀態。 |
defaultReadOnly | 驅動默認值 | 連接默認的 read-only 狀態 。如果沒有設置則 setReadOnly 方法將不會被調用。( 某些驅動不支持只讀模式 , 比如:Informix) |
defaultTransactionIsolation | 驅動默認值 | 連接默認的 TransactionIsolation 狀態。有這些值:NONE、READ_COMMITTED、READ_UNCOMMITTED、REPEATABLE_READ、SERIALIZABLE。 |
連接數相關屬性:
屬性 | 默認值 | 說明 |
---|---|---|
initialSize | 0 | 初始化連接數:連接池啟動時創建的初始化連接數量。 |
maxActive | 8 | 最大活動連接 : 連接池在同一時間內能夠分配的最大活動連接的數量。如果設置為非正數,則表示不限制。 |
maxIdle | 8 | 最大空閑連接 : 連接池中容許保持空閑狀態的最大連接數量 , 超過的空閑連接將被釋放 , 如果設置為負數,則表示不限制。 |
minIdle | 0 | 最小空閑連接 : 連接池中容許保持空閑狀態的最小連接數量 , 低于這個數量將創建新的連接 , 如果設置為 0,則表示不創建。 |
maxWait | 無限 | 最大等待時間 : 當沒有可用連接時 , 連接池等待連接被歸還的最大時間 ( 單位為毫秒 ) , 超出時間將拋出異常 , 如果設置為 -1,則表示無限等待。 |
連接監測與維護相關屬性:
屬性 | 默認值 | 說明 |
---|---|---|
validationQuery | 無 | 配置 SQL 查詢語句 , 用于驗證從連接池取出的連接是否可用。如果指定 , 則查詢必須是一個 SQL SELECT,并且必須返回至少一行記錄。MySQL 中是 “select 1”;在 Oracle 中是 "select 1 from dual"。 |
testOnBorrow | true | 指明是否從連接池中取出連接之前進行檢測 , 如果檢測失敗 , 則從池中去除連接并嘗試取出另一個新的連接。 注意 : 設置為 true 后如果要生效,則 validationQuery 參數必須正確被設置。 |
testOnReturn | false | 指明是否在歸還到池中前進行檢測。 注意 : 與 testOnBorrow 一樣,設置為 true 后如果要生效,則 validationQuery 參數必須正確被設置。 |
testWhileIdle | false | 指明連接是否會被空閑連接回收器 ( 如果有 ) 所檢測。 如果檢測失敗 , 則連接將從池中被移除。 注意 : 設置為 true 后如果要生效,則 validationQuery 參數必須正確被設置。 |
timeBetweenEvictionRunsMillis | -1 | 空閑連接回收器線程運行的周期 , 以毫秒為單位。如果設置為非正數 , 則不運行空閑連接回收器線程。 注意 : 啟用該參數時,則 validationQuery 參數必須正確被設置。 |
numTestsPerEvictionRun | 3 | 在每次空閑連接回收器線程 ( 如果有 ) 運行時需要檢測的連接數量。 |
minEvictableIdleTimeMillis | 1000 * 60 * 30 | 連接在池中保持空閑而不被空閑連接回收器線程回收的最小時間值,以毫秒為單位。 |
緩存相關屬性:
屬性 | 默認值 | 說明 |
---|---|---|
poolPreparedStatements | false | 開啟連接池的 prepared statement 功能設置為 true 后,所有的 CallableStatement 和 PreparedStatement 都會被緩存起來。 |
maxOpenPreparedStatements | 不限制 | 能夠同時分配打開的 statements 的最大數量。0 表示不限制。 |
連接泄露回收相關屬性:
屬性 | 默認值 | 說明 |
---|---|---|
removeAbandoned | false | 是否刪除泄露的連接。如果設置為 true, 那么那些可能存在泄露的連接會被刪除。假設 maxActive 為 10 個,活動連接為 8 個,空閑連接為 1 個,10-8-1=1,那么就會把刪除這個連接(會先檢測該活動連接未被使用的時間是否超過 removeAbandonedTimeout)。如果需要一個長連接操作,那么 removeAbandoned 需要設置的長一些,否則正常使用的連接可能會被誤刪除。 |
removeAbandonedTimeout | 300 | 泄露的連接可以被刪除的時間段,單位為秒。 |
logAbandoned | false | 當 Statement 或連接被泄露時是否打印堆棧日志 。 |
假設數據庫用的是 MySQL,那么如果數據源配置不當,將可能會發生經典的 “8 小時問題 ”。 原因是 MySQL 在默認情況下如果發現一個連接的空閑時間超過 8 小時,那么會在數據庫端自動關閉這個連接 。 而數據源并不知道這個連接已經被關閉了,所以當它將這個無用的連接返回給某個 DAO 時, DAO 就會拋出無法獲取 connection 的異常 。
DBCP 的 testOnBorrow 默認設置為 true,所以從連接池中取出連接之前會先進行檢測,因為不會發生 “8 小時問題 ”。 但如果每次取連接時都進行檢測,那么在高并發應用下就會產生性能問題。
因此建議在高并發下,將 testOnBorrow 設置為 false;然后將 testWhileIdle 設置為 true,打開空閑連接回收器;最后把 timeBetweenEvictionRunsMillis 的值設定為小于 8 小時,這樣那些被 MySQL 所關閉的空閑連接,就會被清除出去。這樣不僅解決了 “8 小時問題 ”,而且還保證了高性能 O(∩_∩)O哈哈~
注意:因為 MySQL 本身的 interactive-timeout(單位為 s)參數,可以設定空閑連接的過期時間,所以我們要想獲取到這個參數值,然后再設定 DBCP 的 timeBetweenEvictionRunsMillis 屬性值。
1.2 C3P0
C3P0 是一個開放源代碼的 JDBC 數據源實現項目,它實現了 JDBC3 和 JDBC2 擴展規范說明的 Connection 和 Statement 池。
下面是使用 C3P0 配置 MySql 數據源的配置片段:
<bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource" destroy-method="close"> <property name="driverClass" value="oracle.jdbc.driver.OracleDriver" /> <property name="jdbcUrl" value="jdbc:mysql://localhost:3309/db" /> <property name="use" value="xxx" /> <property name="password" value="xxxxxx" /> </bean>
C3P0 也提供了一個用于關閉數據源的 close() 方法,這樣我們就可以保證 Spring 容器被關閉時,能夠成功關閉數據源 。
屬性 | 默認值 | 說明 |
---|---|---|
acquireIncrement | 當連接池中無空閑連接時, 一次性創建新連接的數量。 | |
acquireRetryAttempts | 30 | 在從數據庫獲取新連接失敗后,重復嘗試的次數。 |
acquireRetryDelay | 1000 | 嘗試獲取連接之間的間隔時間,單位為毫秒。 |
autoCommitOnClose | false | 連接關閉時,將所有未提交的操作回滾 。 |
automaticTestTable | null | 會創建一張名為 Test 的空表,并使用其自帶的查詢語句進行測試 。 如果定義了這個參數,那么 preferredTestQuery 屬性 將被忽略 。 我們不能在這張 Test 表上進行任何操作,它僅為 C3P0 測試所用。 |
breakAfterAcquireFailure | false | 獲取連接失敗時,將會引起所有等待獲取連接的線程拋出異常 。 但是數據源仍有效保留,并在下次調用 getConnection() 時繼續嘗試獲取連接 。 在嘗試獲取連接失敗后,該數據源將申明已斷開并永久關閉。 |
checkoutTimeout | 0 | 當連接池中的連接用完時,客戶端調用 getConnection() 后等待獲取新連接的時間,單位:毫秒。超時后將拋出 SQLException 。設為 0 表示無限期等待 。 |
connectionTesterClassName | com.mchange.v2.C3P0.impl.DefaultConnectionTester | 通過實現 ConnectionTester 或 QueryConnectionTester 的類來測試連接,類名需設置為全限定名 。 |
idleConnectionTestPeriod | 0 | 隔多少秒,檢查連接池中的所有空閑連接。0 表示不檢查。 |
initialPoolSize | 3 | 初始化時創建的連接數,應在 minPoolSize 與 maxPoolSize 之間取值 。 |
maxIdleTime | 0 | 最大空閑時間,超過空閑時間的連接將會被丟棄 。 為 0 或負數則表示永不丟棄 。 |
maxPoolSize | 15 | 連接池中保留的最大連接數 。 |
maxStatements | 0 | JDBC 標準參數,用以控制數據源內加載的 PreparedStatement 數量 。 但由于預緩存的 Statement 屬于單個 Connection 而不是整個連接池 。 所以設置這個參數需要多方面的考慮,如果 maxStatements 與 maxStatementsPerConnection 均為 0 ,則緩存被關閉 。 |
maxStatementsPerConnection | 0 | 連接池內單個連接所擁有的最大緩存 Statement 數 。 |
numHelperThreads | 3 | C3P0 是異步操作的,緩慢的 JDBC 操作通過 HelperThreads 完成 。 通過多線程實現多個操作同時被執行,這樣可以有效地提升性能。 |
preferredTestQuery | null | 定義所有連接測試都執行的測試語句。在使用連接測試的情況下,這個參數能夠顯著地提高測試速度。測試的表必須在初始數據源時就存在。 |
propertyCycle | 300 | 修改系統配置參數生效時長,單位為 s。 |
testConnectionOnCheckout | false | 因性能消耗大,所以請只在需要時開啟 。 如果設為 true 那么在每個 connection 提交的時候都將校驗其有效性 。 建議使用 idleConnectionTestPeriod 或 automaticTestTable 等方法來提升連接測試的性能 。 |
testConnectionOnCheckin | false | 如果設為 true,那么在取得連接的同時將校驗其連接的有效性。 |
2 JNDI 數據源
如果應用配置在高性能的應用服務器(如 WebLogic 或 Websphere 等)上,我們可能更希望使用應用服務器所提供的數據源 。 應用服務器的數據源使用 JNDI 方式來供調用者使用, Spring 為此專門提供了引用 JNDI 資源的 JndiObjectFactoryBean 類 。 下面是一個簡單的配置:
<bean id="dataSource" class="org.springframework.jndi.JndiObjectFactoryBean" p:jndiName="java:comp/env/jdbc/ds"/>
Spring2.0+ 為獲取 J2EE 資源提供了一個 jee 命名空間,通過 jee 命名空間,可以有效地簡化 J2EE 資源的引用:
<?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:p="http://www.springframework.org/schema/p" xmlns:jee="http://www.springframework.org/schema/jee" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.0.xsd http://www.springframework.org/schema/jee http://www.springframework.org/schema/jee/spring-jee-4.0.xsd "> <jee:jndi-lookup id="dataSource" jndi-name="java:comp/env/jdbc/ds"/> </beans>
3 Spring 數據源實現類
Spring 本身也提供了一個簡單的數據源實現類 DriverManagerDataSource ,它位于 org.springframework.jdbc.datasource 包中 。 這個類實現了 javax.sql.DataSource 接口,但它并沒有提供池化連接機制,每次調用 getConnection() 方法獲取新連接時,只是簡單地創建一個新的連接 。它不需要額外的依賴類,所以,這個數據源類比較適合在單元測試中使用 。
Spring 數據源實現類既可以通過配置直接使用,也可以在代碼中實例化調用:
DriverManagerDataSource dataSource=new DriverManagerDataSource(); dataSource.setDriverClassName("com.mysql.jdbc.Driver"); dataSource.setUrl("jdbc:mysql://127.0.0.1:3306/spring4"); dataSource.setUsername("root"); dataSource.setPassword(""); try { Connection connection=dataSource.getConnection(); if(connection.isClosed()){ System.out.println("連接已關閉"); }else{ System.out.println("連接已開啟"); } } catch (SQLException e) { e.printStackTrace(); }
感謝各位的閱讀!關于“在Spring中使用數據源DBCP、C3P0、JNDI的示例”這篇文章就分享到這里了,希望以上內容可以對大家有一定的幫助,讓大家可以學到更多知識,如果覺得文章不錯,可以把它分享出去讓更多的人看到吧!
免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。