2. 程式人生 > >javaWeb學習記錄：c3p0資料庫連線池;DBUtils工具

javaWeb學習記錄：c3p0資料庫連線池;DBUtils工具

阿新 • • 發佈：2019-01-06

1. c3p0資料庫連線池

讓我想起了星球大戰裡的C-3PO，哈哈。

1.1 資料庫連線池的概念

用池來管理Connection，這可以重複使用Connection。有了池，所以我們就不用自己來建立Connection，而是通過池來獲取Connection物件。當使用完Connection後，呼叫Connection的close()方法也不會真的關閉Connection，而是把Connection“歸還”給池。池就可以再利用這個Connection物件了。

1.2 c3p0資料庫連線池例子

需要的jar包：

  • c3p0-0.9.2-pre1.jar
  • mchange-commons-0.2.jar
  • mysql-connector-java-5.1.37-bin.jar

程式碼如下：

ComboPooledDataSource ds = new ComboPooledDataSource();
//基本配置
ds.setJdbcUrl("jdbc:mysql://localhost:3306/test");
ds.setUser("root");
ds.setPassword("dongjiong");
ds.setDriverClass("com.mysql.jdbc.Driver");

//每次的增量
ds.setAcquireIncrement(5);
//初始化連線數
ds.setInitialPoolSize
 
(30);
//最少連線數
ds.setMinPoolSize(2);
//最多連線數
ds.setMaxPoolSize(50);

//得到聯結器
Connection con = ds.getConnection();
System.out.println(con);
//歸還給池
con.close();

c3p0也可以指定配置檔案，而且配置檔案可以是properties，也可以是xml的。當然xml的高階一些了。但是c3p0的配置檔名必須為c3p0-config.xml，並且必須放在類路徑下。
配置檔案要求：

  • 檔名稱：必須叫c3p0-config.xml
  • 檔案位置：必須在src下


    c3p0-config.xml檔案如下：
<?xml version="1.0" encoding="UTF-8"?>
<c3p0-config>
    <!-- 這是預設配置資訊 -->
    <default-config> 
        <!-- 連線四大引數配置 -->
        <property name="jdbcUrl">jdbc:mysql://localhost:3306/test</property>
        <property name="driverClass">com.mysql.jdbc.Driver</property>
        <property name="user">root</property>
        <property name="password">dongjiong</property>
        <!-- 池引數配置 -->
        <property name="acquireIncrement">3</property>
        <property name="initialPoolSize">10</property>
        <property name="minPoolSize">2</property>
        <property name="maxPoolSize">10</property>
    </default-config>
</c3p0-config>

xml檔案配置好之後，程式碼裡就不用再配置了，直接像下面的程式碼那樣呼叫就行：

ComboPooledDataSource ds = new ComboPooledDataSource();
//得到聯結器
Connection con = ds.getConnection();
System.out.println(con);
//歸還給池
con.close();

c3p0的配置檔案中可以配置多個連線資訊，可以給每個配置起個名字，這樣可以方便的通過配置名稱來切換配置資訊。上面xml檔案中預設配置為mysql的配置，也可以給oracle資料庫配置一下連線資訊，起名為oracle-config，使用時把名字作為引數傳給程式。
xml檔案內加入下面的資訊：

<!-- 專門為oracle提供的配置資訊 -->
<named-config name="oracle-config"> 
    <property>...</property>
    ...
    <property>...</property>
</named-config>

程式碼裡使用時：

ComboPooledDataSource ds = new ComboPooledDataSource("oracle-config");
//得到聯結器
Connection con = ds.getConnection();
System.out.println(con);
//歸還給池
con.close();

2. jdbcUtils類

之前每次用JDBC時都要寫那些基本配置的程式碼，所以就把這些程式碼寫到了jdbcUtils類裡的一個靜態方法裡，返回一個Connection，然後直接在其他類裡呼叫這個方法就可以了，減少了重複程式碼的書寫，提高效率。這個類的程式碼如下：

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;

public class jdbcUtils {
    private static String url =  "jdbc:mysql://localhost:3306/test";        
    private static String username = "root";
    private static String password = "dongjiong";

    static {
        try{
            Class.forName("com.mysql.jdbc.Driver");
        }catch (ClassNotFoundException e) {
            throw new RuntimeException(e);
        }
    }

    public static Connection getConnection() throws SQLException{
        return DriverManager.getConnection(url, username, password);
    }
}

現在使用了c3p0資料庫連線池，這個類裡的程式碼需要改一下：

import java.sql.Connection;
import java.sql.SQLException;
import com.mchange.v2.c3p0.ComboPooledDataSource;
import javax.sql.DataSource;

public class jdbcUtils {
    // 配置檔案的預設配置！要求你必須給出c3p0-config.xml！！！
    private static ComboPooledDataSource dataSource = new ComboPooledDataSource();

    /**
     * 使用連線池返回一個連線物件
     * @return
     * @throws SQLException
     */
    public static Connection getConnection() throws SQLException{
        return dataSource.getConnection();
    }

    /**
     * 返回連線池物件！
     * @return
     */
    public static DataSource getDataSource() {
        return dataSource;
    }
}

3. DBUtils

Commons DbUtils是Apache組織提供的一個對JDBC進行簡單封裝的開源工具類庫，使用它能夠簡化JDBC應用程式的開發，同時也不會影響程式的效能。其最核心的特性是結果集的封裝，可以直接將查詢出來的結果集封裝成JavaBean，這就為我們做了最枯燥乏味、最容易出錯的一大部分工作。

使用DBUtils需要注意的一些問題：

  1. DBUtils對結果集自動封裝為JavaBean是有著苛刻要求的：必須滿足JavaBean的規範，其次Bean的getter與setter方法的名字與結果集的列名（資料庫表的列名）一一對應，而不要求JavaBean的私有成員與表結果集列名一一對應。比如：
    person表中有個欄位叫：address，那麼對應的JavaBean的Person類中必須有getAddress和setAddress兩個方法，而Person類中可以將address屬性命名為add，這是沒問題的。
  2. 對於JavaBean的成員型別定義，有一條原則那就是：儘可能使用包裝型別，而不要使用基本型別。
    //錯誤
    int a1 = (Integer) null;
    boolean x1 = (Boolean)null;
    //正確
    Integer a2 = (Integer) null;
    Boolean x2 = (Boolean)null;

實際上就是為了保證在查詢結果為null的時候，也不會因為給基本型別賦null值而發生錯誤。

DBUtils主要類:QueryRunner

QueryRunner類下面有幾個經常使用的方法：

  • update()：執行insert、update、delete操作
  • query()：執行select語句
  • batch()：執行批處理

假設有一個student表，它有三列：id,name,age。對它進行一些操作。

update()：執行insert、update、delete操作

@Test
public void insert() throws Exception{
    QueryRunner qr = new QueryRunner(jdbcUtils.getDataSource());
    String sql = "INSERT INTO student VALUES(?,?,?)";
    Object[] params = {3,"jinjin",22};
    qr.update(sql, params);
}

@Test
public void update() throws Exception{
    QueryRunner qr = new QueryRunner(jdbcUtils.getDataSource());
    String sql = "UPDATE student SET name=? WHERE id=?";
    Object[] params = {"yaoyao",3};
    qr.update(sql, params);
}

@Test
public void delete() throws Exception{
    QueryRunner qr = new QueryRunner(jdbcUtils.getDataSource());
    String sql = "DELETE FROM student WHERE id=?";
    Object[] params = {3};
    qr.update(sql, params);
}

query()：執行select語句

@Test
public void select() throws SQLException{
    QueryRunner qr = new QueryRunner(jdbcUtils.getDataSource());
    String sql = "SELECT * FROM student WHERE id=?";
    Object[] params = {2};

    Student student = qr.query(sql,new BeanHandler<Student>(Student.class),params);
    System.out.println(student);
}

我們知道在執行select語句之後得到的是ResultSet，然後我們還需要對ResultSet進行轉換，得到最終我們想要的資料。你可能希望把ResultSet的資料放到一個List中，也可能想把資料放到一個Map中，或是一個Bean中。DBUtils提供了一個介面ResultSetHandler，它就是用來ResultSet轉換成目標型別的工具。DBUtils提供了很多個ResultSetHandler介面的實現。
如下：

  1. MapHandler：單行處理器！把結果集轉換成Map<String,Object>，其中列名為鍵！
  2. MapListHandler：多行處理器！把結果集轉換成List<Map<String,Object>>；
  3. BeanHandler：單行處理器！把結果集轉換成Bean，該處理器需要Class引數，即Bean的型別；
  4. BeanListHandler：多行處理器！把結果集轉換成List；
  5. ColumnListHandler：多行單列處理器！把結果集轉換成List<Object>，使用ColumnListHandler時需要指定某一列的名稱或編號,例如：new ColumListHandler(“name”) 表示把name列的資料放到List中。
  6. ScalarHandler：單行單列處理器！把結果集轉換成Object。一般用於聚集查詢,例如select count(*) from tab_student。
  7. ArrayHandler：把結果集中的第一行資料轉成物件陣列。
  8. ArrayListHandler：把結果集中的每一行資料都轉成一個物件陣列，再存放到List中。
  9. KeyedHandler：將結果集中的每一行資料都封裝到一個Map裡，然後再根據指定的key把每個Map再存放到一個Map裡。

舉幾個例子吧：

MapHandler：

@Test
public void select() throws SQLException{
    QueryRunner qr = new QueryRunner(jdbcUtils.getDataSource());
    String sql = "SELECT * FROM student WHERE id=?";
    Object[] params = {2};

    Map<String, Object> student = qr.query(sql,new MapHandler(),params);
    System.out.println(student);
}

MapListHandler

@Test
public void select() throws SQLException{
    QueryRunner qr = new QueryRunner(jdbcUtils.getDataSource());
    String sql = "SELECT * FROM student";

    List<Map<String, Object>> stuList = qr.query(sql,new MapListHandler());
    System.out.println(stuList);
}

BeanHandler

@Test
public void select() throws SQLException{
    QueryRunner qr = new QueryRunner(jdbcUtils.getDataSource());
    String sql = "SELECT * FROM student WHERE id=?";
    Object[] params = {2};

    Student student = qr.query(sql,new BeanHandler<Student>(Student.class),params);
    System.out.println(student);
}

BeanListHandler

@Test
public void select() throws SQLException{
    QueryRunner qr = new QueryRunner(jdbcUtils.getDataSource());
    String sql = "SELECT * FROM student";

    List<Student> stuList = qr.query(sql,new BeanListHandler<Student>(Student.class));
    System.out.println(stuList);
}

ScalarHandler

@Test
public void select() throws SQLException{
    QueryRunner qr = new QueryRunner(jdbcUtils.getDataSource());
    String sql = "SELECT COUNT(*) FROM student";

    Number count = (Number) qr.query(sql,new ScalarHandler());//必須這樣寫,然後再轉換
    int num = count.intValue();

    System.out.println(num);
}

對聚合函式的查詢結果，有的驅動返回的是Long，有的返回的是BigInteger，所以這裡我們把它轉換成Number，Number是Long和BigInteger的父類！然後我們再呼叫Number的intValue()或longValue()方法轉成我們需要的型別。

ColumnListHandler

@Test
public void select() throws SQLException{
    QueryRunner qr = new QueryRunner(jdbcUtils.getDataSource());
    String sql = "SELECT name FROM student";

    List<Object> names = qr.query(sql, new ColumnListHandler());

    System.out.println(names);
}

batch()：執行批處理

我們更新一行記錄時需要指定一個Object[]陣列為引數，如果是批處理，處理多行資料，那麼就要指定一個二維陣列：Object[][]為引數。其中每個Object[]對應一行記錄。

@Test
public void insertBath() throws SQLException{
    QueryRunner qr = new QueryRunner(jdbcUtils.getDataSource());
    String sql = "INSERT INTO student VALUES(?,?,?)";

    Object[][] params = new Object[10][]; //表示 要插入10行記錄
    for(int i = 0; i < params.length; i++) {
        params[i] = new Object[]{30 + i,"name" + i,10+i};
    }

    qr.batch (sql, params);
}

相關推薦

javaWeb學習記錄：c3p0資料庫連線池;DBUtils工具

1. c3p0資料庫連線池 讓我想起了星球大戰裡的C-3PO，哈哈。 1.1 資料庫連線池的概念 用池來管理Connection，這可以重複使用Connection。有了池，所以我們就不用自己來建立Connection，而是通過池來獲取Connecti

spring jdbc --注：c3p0資料庫連線池或druid連線池使用配置整理

是Maven配置檔案：pom.xml的程式碼內容： <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:sch

Mysql學習--07.c3p0資料庫連線池

學習目標 C3p0資料庫連線池 一、c3p0資料庫連線池          1、概述： c3p0是一個開源的JDBC連線池、它實現了資料來源和JNDI（Java Naming and Directory Interface,Java命名和目錄介面）繫結、支援jdbc3

tomcat 配置 quercus記錄：php使用連線池訪問資料庫

JNDI (Java Naming and Directory Interface)是SUN公司提供的一種標準的Java命名系統介面，JNDI提供統一的客戶端API，通過不同的訪問提供者介面JNDI SPI的實現，由管理者將JNDI API對映為特定的命名服務和目錄系統，使得Java應用程式可以和這些命

JavaEE基礎(06)：Servlet整合C3P0資料庫連線池

本文原始碼：GitHub·點這裡 || GitEE·點這裡 一、C3P0連線池 1、C3P0簡介 C3P0是一個開源的JDBC連線池，應用程式根據C3P0配置來初始化資料庫連線，可以自動回收空閒連線的功能。 2、核心依賴 <dependency> <groupId>mysq

ThreadLocal解決事務執行緒安全問題(c3p0資料庫連線池工具類)

ThreadLocal底層是Map集合，它的key是當前執行緒，value由自己設定，可以繫結Connection或其他物件等，保證本次同一執行緒使用同一Connection。 ThreadLocal類提供幾個方法： get/set/remove 以下是ThreadLocal搭配c3p

javaweb 事務&資料庫連線池&DBUtils

事務&資料庫連線池&DBUtils 事務 Transaction 其實指的一組操作，裡面包含許多個單一的邏輯。只要有一個邏輯沒有執行成功，那麼都算失敗。 所有的資料都回歸到最初的狀態(回滾) 為什麼要有事務? 為了確保邏輯的成功。

c3p0 資料庫連線池配置 詳細總結

前言 關於 c3p0 一般有這麼兩種配置，一種是通過 set 方法進行配置，另一種是通過在同 src 目錄下的 c3p0-conflg.xml 檔案或者 c3p0.properties 檔案進行相關的配置。 一、c3p0 通過 set 方法進行配置 原始碼： priva

maven專案管理器，Junit測試單元以及C3P0資料庫連線池的會用總結

最近剛好連續學習了maven專案管理器，Junit測試單元以及C3P0資料庫連線池的使用，現將學習工程中遇到的問題與注意點總結如下： 1.maven專案管理器 maven是一種很好用的專案管理器，在開發工具中建立一個maven專案，它會自動生成各種目錄，有專門存放java

c3p0資料庫連線池死鎖解決

專案進行壓力測試的時候，執行大概1小時候，後臺丟擲以下異常： Java程式碼   Nov 9, 2012 1:41:59 AM com.mchange.v2.async.ThreadPoolAsynchronousRunner$DeadlockDetector 

c3p0資料庫連線池如何正確的關閉資源（“too many connections”的解決辦法）

一.問題分析 關於c3p0資料庫連線池的資源的關閉是一個很重要的問題，但是資源的關閉不僅僅是隻呼叫close()方法，將連結放入池中那麼簡單，如果你不考慮資料來源DataSource的關閉，那麼你的Demo將在很少的資料庫互動之後報出“too many connection

Flask（4）：wtforms元件 & 資料庫連線池 DBUtils

wtforms 元件的作用： 　　--- 生成 HTML 標籤 　　--- form 表單驗證 示例程式碼： app.py from flask import Flask, render_template, request from wtforms import Form from wtform

javaWeb學習記錄：檔案上傳與下載

在web開發中經常需要上傳或下載檔案，這篇文章記錄一下檔案上傳和下載需要注意的知識點。 檔案上傳 上傳對form表單的要求 method方法必須是POST，不能是GET 新加一個屬性enctype，值為”multipart/form-data”

javaWeb學習記錄：BaseServlet 與 service事務

本文根據崔希凡老師的講課視訊和筆記整理而成 1. BaseServlet 分析 通常，寫一個專案可能會出現N多個Servlet，而且一般一個Servlet只有一個方法（doGet或doPost），如果專案大一些，那麼Servlet的數量就會很驚人。為了

c3p0資料庫連線池死鎖問題和mysql重連，連線丟失

c3p0引數解釋 #最常用配置#initialPoolSize：連線池初始化時建立的連線數,default : 3，取值應在minPoolSize與maxPoolSize之間 c3p0.initialPoolSize=10#minPoolSize：連線池保持的最小連線數,d

spring+mybatis+c3p0資料庫連線池或druid連線池使用配置整理

系統性能優化的時候，或者說在進行程式碼開發的時候，多數人應該都知道一個很基本的原則，那就是保證功能正常良好的情況下，要儘量減少對資料庫的操作。  據我所知，原因大概有這樣兩個：  一個是，一般情況下系統伺服器和資料庫伺服器應該是不在同一硬體上，這時候對資料庫的連線

使用c3p0資料庫連線池時出現com.mchange.v2.resourcepool.TimeoutException

有一個線上環境使用的是c3p0資料庫，為外部提供介面服務。最近訪問壓力增大後臺tomcat的日誌裡面頻繁出現 com.mchange.v2.resourcepool.TimeoutException: A client timed out while waiting t

jsp,servlet 連線c3p0資料庫連線池是出現的問題

九月 02, 2015 10:17:48 下午 com.mchange.v2.log.MLog <clinit> INFO: MLog clients using java 1.4+ standard logging. 九月 02, 2015 10:17:48

用Hibernate儲存物件出現c3p0資料庫連線池死鎖問題的可能原因

我在執行以下程式碼時遇到了問題： Session session = getSession(); Transaction tx = session.beginTransaction(); try {

JDBC整合c3p0資料庫連線池 解決Too many connections錯誤

前段時間，接手一個專案使用的是原始的jdbc作為資料庫的訪問，釋出到伺服器上在運行了一段時間之後總是會出現無法訪問的情況，登入到伺服器，檢視tomcat日誌發現總是報如下的錯誤。 Caused by: com.mysql.jdbc.exceptions.jdbc4.