2. 程式人生 > >編寫工具類簡化JDBC（CURD）的操作

編寫工具類簡化JDBC（CURD）的操作

阿新 • • 發佈：2018-12-09

JDBC

全稱是JAVA DATE BASE Connectity(java資料庫連線），可以為多種資料庫提供統一的訪問。即定義一個規範的介面，讓各資料庫廠商提供介面的具體實現類，這種實現類同時也被稱作驅動。

JDBC規範

（4個核心物件） - DriverManager:用於註冊驅動。 - Connection:與資料庫建立連線。 - Statement:操作資料庫sql語句的物件。 - ResultSet：結果集（存放由select語句查詢到的資料資訊）

JDBC連線資料庫的5個主要步驟

（即根據4個核心類物件推匯出的步驟並封裝）

1.載入驅動

方式一： 直接註冊驅動

DriverManager.registerDriver(new Driver());

方式二：（推薦使用） 通過反射的方式，實現驅動的載入

Class.forName("com.mysql.cj.jdbc.Driver");

注意：

  • 在實際開發的過程中，不推薦使用方式一來進行驅動的註冊，檢視Driver原始碼(如下）可以看到，它本身就載入了一次驅動，這樣一來就會導致驅動程式註冊兩次，也就表示了在記憶體中會有兩個Driver物件
  • 程式依賴mysql的jar包，一旦脫離，程式將無法編譯，將來程式切換底層資料庫將會非常麻煩。

Driver原始碼

static {
        try
 
 {
            DriverManager.registerDriver(new Driver());
        } catch (SQLException var1) {
            throw new RuntimeException("Can't register driver!");
        }
    }
  • 採用方式二不會導致驅動物件在記憶體中重複出現，程式僅需要一個字串，不需要依賴具體的驅動，使程式的靈活性更高。

2.建立連線

通過註冊的JDBC驅動來建立資料庫連線物件從而獲取資料庫的URL，使用者名稱，密碼來連線資料庫

 String
 
 url = "jdbc:mysql://localhost:3306/day04?serverTimezone=UTC&characterEnconding=utf-8";
            Connection con = DriverManager.getConnection(url,"root","123456");

解析

String url = "jdbc:mysql://localhost:3306/day04?serverTimezone=UTC&characterEnconding=utf-8";

jdbc:是JDBC連線協議 mysq:// 是mysql資料庫連線協議，即JDBC子協議 Localhost:3306 是主機和埠 day04 是指需要連線的資料庫 serverTimezone=UTC:國際通用時區 characterEncoding=utf-8:資料庫編碼格式 （主要是解決資料庫亂碼的問題）

3.操作資料

方式一：（該方式有弊端，會導致sql注入問題） 通過資料庫連線物件獲取操作資料庫sql語句的物件Statement

String sql = "select * from user where username = '"+name+"' and password = '"+passwd+"';";
            Statement stmt = con.createStatement();

模擬使用者登入 需求：通過鍵盤錄入來獲取使用者名稱和密碼，同時在資料庫中判斷該使用者是否存在 存在即登入成功，反之則失敗。

程式碼一：

import java.sql.*;
import java.util.Scanner;

public class JDBCTest3 {

    public static void main(String[] args) {
        System.out.println("請輸入使用者名稱");
        String name = new Scanner(System.in).nextLine();
        System.out.println("請輸入密碼");
        String passwd = new Scanner(System.in).nextLine();
    //載入驅動
        try {
            Class.forName("com.mysql.cj.jdbc.Driver");
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        }

        Connection con = null;
        Statement stmt = null;
        ResultSet rs = null;

        try {
        //建立連線
            String url = "jdbc:mysql://localhost:3306/day04?serverTimezone=UTC&characterEnconding=utf-8";
            con = DriverManager.getConnection(url,"root","123456");

        //操作資料
            String sql = "select * from user where username = '"+name+"' and password = '"+passwd+"';";
            stmt = con.createStatement();
            rs = stmt.executeQuery(sql);
            // 判斷返回的結果
            if (rs.next()) {
                // 登入成功
                int id = rs.getInt("id");
                String u_name = rs.getString("username");
                String u_pwd = rs.getString("password");
                String email = rs.getString("email");
//                System.out.println(id + " : " + u_name + " : " + u_pwd + " : " + email);
                System.out.println("登入成功!");
            } else {
                // 登入失敗
                System.out.println("登入失敗! 使用者名稱或密碼錯誤!");
            }
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            //釋放資源
            if (rs != null) {
                try {
                    rs.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
                rs = null;
            }
            if (stmt != null) {
                try {
                    stmt.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
                stmt = null;
            }
            if (con != null) {
                try {
                    con.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
                con = null;
            }

        }
    }
}

結果：

請輸入使用者名稱
lisi
請輸入密碼
123
登入成功!

由於對使用者的輸入沒有進行充分的檢查而SQL又是拼接而成，在使用者輸入引數時，在引數中新增一些SQL 關鍵字，達到改變SQL執行結果的目的。

案例一： 輸入使用者時: zhangsan’ or ‘1’=’1 password 隨意 程式碼中sql語句進行拼接

select * from user where username ='zhangsan' or '1'='1' and password ='';

由於 and 優先順序 執行 高於 or，導致不需要任何密碼都能登入成功 

請輸入使用者名稱
lisi' or '1'='1
請輸入密碼
00000000
登入成功!

案例二： 使用者輸入 username: zhangsan’ – password 隨意 程式碼中sql語句進行拼接

select * from user where username ='zhangsan' -- ' and password ='' ;

在SQL新增 – 是mysql的註釋 

請輸入使用者名稱
lisi' -- 
請輸入密碼
111111
登入成功!

方式二：（推薦使用） 通過資料庫連線物件獲取操作資料庫sql語句的物件PreparedStatement

String sql = "select * from user where username = ? and password = ?;";
PreparedStatement pstmt = con.prepareStatement(sql);
pstmt.setString(1,name);
pstmt.setString(2,passwd);

解析：

  • ？表示佔位符
  • 將帶有?的SQL 傳送給資料庫完成預編譯 ，在SQL編譯後發現缺少兩個引數。PreparedStatement 可以將? 代替引數傳送給資料庫伺服器，因為SQL已經編譯過，引數中特殊字元不會當做特殊字元編譯，無法達到SQL注入的目的 。
  • setString(int parameterIndex, String x)
//表示給第一個？設定一個字串型別的值
pstmt.setString(1,name);
  • PreparedStatement是Statement的子介面，它的例項物件可以通過呼叫Connection.preparedStatement(sql)方法獲得，相對於Statement物件而言： PreperedStatement可以避免SQL注入的問題。 Statement會使資料庫頻繁編譯SQL，可能造成資料庫緩衝區溢位。PreparedStatement可對SQL進行預編譯，從而提高資料庫的執行效率。並且PreperedStatement對於sql中的引數，允許使用佔位符的形式進行替換，簡化sql語句的編寫。

程式碼二：

import java.sql.*;
import java.util.Scanner;

public class JDBCTest3 {

    public static void main(String[] args) {
        System.out.println("請輸入使用者名稱");
        String name = new Scanner(System.in).nextLine();
        System.out.println("請輸入密碼");
        String passwd = new Scanner(System.in).nextLine();

        try {
            Class.forName("com.mysql.cj.jdbc.Driver");
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        }

        Connection con = null;
        PreparedStatement pstmt = null;
        ResultSet rs = null;

        try {
            String url = "jdbc:mysql://localhost:3306/day04?serverTimezone=UTC&characterEnconding=utf-8";
            con = DriverManager.getConnection(url,"root","123456");

            String sql = "select * from user where username = ? and password = ?;";
            pstmt = con.prepareStatement(sql);
            pstmt.setString(1,name);
            pstmt.setString(2,passwd);


            rs = pstmt.executeQuery();
            // 判斷返回的結果
            if (rs.next()) {
                // 登入成功
                int id = rs.getInt("id");
                String u_name = rs.getString("username");
                String u_pwd = rs.getString("password");
                String email = rs.getString("email");
//                System.out.println(id + " : " + u_name + " : " + u_pwd + " : " + email);
                System.out.println("登入成功!");
            } else {
                // 登入失敗
                System.out.println("登入失敗! 使用者名稱或密碼錯誤!");
            }
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            if (rs != null) {
                try {
                    rs.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
                rs = null;
            }
            if (pstmt != null) {
                try {
                    pstmt.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
                pstmt = null;
            }
            if (con != null) {
                try {
                    con.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
                con = null;
            }

        }
    }
}

結果

請輸入使用者名稱
lisi
請輸入密碼
123
登入成功!

4.獲取操作資料

  • executeUpdate 無結果集 用於向資料庫傳送 insert/update/delete 語句，返回int 型別引數，代表影響記錄行數.
int count = pstmt.executeUpdate();
  • executeQuery 通過結果集獲取操作資料庫後的結果 用於向資料庫傳送 select 語句，返回ResultSet 結果集物件.。
ResultSet rs = pstmt.executeQuery();
  • execute 用於判斷資料庫傳送任何SQL語句（包括 select/insert/update/delete） 返回boolean型別 ，SQL執行結果是select返回true，否則 false。
boolean flag = pstmt.execute();

5.釋放資源

Jdbc程式執行完後，切記要釋放程式在執行過程中，建立的那些與資料庫進行互動的物件，這些物件通常是ResultSet, Statement和Connection物件。 特別是Connection物件，它是非常稀有的資源，用完後必須馬上釋放，如果Connection不能及時、正確的關閉，極易導致系統宕機。Connection的使用原則是儘量晚建立，儘量早的釋放。為確保資源釋放程式碼能執行，資源釋放程式碼也一定要放在finally語句中。

無結果集釋放資源

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

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

有結果集釋放資源

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

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

       release(rs);
    }

    public static void release(ResultSet rs) {
        if(rs != null) {
            try {
                rs.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
            rs = null;
        }
    }

對上述JDBC連線資料庫並操作資料的步驟進行封裝

  • 抽取資料庫資訊

    1. 抽取註冊驅動依賴的mysql的jar包
    2. 抽取註冊的JDBC驅動來建立資料庫連線物件從而獲取資料庫的URL，使用者名稱，密碼
    3. 把以上抽取的物件放入配置檔案中
driverClass=com.mysql.cj.jdbc.Driver
url=jdbc:mysql://localhost:3306/day04?serverTimezone=UTC&characterEncoding=utf-8
username=root
passwd=123456

解析配置檔案並對上述JDBC連線資料庫的步驟進行封裝

import java.sql.*;

public class JDBCUtils {

    private static final String DRIVERCLASS="com.mysql.cj.jdbc.Driver";
    private static final String URL="jdbc:mysql://localhost:3306/day04?serverTimezone=UTC" +
            "&characterEncoding=utf-8";
    private static final String USERNAME="root";
    private static final String PASSWD="123456";

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

    //獲取連線
    public static Connection getConnection() throws SQLException {
        String url = URL;
        Connection con = DriverManager.getConnection(url,USERNAME,PASSWD);

        return con;
    }

    //無結果集釋放資源
    public static void realease(Connection con, Statement stmt) {
        if(stmt != null) {
            try {
                stmt.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
            stmt = null;
        }

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

    //有結果集釋放資源
    public static void realease(Connection con, Statement stmt,ResultSet rs) {
        if(stmt != null) {
            try {
                stmt.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
            stmt = null;
        }

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

        realease(rs);
    }

    public static void realease(ResultSet rs) {
        if(rs != null) {
            try {
                rs.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
            rs = null;
        }
    }
}

測試：

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

public class JDBCTest5 {
    public static void main(String[] args) {
        Connection con = null;
        PreparedStatement pstmt = null;

        try {
            con = JDBCUTils2.getConnection();

            String sql = "update user set username = ?,password = ?,email = ? where id = ?;";
            pstmt = con.prepareStatement(sql);

            pstmt.setString(1,"jiuba");
            pstmt.setString(2,"888");
            pstmt.setString(3,"[email protected]");
            pstmt.setString(4,"2");

            int count = pstmt.executeUpdate();
            System.out.println(count);

        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            JDBCUTils2.realease(con,pstmt);
        }
    }
}

結果

1

相關推薦

編寫工具類簡化JDBC（CURD）的操作

JDBC 全稱是JAVA DATE BASE Connectity(java資料庫連線），可以為多種資料庫提供統一的訪問。即定義一個規範的介面，讓各資料庫廠商提供介面的具體實現類，這種實現類同時也被稱作驅動。 JDBC規範 （4個核心物件） - Dri

前端常用外掛、工具類庫彙總（上）

前言 在開發中，我們經常會將一些常用的程式碼塊、功能塊進行封裝，為的是更好的複用。那麼，被抽離出來獨立完成功能，通過API或配置項和其他部分互動，便形成了外掛。 下面這些是我在工作中積累的一些常用的前端開源外掛，這裡只是羅列出來，詳細的用法各個外掛官網或者Gayhub都有介紹。注意：往往一個解決方案會

前端常用外掛、工具類庫彙總（下）

前言 對本文感興趣可以先加個收藏，也可以轉發分享給身邊的小夥伴，以後遇到類似的場景就來看看具體的外掛及其用法。 上一篇《前端常用外掛、工具類庫彙總（上）》內容摘要： 動畫庫 滾動庫 輪播圖 滾屏 彈出框 訊息通知 下拉框 級聯選擇器

前端常用外掛、工具類庫彙總（轉）

前言 在開發中，我們經常會將一些常用的程式碼塊、功能塊進行封裝，為的是更好的複用。那麼，被抽離出來獨立完成功能，通過API或配置項和其他部分互動，便形成了外掛。 下面這些是我在工作中積累的一些常用的前端開源外掛，這裡只是羅列出來，詳細的用法各個外掛官網或者Gayhub都有介紹。注意：往往一個

day01-----> json工具類學習筆記（1）

day01—–工具類學習筆記之一【json工具類】 程式碼塊 自定義JSONUtils工具類 ===> 例如： package com.utils.josnutils; import java.util.ArrayList; import jav

java分頁的實現（後臺工具類和前臺jsp頁面）

cal else static pre cti per servle reac tint 1、首先，新建一個類Page.java 1 public class Page implements Serializable { 2 private static fi

Java類集框架（六）：Stack及Properties子類、Collections工具類

Stack子類 在java.util包內可以利用stack類實現棧的功能。此類定義如下： public class Stack<E> extends Vector<E> Stack類常用方法： 方法 型別

Android 常用開發工具類之 SPUtils （SharedPreference 工具類）

開發過程中難免會遇到如持久儲存使用者資訊等需求，而由於資料量很少感覺使用 Sql 有些殺雞用牛刀的感覺也有些累贅。所以善於使用 SharedPreference 可以幫助我們在本地儲存一些資料量少，又使用很頻繁的東西。 SPUtils 一個可以幫助我們很簡潔的使用  Sha

RedisUtil（RedisTemplateUtil）操作redis的工具類

操作redis的工具類： package com.qiang.util; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.data.redi

Java工具類--JSON解析（以百度天氣為例）

隨著JSON的廣泛應用，解析JSON也成了程式設計師的一項基本技能。今天介紹JSON解析利器-Gson和fastjson Gson是谷歌封裝的JSON解析類庫，使用方便，fastjson是阿里巴巴的產品，使用也非常方便，我問小滿喜歡用哪個？他說Gson，wh

Android studio 封裝請求網路工具類以及實現（包含單例模式）

一般我們在請求網路資料時都會通過一個或多個連結去請求網路資料，但對於一些初學人士都只是在一個類裡或MainActivity做很多操作，這樣的話耦合度太高，程式碼感覺非常繁瑣，專案執行時可能會卡。一般在公司裡面也會要求低耦合，高類聚。這時就會通過封裝工具類來降低耦合度，這樣也就減少了程式碼與程

laravel DB類SQL語句操作（CURD）

$user = DB::table('users')->where('name', 'John')->first(); var_dump($user->name);檢索單個列的行 複製程式碼程式碼如下: $name = DB::table('users')->where('n

工具類之SpannableStringUtils（相信你會愛上它）

這個工具類真是構思了良久才設計出來，採用了建造者模式，然後你們就可以用鏈式呼叫了，talk is cheap, let me show the demo. demo code 有沒有心動一下哈，下面就讓老司機為你們開路。 站點 getBuilder

POI讀取execl的工具類：ExcelReader（解析Excel的工具類）

package cn.com.css.common.util; import java.io.IOException; import java.io.InputStream; import java.text.SimpleDateFormat; import java.

JDBC（六） 編寫通用的更新和查詢方法

對於C（建立），U（更新），D（刪除）都屬於更新操作，對於R（讀取查詢）屬於查詢操作。這裡編寫兩個通用的更新和查詢方法。 更新 更新簡單，只需要傳入對應的sql和sql的佔位符，然後執行更新就可以了。 /** * @return 返回影響

Andorid開發工具類之——BitmapUtils（壓縮圖片利器，告別oom，程式更快）

最近開發的一個專案使用到了圖片載入上傳和儲存，由於是接受別人的做，也基本上做完了。但是程式已啟動到需要載入圖片上傳到伺服器的介面的時候記憶體就暴漲，雖然也沒有oom,估計舊點的手機肯定會爆，只要不啟動到圖片載入的頁面，記憶體基本上佔用只用20+mb,選擇圖片後達到了80兆。

第十二章 Shell腳本編寫及常見面試題（二）

shell腳本 shell面試題 shell本章目錄：12.11 屏蔽網站訪問頻繁的IP1）屏蔽每分鐘訪問超過200的IP方法1：以Nginx日誌作為測試DATE=$(date +%d/%b/%Y:%H:%M) ABNORMAL_IP=$(tail -n5000 access.log |grep $DATE

第2課 類型推導（2）_decltype關鍵字

bar using 獲取 臨時 pub 通過 lsp amp 判斷 1. decltype關鍵字 （1）auto所修飾的變量必須被初始化，編譯器才能通過初始化來確定auto所代表的類型，即必須先定義變量。 （2）decltype可以在編譯期推導出一個變量或表達式的結果類型（

3.2 標準庫類型string（上）

讀寫 什麽 empty lin 標準庫 urn 錯誤 序列 nbsp #include <string> #include <iostream> using std::string; using std::cin; using std::cout;

C# 類型基礎（下）

合成 托管 相加 返回 長度 參數類型 一個 con 重載 前面介紹了基本的類型，接下來我們講講類型的轉換 值類型的兩種表現形式：未裝箱和已裝箱 ，而引用類型總是處於裝箱形式 int count = 10; object obj = count; 裝箱：值類型