Java的JDBC

• 2022 年 1 月 12 日
• 筆記
• MySQL, MySQL資料庫

第一個JDBC程式

創建測試資料庫

CREATE DATABASE jdbcStudy CHARACTER SET utf8 COLLATE utf8_general_ci;

USE jdbcStudy;

CREATE TABLE users(
   id INT PRIMARY KEY,
   NAME VARCHAR(40),
   PASSWORD VARCHAR(40),
   email VARCHAR(60),
   birthday DATE
)

INSERT INTO users(id,NAME,PASSWORD,email,birthday)
VALUES(1,'zhangsan','123456','[email protected]','1980-12-04'),
(2,'lisi','123456','[email protected]','1981-12-04'),
(3,'wangwu','123456','[email protected]','1979-12-04');

1. 創建一個普通項目
2. 導入資料庫驅動
3. 編寫測試程式碼

import java.sql.*;

//我的第一個JDBC程式
public class JdbcFirstDemo {
    public static void main(String[] args) throws ClassNotFoundException, SQLException {
        //1. 載入驅動
        Class.forName("com.mysql.jdbc.Driver"); //固定寫法，載入驅動
        //2. 用戶資訊和url
        String url = "jdbc:mysql://localhost:3306/jdbcstudy?useUnicode=true&characterEncoding=utf8&useSSL=true";
        String username = "root";
        String password = "123456";
        //3. 連接成功，返回資料庫對象
        Connection connection = DriverManager.getConnection(url, username, password);

        //4. 執行SQL的對象
        Statement statement = connection.createStatement();

        //5. 執行SQL的對象 去 執行SQL，可能存在結果，查看返回結果
        String sql = "SELECT * FROM users";
        ResultSet resultSet = statement.executeQuery(sql); //返回的結果集，結果集中封裝了我們全部的查詢出來的結果

        while (resultSet.next()){
            System.out.println("id="+resultSet.getObject("id"));
            System.out.println("name="+resultSet.getObject("NAME"));
            System.out.println("pwd="+resultSet.getObject("PASSWORD"));
            System.out.println("email="+resultSet.getObject("email"));
            System.out.println("birth="+resultSet.getObject("birthday"));
            System.out.println("=================================");
        }
        //6. 釋放連接
        resultSet.close();
        statement.close();
        connection.close();
    }
}

步驟總結：

1. 載入驅動
2. 連接資料庫DriverManager.getConnection
3. 獲得執行sql的對象 Statement
4. 獲得返回的結果集
5. 釋放連接

DriverManager

//1. 載入驅動
//DriverManager.registerDriver(new com.mysql.jdbc.Driver());
Class.forName("com.mysql.jdbc.Driver"); //固定寫法，載入驅動  
Connection connection = DriverManager.getConnection(url, username, password);

// connection 代表資料庫
// 資料庫設置自動提交
// 事務提交
// 事務回滾
connection.rollback();
connection.commit();
connection.setAutoCommit();

URL

String url = "jdbc:mysql://localhost:3306/jdbcstudy?useUnicode=true&characterEncoding=utf8&useSSL=true";

// mysql  -- 3306
//jdbc:mysql://主機地址:埠號/資料庫名?參數1&參數2&參數3

// oracle -- 1521
//jdbc:oracle:thin:@localhost:1521:sid

Statement 執行SQL的對象 PrepareStatement 執行SQL的對象

String sql = "SELECT * FROM users"; //編寫SQL

statement.executeQuery(); //查詢操作返回 ResultSet
statement.execute(); // 執行任何SQL
statement.executeUpdate(); // 更新、插入、刪除。都是用這個，返回一個受影響的行數

ResultSet 查詢的結果集：封裝了所有的查詢結果

獲得指定的數據類型

resultSet.getObject(); // 在不知道列類型的情況下使用
// 如果知道列的類型就使用指定的類型
resultSet.getString();
resultSet.getInt();
resultSet.getFloat();
resultSet.getDouble();
resultSet.getDate();
....

遍歷，指針

resultSet.beforeFirst(); // 移動到最前面
resultSet.afterLast(); // 移動到最後面
resultSet.next(); // 移動到下一個數據
resultSet.previous(); // 移動到前一行
resultSet.absolute(row); // 移動到指定行

釋放資源

//6. 釋放資源
resultSet.close();
statement.close();
connection.close(); // 耗資源，用完關掉！

statement對象

JDBC中的statement對象用於向資料庫發送SQL語句，像完成對資料庫的增刪改查，只需要通過這個對象向資料庫發送增刪改查語句即可。

statement對象的executeUpdate方法，用於向資料庫發送增、刪、改的sql語句，executeUpdate執行完後，將會返回一個整數（即增刪改語句導致了資料庫幾行數據發生了變化）。

Statement.executeQuery方法用於向資料庫發送查詢語句，executeQuery方法返回代表查詢結果的ResultSet對象。

CRUD操作-create

使用executeUpdate(String sql)方法完成數據添加操作，示例操作：

Statement st = conn.createStatement();
String sql = "insert into user(...) values(...)";
int num = st.executeUpdate(sql);
if(num>0){
    System.out.println("插入成功！")
}

CRUD操作-delete

使用executeUpdate(String sql)方法完成數據刪除操作，示例操作：

Statement st = conn.createStatement();
String sql = "delete from user where id=1";
int num = st.executeUpdate(sql);
if(num>0){
    System.out.println("刪除成功！")
}

CRUD操作-update

使用executeUpdate(String sql)方法完成數據修改操作，示例操作：

Statement st = conn.createStatement();
String sql = "update user set name='' where name=''";
int num = st.executeUpdate(sql);
if(num>0){
    System.out.println("修改成功！")
}

CRUD操作-read

使用executeQuery(String sql)方法完成數據查詢操作，示例操作：

Statement st = conn.createStatement();
String sql = "select * from user where id=1";
ResultSet rs = st.executeQuery(sql);
while(rs.next()){
    //根據獲取列的數據類型，分別調用rs的相應方法映射到java對象中
}

程式碼實現

1、提取工具類

driver=com.mysql.jdbc.Driver
url=jdbc:mysql://localhost:3306/jdbcstudy?useUnicode=true&characterEncoding=utf8&useSSL=true
username=root
password=123456
==========================================================================
import java.io.IOException;
import java.io.InputStream;
import java.sql.*;
import java.util.Properties;

public class JdbcUtils {
    private static String driver = null;
    private static String url = null;
    private static String username = null;
    private static String password = null;

    static{
        try{
            InputStream in = JdbcUtils.class.getClassLoader().getResourceAsStream("db.properties");
            Properties properties = new Properties();
            properties.load(in);

            driver = properties.getProperty("driver");
            url = properties.getProperty("url");
            username = properties.getProperty("username");
            password = properties.getProperty("password");

            //1.驅動只用載入一次
            Class.forName(driver);
        }catch(IOException | ClassNotFoundException e){
            e.printStackTrace();
        }
    }

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

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

2、編寫增刪改的方法，executeUpdate

import com.kuang.lesson02.utils.JdbcUtils;

import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

public class TestInsert {
    public static void main(String[] args) {
        Connection conn = null;
        Statement st = null;
        ResultSet rs = null;
        try {
            conn = JdbcUtils.getConnection();//獲取資料庫連接
            st = conn.createStatement();//獲得SQL的執行對象
            String sql = "INSERT INTO users(id,`NAME`,`PASSWORD`,email,birthday)" +
                    "VALUES(4,'kuangshen','123456','[email protected]','2020-01-01')";
            int i = st.executeUpdate(sql);
            if (i>0){
                System.out.println("插入成功！");
            }
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            JdbcUtils.release(conn,st,rs);
        }
    }
}
==================================================================
import com.kuang.lesson02.utils.JdbcUtils;

import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

public class TestDelete {
    public static void main(String[] args) {
        Connection conn = null;
        Statement st = null;
        ResultSet rs = null;
        try {
            conn = JdbcUtils.getConnection();//獲取資料庫連接
            st = conn.createStatement();//獲得SQL的執行對象
            String sql = "DELETE FROM users WHERE id=4;";
            int i = st.executeUpdate(sql);
            if (i>0){
                System.out.println("刪除成功！");
            }
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            JdbcUtils.release(conn,st,rs);
        }
    }
}
================================================================
import com.kuang.lesson02.utils.JdbcUtils;

import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

public class TestUpdate {
    public static void main(String[] args) {
        Connection conn = null;
        Statement st = null;
        ResultSet rs = null;
        try {
            conn = JdbcUtils.getConnection();//獲取資料庫連接
            st = conn.createStatement();//獲得SQL的執行對象
            String sql = "UPDATE users SET `NAME` = 'kuangshen' WHERE id=1;";
            int i = st.executeUpdate(sql);
            if (i>0){
                System.out.println("更新成功！");
            }
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            JdbcUtils.release(conn,st,rs);
        }
    }
}

3、查詢，executeQuery

import com.kuang.lesson02.utils.JdbcUtils;

import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

public class TestSelect {
    public static void main(String[] args) {
        Connection conn = null;
        Statement st = null;
        ResultSet rs = null;
        try {
            conn = JdbcUtils.getConnection();
            st = conn.createStatement();
            String sql = "SELECT * FROM users WHERE `id` = 1;";
            rs = st.executeQuery(sql);
            while (rs.next()){
                System.out.println(rs.getString("NAME"));
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }finally {
            JdbcUtils.release(conn,st,rs);
        }
    }
}

SQL注入的問題

sql存在漏洞，會被攻擊導致數據泄露，SQL會被拼接 or

import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

public class SQL注入 {
    public static void main(String[] args) {
        // login("kuangshen","123456");
        login(" 'or '1=1"," 'or '1=1"); //技巧
    }
    // 登陸業務
    public static void login(String username,String password){

        Connection conn = null;
        Statement st = null;
        ResultSet rs = null;
        try {
            conn = JdbcUtils.getConnection();
            st = conn.createStatement();

            //SELECT * FROM users WHERE `NAME`='kuangshen' AND `PASSWORD`='123456'
            //SELECT * FROM users WHERE `NAME`=' 'or '1=1' AND `PASSWORD`=' 'or '1=1'
            String sql = "SELECT * FROM users WHERE `NAME` = '"+username+"' AND `password` ='"+password+"'";

            rs = st.executeQuery(sql);
            while (rs.next()){
                System.out.println(rs.getString("NAME"));
                System.out.println(rs.getString("password"));
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }finally {
            JdbcUtils.release(conn,st,rs);
        }
    }
}

PreparedStatement對象

PreparedStatement 可以防止SQL注入。效率更好！

1、新增

import com.kuang.lesson02.utils.JdbcUtils;

import java.sql.*;
import java.util.Date;

public class TestInsert {
    public static void main(String[] args) {
        Connection conn = null;
        PreparedStatement st = null;
        try {
            conn = JdbcUtils.getConnection();

            //區別
            //使用？佔位符代替參數
            String sql = "insert into users(id,`NAME`,`PASSWORD`,`email`,`birthday`) values(?,?,?,?,?)";

            st = conn.prepareStatement(sql); //預編譯SQL，先寫sql，然後不執行

            //手動給參數賦值
            st.setInt(1,4);
            st.setString(2,"qinjiang");
            st.setString(3,"123456");
            st.setString(4,"[email protected]");
            //注意點：sql.Date     資料庫  java.sql.Date()
            //       util.Date    Java   new Date().getTime()  獲得時間戳
            st.setDate(5,new java.sql.Date(new Date().getTime()));

            //執行
            int i = st.executeUpdate();
            if (i>0){
                System.out.println("插入成功！");
            }

        } catch (SQLException e) {
            e.printStackTrace();
        }finally {
            JdbcUtils.release(conn,st,null);
        }
    }
}

2、刪除

import com.kuang.lesson02.utils.JdbcUtils;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.util.Date;

public class TestDelete {
    public static void main(String[] args) {
        Connection conn = null;
        PreparedStatement st = null;
        try {
            conn = JdbcUtils.getConnection();

            //區別
            //使用？佔位符代替參數
            String sql = "delete from users where id=?";

            st = conn.prepareStatement(sql); //預編譯SQL，先寫sql，然後不執行

            //手動給參數賦值
            st.setInt(1,4);

            //執行
            int i = st.executeUpdate();
            if (i>0){
                System.out.println("刪除成功！");
            }

        } catch (SQLException e) {
            e.printStackTrace();
        }finally {
            JdbcUtils.release(conn,st,null);
        }
    }
}

3、更新

import com.kuang.lesson02.utils.JdbcUtils;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;

public class TestUpdate {
    public static void main(String[] args) {
        Connection conn = null;
        PreparedStatement st = null;
        try {
            conn = JdbcUtils.getConnection();

            //區別
            //使用？佔位符代替參數
            String sql = "update users set `NAME` = ? where id=?;";

            st = conn.prepareStatement(sql); //預編譯SQL，先寫sql，然後不執行

            //手動給參數賦值
            st.setString(1,"狂神");
            st.setInt(2,1);

            //執行
            int i = st.executeUpdate();
            if (i>0){
                System.out.println("更新成功！");
            }

        } catch (SQLException e) {
            e.printStackTrace();
        }finally {
            JdbcUtils.release(conn,st,null);
        }
    }
}

4、查詢

import com.kuang.lesson02.utils.JdbcUtils;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;

public class TestSelect {
    public static void main(String[] args) {

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

        try {
            conn = JdbcUtils.getConnection();

            String sql = "select * from users where id=?";//編寫SQL
            st = conn.prepareStatement(sql);//預編譯

            st.setInt(1,1);//傳遞參數

            rs = st.executeQuery();//執行
            if (rs.next()){
                System.out.println("查詢成功！");
                System.out.println(rs.getString("NAME"));
            }

        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}

5、防止SQL注入

import com.kuang.lesson02.utils.JdbcUtils;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;

public class SQL注入 {
    public static void main(String[] args) {
        login("lisi","123456");
        //login("'' or 1=1","123456"); //技巧
    }
    // 登陸業務
    public static void login(String username,String password){

        Connection conn = null;
        PreparedStatement st = null;
        ResultSet rs = null;
        try {
            conn = JdbcUtils.getConnection();

            //PreparedStatement 防止SQL諸如的本質，把傳遞進來的參數當作字元
            //假設其中存在轉義字元，比如說 ' 會被直接轉義
            String sql = "select * from users where `NAME` = ? and `PASSWORD` = ?;";

            st = conn.prepareStatement(sql);
            st.setString(1,username);
            st.setString(2,password);

            rs = st.executeQuery(sql);//查詢完畢會返回一個結果集
            while (rs.next()){
                System.out.println(rs.getString("NAME"));
                System.out.println(rs.getString("password"));
            }
        } catch (Exception e) {
            e.printStackTrace();
        }finally {
            JdbcUtils.release(conn,st,rs);
        }
    }
}

使用IDEA連接資料庫

1、

2、連接成功後，可以選擇資料庫

更新數據

切換資料庫

IDEA實現事務

要麼都成功，要麼都失敗

ACID原則

原子性：要麼全部完成，要麼都不完成

一致性：總數不變

隔離性：多個進程互不干擾

持久性：一旦提交不可逆，持久化到資料庫了

隔離性的問題：

臟讀：一個事務讀取了另一個沒有提交的事務

不可重複讀：在同一個事物內，重複讀取表中的數據，表數據發生了改變

虛讀（幻讀）：在一個事務內，讀取到了別人插入的數據，導致前後都出來結果不一致

程式碼實現

1、開啟事務 conn.setAutoCommit(false);

2、一組業務執行完畢，提交事務

3、可以在catch語句中顯式的定義回滾語句，但默認失敗就會回滾

import com.kuang.lesson02.utils.JdbcUtils;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;

public class TestTransaction1 {
    public static void main(String[] args) {
        Connection conn = null;
        PreparedStatement st = null;
        ResultSet rs = null;

        try {
            conn = JdbcUtils.getConnection();
            //關閉資料庫的自動提交,自動會開啟事務
            conn.setAutoCommit(false);

            String sql1 = "update account set money = money-100 where name = 'A'";
            st = conn.prepareStatement(sql1);
            st.executeUpdate();

            int x = 1/0; //報錯

            String sql2 = "update account set money = money+100 where name = 'B'";
            st = conn.prepareStatement(sql2);
            st.executeUpdate();

            //業務完畢，提交事務
            conn.commit();
            System.out.println("成功！");

        } catch (SQLException e) {
            //如果失敗，則默認回滾
            /*try {
                conn.rollback();//如果失敗則回滾事務
            } catch (SQLException ex) {
                ex.printStackTrace();
            }*/
            e.printStackTrace();
        }finally {
            JdbcUtils.release(conn,st,null);
        }
    }
}

資料庫連接池

資料庫連接 — 執行完畢 — 釋放

連接 — 釋放 十分浪費系統資源

池化技術：準備一些預先的資源，過來就連接預先準備好的

—— 開門 — 業務員：等待 — 服務 — 關門

常用連接數 10個

最小連接數：10

最大連接數：15 業務最高承載上限

排隊等待，

等待超時：100ms

編寫連接池，實現一個介面 DataSource

開源數據源實現（拿來即用）

DBCP

C3P0

Druid：阿里巴巴

使用了這些資料庫連接池之後，我們在項目開發中就不需要編寫連接資料庫的程式碼了！

DBCP

需要用到的 jar 包

commons-dbcp-1.4、commons-pool-1.6

//Java的src文件夾下設置properties配置文件
#連接設置
driverClassName=com.mysql.jdbc.Driver
url=jdbc:mysql://localhost:3306/jdbcStudy?useUnicode=true&characterEncoding=utf8&useSSL=true
username=root
password=123456

#<!-- 初始化連接 -->
initialSize=10

#最大連接數量
maxActive=50

#<!-- 最大空閑連接 -->
maxIdle=20

#<!-- 最小空閑連接 -->
minIdle=5

#<!-- 超時等待時間以毫秒為單位 6000毫秒/1000等於60秒 -->
maxWait=60000

#JDBC驅動建立連接時附帶的連接屬性屬性的格式必須為這樣：[屬性名=property;]
#注意："user" 與 "password" 兩個屬性會被明確的傳遞，因此這裡不需要包含他們。
connectionProperties=useUnicode=true;characterEncoding=UTF8

#指定由連接池所創建的連接的自動提交（auto-commit）狀態。
defaultAutoCommit=true

#driver default 指定由連接池所創建的連接的只讀（read-only）狀態。
#如果沒有設置該值，則"setReadOnly"方法將不被調用。（某些驅動並不支援只讀模式，如：Informix）
defaultReadOnly=

#driver default 指定由連接池所創建的連接的事務級別（TransactionIsolation）。
#可用值為下列之一：（詳情可見javadoc。）NONE,READ_UNCOMMITTED,READ_COMMITTED,REPEATABLE_READ,SERIALIZABLE
defaultTransactionIsolation=READ_UNCOMMITTED
===================================
import com.kuang.lesson02.utils.JdbcUtils;
import org.apache.commons.dbcp.BasicDataSourceFactory;
import javax.sql.DataSource;
import java.io.InputStream;
import java.sql.*;
import java.util.Properties;

public class JdbcUtils_DBCP {

    private static DataSource dataSource;

    static{
        try{
            InputStream in = JdbcUtils.class.getClassLoader().getResourceAsStream("dbcpconfig.properties");
            Properties properties = new Properties();
            properties.load(in);
            //創建數據源 工廠模式--> 創建
            dataSource = BasicDataSourceFactory.createDataSource(properties);
        }catch(Exception e){
            e.printStackTrace();
        }
    }
    //獲取連接
    public static Connection getConnection() throws SQLException {
        return dataSource.getConnection();//從數據源中獲取連接
    }
    //釋放連接資源
    public static void release(Connection conn, Statement st, ResultSet rs){
        if (rs!=null){
            try {
                rs.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
        if (st!=null){
            try {
                st.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
        if (conn!=null){
            try {
                conn.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }
}
===================================
import com.kuang.lesson05.utils.JdbcUtils_DBCP;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.util.Date;

public class TestDBCP {
    public static void main(String[] args) {
        Connection conn = null;
        PreparedStatement st = null;
        try {
            conn = JdbcUtils_DBCP.getConnection();
            //區別
            //使用？佔位符代替參數
            String sql = "insert into users(id,`NAME`,`PASSWORD`,`email`,`birthday`) values(?,?,?,?,?)";
            st = conn.prepareStatement(sql); //預編譯SQL，先寫sql，然後不執行
            //手動給參數賦值
            st.setInt(1,4);
            st.setString(2,"qinjiang");
            st.setString(3,"123456");
            st.setString(4,"[email protected]");
            //注意點：sql.Date     資料庫  java.sql.Date()
            //       util.Date    Java   new Date().getTime()  獲得時間戳
            st.setDate(5,new java.sql.Date(new Date().getTime()));
            //執行
            int i = st.executeUpdate();
            if (i>0){
                System.out.println("插入成功！");
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }finally {
            JdbcUtils_DBCP.release(conn,st,null);
        }
    }
}

C3P0

需要用到的 jar 包

commons-dbcp-1.4、 commons-pool-1.6

//Java的src文件夾下設置XML配置文件
<?xml version="1.0" encoding="UTF-8"?>
<c3p0-config>
    <!--
    C3P0的預設（默認）配置，
    如果在程式碼中「ComboPooledDataSource ds = new ComboPooledDataSource();」這樣寫就表示使用的是C3P0的預設（默認）
    -->
    <default-config>
        <property name="driverClass">com.mysql.jdbc.Driver</property>
        <property name="jdbcUrl">jdbc:mysql://localhost:3306/jdbcStudy?useUnicode=true&amp;characterEncoding=utf8&amp;useSSL=true</property>
        <property name="user">root</property>
        <property name="password">123456</property>
        <property name="acquireIncrement">5</property>
        <property name="initialPoolSize">10</property>
        <property name="minPoolSize">5</property>
        <property name="maxPoolSize">20</property>
    </default-config>

    <!--
    C3P0的命名配置，
    如果在程式碼中「ComboPooledDataSource ds = new ComboPooledDataSource("MySQL");」這樣寫就表示使用的是name是MySQL
    -->
    <named-config name="MySQL">
        <property name="driverClass">com.mysql.jdbc.Driver</property>
        <property name="jdbcUrl">jdbc:mysql://localhost:3306/jdbcStudy?useUnicode=true&amp;characterEncoding=utf8&amp;useSSL=true</property>
        <property name="user">root</property>
        <property name="password">123456</property>
        <property name="acquireIncrement">5</property>
        <property name="initialPoolSize">10</property>
        <property name="minPoolSize">5</property>
        <property name="maxPoolSize">20</property>
    </named-config>
</c3p0-config>
==================================
import com.mchange.v2.c3p0.ComboPooledDataSource;
import javax.sql.DataSource;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

public class JdbcUtils_C3P0 {
    private static DataSource dataSource;

    static{
        try{
            //程式碼版配置
            /*dataSource = new ComboPooledDataSource();
            dataSource.setDriverClass();
            dataSource.setUser();
            dataSource.setPassword();
            dataSource.setJdbcUrl();
            dataSource.setMaxPoolSize();
            dataSource.setMinPoolSize();*/

            //創建數據源 工廠模式--> 創建
            dataSource = new ComboPooledDataSource("MySQL");//配置文件寫法
        }catch(Exception e){
            e.printStackTrace();
        }
    }
    //獲取連接
    public static Connection getConnection() throws SQLException {
        return dataSource.getConnection();//從數據源中獲取連接
    }
    //釋放連接資源
    public static void release(Connection conn, Statement st, ResultSet rs){
        if (rs!=null){
            try {
                rs.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
        if (st!=null){
            try {
                st.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
        if (conn!=null){
            try {
                conn.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }
}
===================================
import com.kuang.lesson05.utils.JdbcUtils_C3P0;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.util.Date;

public class TestC3P0 {
    public static void main(String[] args) {
        Connection conn = null;
        PreparedStatement st = null;
        try {
            conn = JdbcUtils_C3P0.getConnection();//原來是自己實現的，現在用別人實現的
            //區別
            //使用？佔位符代替參數
            String sql = "insert into users(id,`NAME`,`PASSWORD`,`email`,`birthday`) values(?,?,?,?,?)";
            st = conn.prepareStatement(sql); //預編譯SQL，先寫sql，然後不執行
            //手動給參數賦值
            st.setInt(1,5);
            st.setString(2,"qinjiang");
            st.setString(3,"123456");
            st.setString(4,"[email protected]");
            //注意點：sql.Date     資料庫  java.sql.Date()
            //       util.Date    Java   new Date().getTime()  獲得時間戳
            st.setDate(5,new java.sql.Date(new Date().getTime()));

            //執行
            int i = st.executeUpdate();
            if (i>0){
                System.out.println("插入成功！");
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }finally {
            JdbcUtils_C3P0.release(conn,st,null);
        }
    }
}

結論

無論使用什麼數據源，本質還是一樣的，DataSource介面不會變，方法就不會變