JDBC之C3P0數(shù)據(jù)庫(kù)連接池,供大家參考,具體內(nèi)容如下
創(chuàng)新互聯(lián)專注于廣昌企業(yè)網(wǎng)站建設(shè),自適應(yīng)網(wǎng)站建設(shè),商城網(wǎng)站建設(shè)。廣昌網(wǎng)站建設(shè)公司,為廣昌等地區(qū)提供建站服務(wù)。全流程按需求定制制作,專業(yè)設(shè)計(jì),全程項(xiàng)目跟蹤,創(chuàng)新互聯(lián)專業(yè)和態(tài)度為您提供的服務(wù)
1 首先在src中創(chuàng)建c3p0-config.xml 配置文件,文件中內(nèi)容如下(首先下載C3P0.jar工具包 并放入項(xiàng)目環(huán)境變量中)
<?xml version="1.0" encoding="UTF-8"?>com.mysql.jdbc.Driver jdbc:mysql:localhost:3306/jdbc_01 root root 5 10 5 100 2 5
2 創(chuàng)建一個(gè)工具類用于利用C3P0數(shù)據(jù)庫(kù)連接池獲得數(shù)據(jù)庫(kù)連接 工具類如下
package cn.qhy.jdbc; import java.io.IOException; import java.lang.reflect.Field; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.ResultSetMetaData; import java.sql.SQLException; import java.sql.Statement; import java.util.HashMap; import java.util.Map; import java.util.Map.Entry; import javax.sql.DataSource; import com.mchange.v2.c3p0.ComboPooledDataSource; public class MyDBUtils { private static DataSource dataSource; static {// 靜態(tài)代碼塊,只執(zhí)行一次 dataSource = new ComboPooledDataSource("MySQL"); } /** * * @return * @throws SQLException */ public static Connection getConnection() throws SQLException { return dataSource.getConnection(); } /** * 通用的用來(lái)關(guān)閉數(shù)據(jù)有關(guān)的所有的資源的操作 */ public static void close(Connection conn, Statement sta, ResultSet re) { if (re != null) try { re.close(); } catch (SQLException e) { e.printStackTrace(); } if (sta != null) try { sta.close(); } catch (SQLException e) { e.printStackTrace(); } if (conn != null) try { conn.close(); } catch (SQLException e) { e.printStackTrace(); } } }
3 創(chuàng)建測(cè)試類,測(cè)試C3P0是否連接數(shù)據(jù)庫(kù)(利用JUnit單元測(cè)試)
package cn.qhy.test; import java.beans.PropertyVetoException; import java.sql.Connection; import java.sql.SQLException; import org.junit.jupiter.api.Test; import com.mchange.v2.c3p0.ComboPooledDataSource; import cn.qhy.jdbc.MyDBUtils; public class C3P0Test { /** * @throws SQLException * */ @Test public void c3p0xmlTest() throws SQLException { Connection conn = MyDBUtils.getConnection(); System.out.println(conn); conn.close(); } }
結(jié)果如下
以上就是本文的全部?jī)?nèi)容,希望對(duì)大家的學(xué)習(xí)有所幫助,也希望大家多多支持創(chuàng)新互聯(lián)。