首先為什么要使用連接池及為什么要選擇C3P0連接池,這里就不多說了,目前C3P0連接池還是比較方便、比較穩定的連接池,能與spring、hibernate等開源框架進行整合。
一、hibernate中使用C3P0連接池
首先在hibernate項目中引入此c3p0相關jar包,我是在hibernate4.2中拿出來的:
在hibernate.cfg.xml中配置
<?xml version="1.0" encoding="UTF-8"?>
<!-- <!DOCTYPE hibernate-configuration PUBLIC "-//Hibernate/Hibernate Configuration DTD 3.0//EN" "http://www.hibernate.org/dtd/hibernate-configuration-3.0.dtd"> -->
<!DOCTYPE hibernate-configuration PUBLIC "-//Hibernate/Hibernate Configuration DTD 3.0//EN" "http://hibernate.sourceforge.net/hibernate-configuration-3.0.dtd">
<hibernate-configuration>
<session-factory>
<property name="hibernate.connection.provider_class">org.hibernate.service.jdbc.connections.internal.C3P0ConnectionProvider</property>
<!-- 最小連接數 -->
<property name="hibernate.c3p0.min_size">5</property>
<!-- 最大連接數 -->
<property name="hibernate.c3p0.max_size">20</property>
<!-- 獲得連接的超時時間,如果超過這個時間,會拋出異常,單位毫秒 -->
<property name="hibernate.c3p0.timeout">120</property>
<!--JDBC的標准參數,用以控制數據源內加載的PreparedStatements數量。但由於預緩存的statements 屬於單個connection而不是整個連接池。所以設置這個參數需要考慮到多方面的因素。 如果maxStatements與maxStatementsPerConnection均為0,則緩存被關閉。Default: 0-->
<property name="hibernate.c3p0.max_statements">100</property>
<!--maxStatementsPerConnection定義了連接池內單個連接所擁有的最大緩存statements數。Default: 0 -->
<property name="hibernate.c3p0.maxStatementsPerConnection">100</property>
<!-- 每隔120秒檢查連接池里的空閑連接 ,單位是秒-->
<property name="hibernate.c3p0.idle_test_period">120</property>
<!-- 當連接池耗盡,且未達到最大連接數時,一次獲取的連接數 -->
<property name="hibernate.c3p0.acquire_increment">2</property>
<property name="hibernate.c3p0.testConnectionOnCheckout">true</property>
<!--最大空閑時間,25000秒內未使用則連接被丟棄。若為0則永不丟棄。Default: 0 -->
<property name="hibernate.c3p0.maxIdleTime">25000</property>
<!--初始化時獲取10個連接,取值應在minPoolSize與maxPoolSize之間。Default: 3 -->
<property name="c3p0.initialPoolSize">10</property>
<!--連接關閉時默認將所有未提交的操作回滾。Default: false -->
<property name="autoCommitOnClose">false</property>
<!--c3p0將建一張名為c3p0_test的空表,並使用其自帶的查詢語句進行測試。如果定義了這個參數那么 屬性preferredTestQuery將被忽略。你不能在這張Test表上進行任何操作,它將只供c3p0測試 使用。Default: null-->
<property name="automaticTestTable">c3p0_test</property>
<!--定義在從數據庫獲取新連接失敗后重復嘗試的次數。Default: 30 -->
<property name="acquireRetryAttempts">30</property>
<property name="connection.driver_class">com.microsoft.sqlserver.jdbc.SQLServerDriver</property>
<property name="connection.url">jdbc:sqlserver://192.168.162.125:1433;DatabaseName=test</property>
<property name="connection.username">admin</property>
<property name="connection.password">passwd</property>
<property name="dialect">org.hibernate.dialect.SQLServerDialect</property>
<property name="show_sql">true</property>
<property name="hibernate.format_sql">true</property>
<mapping resource="com/hibernate/learn/bean/TestBean.hbm.xml" />
</session-factory>
</hibernate-configuration>
與原來的hibernate配置比較可發現在原來的基礎上增加了一些配置,如不使用C3P0連接池,則這些新加的配置去掉即可,hibernate默認使用jdbc連接池。java代碼的使用與hibernate的使用方法沒區別:
Configuration cfg = new Configuration().configure(); SessionFactory factory = cfg.buildSessionFactory(); Session session = factory.openSession();
二、spring中使用C3P0連接池
直接引入C3P0對應的jar包即可,applicationContext.xml中配置數據源的bean
<?xml version="1.0" encoding="UTF-8"?> <!-- <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd"> --> <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:context= "http://www.springframework.org/schema/context" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.5.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-2.5.xsd" default-lazy-init="true"> <bean id="person" class="com.learn.yt.bean.Person"> <property name="height" value="170"/> <constructor-arg index="0" ref="skill"/> </bean> <bean id="skill" class="com.learn.yt.bean.Skill"/> <bean id="dataSource" name="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource"> <property name="driverClass" value="com.microsoft.sqlserver.jdbc.SQLServerDriver"/> <property name="jdbcUrl" value="jdbc:sqlserver://192.168.162.25:1433;DatabaseName=test_db"/> <property name="user" value="admin"/> <property name="password" value="passwd"/> <property name="maxPoolSize" value="20"/> <property name="minPoolSize" value="5"/> <!-- 初始化建立的連接數 --> <property name="initialPoolSize" value="10"/> <!-- 最大空閑時間,120秒內未被使用的連接將被丟棄 --> <property name="maxIdleTime" value="120"/> <!-- 當連接池耗盡,且未達到最大連接數時,一次獲取的連接數 --> <property name="acquireIncrement" value="2"/> <!-- 空閑檢查時間間隔, 每隔120秒檢查連接池里的空閑連接 ,單位是秒--> <property name="idleConnectionTestPeriod" value="60"/> </bean> <bean id="dataSource2" name="dataSource2" class="com.mchange.v2.c3p0.ComboPooledDataSource"> <property name="driverClass" value="com.microsoft.sqlserver.jdbc.SQLServerDriver"/> <property name="jdbcUrl" value="jdbc:sqlserver://192.168.162.25:1433;DatabaseName=test_db2"/> <property name="user" value="admin"/> <property name="password" value="passwd"/> <property name="maxPoolSize" value="20"/> <property name="minPoolSize" value="5"/> <property name="initialPoolSize" value="10"/> <property name="maxIdleTime" value="120"/> <property name="acquireIncrement" value="2"/> <property name="idleConnectionTestPeriod" value="60"/> </bean> </beans>
其中的dataSource即為C3P0連接池的配置,可配置多個數據庫的連接,bean的id不一樣即可。代碼中的調用直接獲取bean實例,用得到的dataSource對象獲取連接即可,如:
ApplicationContext context = new ClassPathXmlApplicationContext("applicationContext.xml"); DataSource ds = (DataSource)context.getBean("dataSource"); Connection conn = null; try { conn = ds.getConnection(); ResultSet res = conn.createStatement().executeQuery("select * from test_hibernate"); while(res.next()){ System.out.println(res.getString(1)); } } catch (SQLException e) { e.printStackTrace(); }