一、什麼是C3P0 我們開始實現了一個自定義的連接池,那麼C3P0連接池和我們自定義那個就差不多了,只是它是一個開源的,比我們自己實現的要強大很多的連接池。下麵為百科上的定義: C3P0是一個開源的JDBC連接池,它實現了數據源和JNDI綁定,支持JDBC3規範和JDBC2的標準擴展。目前使用它的開 ...
一、什麼是C3P0
我們開始實現了一個自定義的連接池,那麼C3P0連接池和我們自定義那個就差不多了,只是它是一個開源的,比我們自己實現的要強大很多的連接池。下麵為百科上的定義:
C3P0是一個開源的JDBC連接池,它實現了數據源和JNDI綁定,支持JDBC3規範和JDBC2的標準擴展。目前使用它的開源項目有Hibernate,Spring等。
二、如何使用C3P0
首先我們先要引入C3P0的jar包,(當然連接mysql是少不了mysql的驅動包的),我這裡因為使用的Maven,就直接引入到pom文件中了
<dependency> <groupId>c3p0</groupId> <artifactId>c3p0</artifactId> <version>0.9.1.2</version> </dependency>
然後我們使用的時候就直接new出ComboPooledDataSource對象就可以了 ,然後去設置它的一些需要連接資料庫的參數,如下:
ComboPooledDataSource dataSource = new ComboPooledDataSource(); dataSource.setDriverClass("com.mysql.jdbc.Driver"); dataSource.setJdbcUrl("jdbc:mysql://localhost:3306/test?useUnicode=true&characterEncoding=utf8"); dataSource.setUser("root"); dataSource.setPassword("root");
那麼,一個最簡單的C3P0就可以使用了,我們就可以像JDBC那樣去獲得連接,使用連接了,完整測試代碼如下:
public static void main( String[] args ) throws SQLException, PropertyVetoException { ComboPooledDataSource dataSource = new ComboPooledDataSource(); dataSource.setDriverClass("com.mysql.jdbc.Driver"); dataSource.setJdbcUrl("jdbc:mysql://localhost:3306/test?useUnicode=true&characterEncoding=utf8"); dataSource.setUser("root"); dataSource.setPassword("root"); Connection conn = dataSource.getConnection(); String sql = "select * from user where u_id = ?"; PreparedStatement ps = null; ResultSet rs = null; try { ps = conn.prepareStatement(sql); ps.setInt(1, 1); rs = ps.executeQuery(); while (rs.next()) { System.out.println("id="+rs.getInt(1)); System.out.println("username="+rs.getString(2)); System.out.println("password="+rs.getString(3)); } } catch (SQLException e) { e.printStackTrace(); } finally { JDBCUtils_V3.close(conn, ps, rs);//這是本人自己封裝的一個關閉資源的方法,非C3P0所提供 } }
OK,一個簡單的C3P0使用測試案例就完成了,但是,為了避免硬編碼,C3P0提供對配置文件的引入,支持xml,和properties文件,我這裡就使用xml文件,properties不做介紹
文件如下:
<?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/test</property> <property name="user">root</property> <property name="password">root</property> <!-- 初始化連接池的連接數 --> <property name="initialPoolSize">5</property> <!-- 連接池中最大的連接數 --> <property name="maxPoolSize">20</property> </default-config> <!-- 當需要使用這裡的配置時只需要在創建對象的時候傳入這個的name值,即oracle --> <named-config name="oracle"> <property name="driverClass">com.mysql.jdbc.Driver</property> <property name="jdbcUrl">jdbc:mysql:///web_07</property> <property name="user">root</property> <property name="password">123</property> </named-config> </c3p0-config>
其中註釋都已經很清楚,值得註意的是,C3P0預設配置文件的路徑是在classpath下,且文件名必須為c3p0-config.xml;當然,C3P0的配置不會這麼簡單,還有很多配置項是可以去配置優化的,詳細可以去官網查看文檔介紹,會更好。
配置文件方式的測試代碼如下:
public static void main( String[] args ) throws SQLException, PropertyVetoException { //因為有配置文件存在且在類路徑下,所以創建此對象的時候就會去載入預設路徑下名為c3p0-config.xml的配置文件 ComboPooledDataSource dataSource = new ComboPooledDataSource(); // dataSource.setDriverClass("com.mysql.jdbc.Driver"); // dataSource.setJdbcUrl("jdbc:mysql://localhost:3306/test?useUnicode=true&characterEncoding=utf8"); // dataSource.setUser("root"); // dataSource.setPassword("root"); Connection conn = dataSource.getConnection(); String sql = "select * from user where u_id = ?"; PreparedStatement ps = null; ResultSet rs = null; try { ps = conn.prepareStatement(sql); ps.setInt(1, 1); rs = ps.executeQuery(); while (rs.next()) { System.out.println("id="+rs.getInt(1)); System.out.println("username="+rs.getString(2)); System.out.println("password="+rs.getString(3)); } } catch (SQLException e) { e.printStackTrace(); } finally { JDBCUtils_V3.close(conn, ps, rs);//這是本人自己封裝的一個關閉資源的方法,非C3P0所提供 } }
OK,c3p0的使用就這樣了 。