20連接池

来源:https://www.cnblogs.com/zhengyuan/archive/2018/08/12/9461797.html
-Advertisement-
Play Games

一、c3p0連接池 1.導包(lib 下) 資料庫連接池 c3p0-0.9.5.2.jar machange-commons-java-0.2.11.jar MySQL驅動 mysql-connector-java-8.0.11.jar 2.核心方法 // 核心連接池類 ComboPooledDat ...


一、c3p0連接池

1.導包(lib 下)

    資料庫連接池
     c3p0-0.9.5.2.jar     machange-commons-java-0.2.11.jar     MySQL驅動     mysql-connector-java-8.0.11.jar

2.核心方法

                  // 核心連接池類

                  ComboPooledDataSource comboPooledDataSource = new ComboPooledDataSource();

                  // 設置四個JDBC基本連接屬性

                  comboPooledDataSource.setDriverClass("com.mysql.jdbc.Driver");

                  comboPooledDataSource.setJdbcUrl("jdbc:mysql:///day04");

                  comboPooledDataSource.setUser("root");

                  comboPooledDataSource.setPassword("123");

 

3.jdbc.properties配置文件

driverClass=com.mysql.cj.jdbc.Driver
url=jdbc:mysql://localhost:3306/mysql?serverTimezone=UTC&characterEncoding=utf-8
username=root
password=111

　　

 

4.JDBCUtils工具類

import java.io.FileReader;
import java.io.IOException;
import java.sql.*;
import java.util.Properties;

public class JDBCUtils {

    private static final String driverClass;
    private static final String url;
    private static final String username;
    private static final String password;

    static {
        Properties prop = new Properties();

        try {
            prop.load(new FileReader("jdbc.properties"));

            driverClass = prop.getProperty("driverClass");
            url = prop.getProperty("url");
            username = prop.getProperty("username");
            password = prop.getProperty("password");

            // 載入驅動
            loadDriver();

        } catch (IOException e) {
            // e.printStackTrace();
            throw new RuntimeException("配置文件載入失敗!");
        }
    }

    // 載入驅動
    public static void loadDriver() {
        try {
            Class.forName(driverClass);
        } catch (ClassNotFoundException e) {
            // e.printStackTrace();
            throw new RuntimeException("驅動載入失敗!");
        }
    }

    // 獲取連接
    public static Connection getConnection() throws SQLException {
        return DriverManager.getConnection(url, username, password);
    }

    // 釋放資源
    public static void release(Connection conn, Statement stmt, ResultSet rs) {
        if (rs != null) {
            try {
                rs.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
            rs = null;
        }

        release(conn, stmt);
    }

    public static void release(Connection conn, Statement stmt) {
        if (stmt != null) {
            try {
                stmt.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
            stmt = null;
        }

        if (conn != null) {
            try {
                conn.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
            conn = null;
        }
    }
}

 

    
// 測試類
public class JDBCTemplateTest1 {

    @Test
    public void test1() throws SQLException, PropertyVetoException {

        // 需求 : 查詢 user 表中的所有數據

        // 核心連接池類
        ComboPooledDataSource dataSource = new ComboPooledDataSource();
        // 設置四個JDBC基本連接屬性
        dataSource.setDriverClass("com.mysql.cj.jdbc.Driver");
        dataSource.setJdbcUrl("jdbc:mysql://localhost:3306/mydb?serverTimezone=UTC&characterEncoding=utf-8");
        dataSource.setUser("root");
        dataSource.setPassword("111");

        Connection conn = null;
        PreparedStatement stmt = null;
        ResultSet rs = null;

        try {
            // 1. 建立連接
            conn = dataSource.getConnection();
            // 2. 操作數據
            String sql = "select * from user;";
            stmt = conn.prepareStatement(sql);
            rs = stmt.executeQuery();
            while (rs.next()) {
                int id = rs.getInt("id");
                String username = rs.getString("username");
                String password = rs.getString("password");
                String email = rs.getString("email");
                System.out.println(id + " : " + username + " : " + password + " : " + email);
            }
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            // 3. 釋放資源
            JDBCUtils.release(conn, stmt, rs);
        }
    }
}

 

 

5.通過xml 獲取配置信息

ComboPooledDataSource comboPooledDataSource = new ComboPooledDataSource(); 會自定載入配置文件

 

常用基本連接池屬性

acquireIncrement  如果連接池中連接都被使用了，一次性增長3個新的連接

initialPoolSize  連接池中初始化連接數量預設:3

maxPoolSize      最大連接池中連接數量預設：15連接

maxIdleTime      如果連接長時間沒有時間，將被回收預設：0 連接永不過期

    minPoolSize      連接池中最小連接數量 預設：3

  
c3p0-config.xml 資料庫連接池配置文件 : 需要創建在 src 目錄下.
<?xml version="1.0" encoding="UTF-8"?>
<c3p0-config>
    <!-- 預設配置，c3p0框架預設載入這段預設配置 -->
    <default-config>
        <!-- 配置JDBC 四個基本屬性 -->
        <property name="driverClass">com.mysql.cj.jdbc.Driver</property>
        <property name="jdbcUrl">jdbc:mysql://localhost:3306/mydb?serverTimezone=UTC&characterEncoding=utf-8</property>
        <property name="user">root</property>
        <property name="password">111</property>
    </default-config>
    <!-- 可以自定義配置，為這段配置起一個名字，c3p0指定名稱載入配置 -->
    <named-config name="xxxxx">
        <property name="driverClass">com.mysql.cj.jdbc.Driver</property>
        <property name="jdbcUrl">jdbc:mysql://localhost:3306/mydb?serverTimezone=UTC&characterEncoding=utf-8</property>
        <property name="user">root</property>
        <property name="password">111</property>
    </named-config>
</c3p0-config>c

　　

　　@Test
    public void test_c3p0() throws PropertyVetoException {
        // 需求 : 查詢 user 表中的所有數據
        
        // 核心連接池類
        ComboPooledDataSource dataSource = new ComboPooledDataSource();
        
        Connection conn = null;
        PreparedStatement stmt = null;
        ResultSet rs = null;
        
        try {
            // 1. 建立連接
            conn = dataSource.getConnection();
            // 2. 操作數據
            String sql = "select * from user;";
            stmt = conn.prepareStatement(sql);
            rs = stmt.executeQuery();
            while (rs.next()) {
                int id = rs.getInt("id");
                String username = rs.getString("username");
                String password = rs.getString("password");
                String email = rs.getString("email");
                System.out.println(id + " : " + username + " : " + password + " : " + email);
            }
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            // 3. 釋放資源
            JDBCUtils.release(conn, stmt, rs);
        }
    }

 

   

優化版的JDBCUtils 中的getConnectio 使用資料庫連接池對象方式實現

  
public class JDBCUtils {
    
    // c3p0 資料庫連接池對象屬性
    private static final ComboPooledDataSource dataSource = new ComboPooledDataSource();
    
    // 獲取連接
    public static Connection getConnection() throws SQLException {
        return dataSource.getConnection();
    }
    
    // 釋放資源
    public static void release(Connection conn, Statement stmt, ResultSet rs) {
        if (rs != null) {
            try {
                rs.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
            rs = null;
        }
        release(conn, stmt);
    }
    
    public static void release(Connection conn, Statement stmt) {
        if (stmt != null) {
            try {
                stmt.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
            stmt = null;
        }
        if (conn != null) {
            try {
                conn.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
            conn = null;
        }
    }
}
    @Test
    public void test_jdbcUtils() {
        
        // 需求 : 查詢 user 表中的所有數據
        
        Connection conn = null;
        PreparedStatement stmt = null;
        ResultSet rs = null;
        
        try {
            // 1. 建立連接
            conn = JDBCUtils.getConnection();
            // 2. 操作數據
            String sql = "select * from user;";
            stmt = conn.prepareStatement(sql);
            rs = stmt.executeQuery();
            while (rs.next()) {
                int id = rs.getInt("id");
                String username = rs.getString("username");
                String password = rs.getString("password");
                String email = rs.getString("email");
                System.out.println(id + " : " + username + " : " + password + " : " + email);
            }
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            // 3. 釋放資源
            JDBCUtils.release(conn, stmt, rs);
        }
    }

 


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • javascript 對象的方式解析url地址參數
    看到一個知識點，比如說給一個 url參數，讓其解析裡面的各個參數，以前我都是通過字元串分割來實現的。但是通過這樣的方式比較麻煩，而且操作字元串容易出錯。今天看到了一個更有效更快速的方式，就是通過對象來解析的。 比如我們的url是：https://www.baidu.com:8080/aaa/1.ht ...
  • Vue父子組件生命周期執行順序及鉤子函數的個人理解
    先附一張官網上的vue實例的生命周期圖，每個Vue實例在被創建的時候都需要經過一系列的初始化過程，例如需要設置數據監聽，編譯模板，將實例掛載到DOM併在數據變化時更新DOM等。同時在這個過程中也會運行一些叫做生命周期鉤子的函數(回調函數)，這給了用戶在不同階段添加自己代碼的機會。 1、vue的生命周 ...
  • Vue 動態載入組件
    為什麼要動態載入呢？而不是一次性載入呢？ 一次性？你能保證你拿的內容不多，那從性能方面說還是OK的。否則，就該什麼時候用，就什麼時候取。 得出這想法，源於前幾天上班趕產品的故事： A組件是父親，B組件是A組件的孩子。剛剛，我在A組件里直接載入B組件。 編譯居然用了將近一分半鐘，我都還沒加其他C孩子， ...
  • Java_設計模式之享元模式
    1、關於享元模式 享元模式有點類似於單例模式，都是只生成一個對象被共用使用。享元模式主要目的就是讓多個對象實現共用，減少不會要額記憶體消耗，將多個對同一對象的訪問集中起來，不必為每個訪問者創建一個單獨的對象，以此來降低記憶體的消耗。 2、享元模式結構圖 因為享元模式結構比較複雜，一般結合工廠模式一起使用 ...
  • Python 高階函數 -- filter
    詳細內容請參考廖雪峰官網，此處只是一些摘抄，心得與練習的coding。 Python內建的filter()函數用於過濾序列。 和map()類似(可參考 Python 高階函數 -- map/reduce)，filter()也接收一個函數和一個序列。和map()不同的是，filter()把傳入的函數依 ...
  • Leetcode解題 7. Reverse Integer 反轉整數
    沒看清要求，提交錯誤一次。 要求是 "如果反轉後的整數溢出，則返回 0"。 ...
  • 【leetcode 簡單】第十八題 刪除排序鏈表中的重覆元素
    給定一個排序鏈表，刪除所有重覆的元素，使得每個元素只出現一次。 示例 1: 輸入: 1->1->2 輸出: 1->2 示例 2: 輸入: 1->1->2->3->3 輸出: 1->2->3 /** * Definition for singly-linked list. * struct ListN ...
  • 【leetcode 簡單】第十八題 爬樓梯
    假設你正在爬樓梯。需要 n 階你才能到達樓頂。 每次你可以爬 1 或 2 個臺階。你有多少種不同的方法可以爬到樓頂呢？ 註意：給定 n 是一個正整數。 示例 1： 輸入： 2 輸出： 2 解釋： 有兩種方法可以爬到樓頂。 1. 1 階 + 1 階 2. 2 階 示例 2： 輸入： 3 輸出： 3 解 ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發（一）：使用.NET MAUI開發第一個安卓APP
    移動開發（一）：使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說，近來想嘗試開發一款安卓APP，考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP，畢竟是使用Visual Studio開發工具，使用起來也比較的順手，結合微軟官方的教程進行了安卓 ...
  • wpf ToggleButton選中效果和一個登錄界面
    前言 QuestPDF 是一個開源 .NET 庫，用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫，它徹底改變了我們生成 PDF 文檔的方 ...
  • 彈幕樹洞項目功能新增篇
    項目地址 項目後端地址： https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址： ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址： http://tree ...
  • 第27篇 sqlserver2022詳細安裝步驟
    話不多說，直接開乾 一.下載 1.官方鏈接下載： https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe，運行開始下載SQL server； 二. ...
  • .NET 開源高性能 MQTT 類庫
    前言 隨著物聯網（IoT）技術的迅猛發展，MQTT（消息隊列遙測傳輸）協議憑藉其輕量級和高效性，已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫，為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog文檔翻譯系列（六） - 可用的接收器、增強器、格式化輸出
    Serilog支持多種接收器用於日誌存儲，增強器用於添加屬性，LogContext管理動態屬性，支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項，適用於不同需求。 ...
  • 警惕 Visual Studio 屬性求值副作用導致邏輯不符合預期
    目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據，爬取信息時需要模擬瀏覽器行為，否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下： 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • [使用目前最新版]HybridCLR6.9.0+YooAsset2.2.4實現純C# Unity熱更新方案 (一)
    1.前言 什麼是熱更新 游戲或者軟體更新時，無需重新下載客戶端進行安裝，而是在應用程式啟動的情況下，在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR，Xlua，ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles，Addressable， ...
  • 在 ASP.NET Core Web API 中使用操作篩選器統一處理通用操作
    本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺，其實像阿裡雲，騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後，它會送 ...
  • 第28篇 如何.net中實現高效可靠數據同步api
    通過以下方式可以高效，並保證數據同步的可靠性 1.API設計 使用RESTful設計，確保API端點明確，並使用適當的HTTP方法（如POST用於創建，PUT用於更新）。 設計清晰的請求和響應模型，以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證，確保接收到的數據符合預期格 ...
所有分類