7.21 JDBC 學(xué)習(xí)總結(jié)

謙虛其心,宏大其量

上午主要學(xué)習(xí)了JDBC

JDBC(Java DataBase Connectivity,即java數(shù)據(jù)庫連接)是一種用于執(zhí)行SQL語句的Java API,可以為多種關(guān)系數(shù)據(jù)庫提供統(tǒng)一訪問,它由一組用Java語言編寫的類和接口組成。JDBC提供了一種基準(zhǔn),據(jù)此可以構(gòu)建更高級的工具和接口,使數(shù)據(jù)庫開發(fā)人員能夠編寫數(shù)據(jù)庫應(yīng)用程序。

(JDBC用socket技術(shù)實(shí)現(xiàn) 是典型的兩個(gè)進(jìn)程之間的通信)

JDBC用途

基于昨天學(xué)的MySQL知識
http://www.itdecent.cn/p/c98059693e5d

在itcast數(shù)據(jù)庫中建立的student表:

student表.png

在MyEclispse中建立Web項(xiàng)目:

2017-07-21 (1).png
2017-07-21 (2).png

下載老師給的mysql-connector-java-5.1.30.jar文件
http://pan.baidu.com/s/1bp1tb7h
(用于連接java和mysql數(shù)據(jù)庫關(guān)鍵文件)

選中文件 (左上角):


2017-07-21 (3).png

復(fù)制文件后直接粘貼到 Web工程中WebRoot\WEB-INF\lib文件夾下:

QQ圖片20170721113313.png

安裝的MySQL數(shù)據(jù)庫為服務(wù)器端(左)
打開的MySQL命令行是客戶端程序(右):


QQ圖片20170721204246.png

我們在客戶端(shell)下輸入指令:


QQ圖片20170721204647.png

傳給MySQL服務(wù)器端后 其接收指令——解釋指令——執(zhí)行指令——返回給shell結(jié)果

Java 所有的API都是為了讓我們方便編程設(shè)計(jì)的,讓程序員不用再去考慮很復(fù)雜的問題,但要知道其原理! JDBC就是一種用于執(zhí)行SQL語句的Java API。

使用JDBC來操作數(shù)據(jù)庫用到的類:
1 Connection 連接 (接頭人)
2 Statement 語句 (送信的)
3 ResultSet 結(jié)果集 (查詢需要)

連接遍歷數(shù)據(jù)庫的大致步驟:

遍歷數(shù)據(jù)庫

遍歷打印數(shù)據(jù)庫中數(shù)據(jù) 代碼:

import java.sql.DriverManager;
import java.sql.ResultSet;
import com.mysql.jdbc.Connection;
import com.mysql.jdbc.Statement;

public class TestJDBC {
    public static void main(String[] args) throws Exception {
        // 第一步 先加載注冊JDBC的驅(qū)動類
        Class.forName("com.mysql.jdbc.Driver");
        // 第二步 提供JDBC連接的url
        String url = "jdbc:mysql://localhost:3306/itcast";
        String username = "root";
        String password = "root";
        // 第三步 創(chuàng)建數(shù)據(jù)庫的連接(利用驅(qū)動器管理器DriverManager的getConnection方法)
        Connection conn = (Connection) DriverManager.getConnection(url, username, password);
        // 第四步 創(chuàng)建一個(gè)statement對象
        Statement stmt = (Statement) conn.createStatement();
        // 第五步 執(zhí)行sql語句
        ResultSet rs = stmt.executeQuery("select * from student");
        // 第六步 循環(huán)遍歷處理結(jié)果
        while(rs.next()) {
            System.out.println(rs.getString("name"));
            System.out.println(rs.getFloat("grade"));
        }
        // 第七步 關(guān)閉JDBC對象
        rs.close();
        stmt.close();
        conn.close();
    }
}

注:
第一步 加載注冊JDBC的驅(qū)動類 Class.forName("com.mysql.jdbc.Driver"); 不同數(shù)據(jù)庫不一樣(這里用的是mysql) 需要其他數(shù)據(jù)庫的話 直接去查即可

stmt.executeQuery 返回一個(gè)結(jié)果集 用于查詢

關(guān)鍵語句:

ResultSet rs = stmt.executeQuery("select * from student");

另外要注意第七步關(guān)閉順序(反著來)

上面代碼版本異常處理為main函數(shù)處拋出:

public static void main(String[] args) throws Exception { }

這種做法不好,若后面代碼中間一旦異常停止
則其后面的代碼不會執(zhí)行。

改進(jìn)的版本:(增加try catch)

import java.sql.*;

public class TestJDBC {
    public static void main(String[] args) {
    
        Connection conn = null;
        Statement stmt = null;
        ResultSet rs = null;
        
        try{
            // 第一步 先加載JDBC的驅(qū)動類
            Class.forName("com.mysql.jdbc.Driver");
            // 第二步 提供JDBC連接的url
            String url = "jdbc:mysql://localhost:3306/itcast";
            String username = "root";
            String password = "root";
            // 第三步 創(chuàng)建數(shù)據(jù)庫的連接
            conn = DriverManager.getConnection(url, username, password);
            // 第四步 創(chuàng)建一個(gè)statement對象
            stmt = conn.createStatement();
            // 第五步 執(zhí)行sql語句 獲取結(jié)果集合
            rs = stmt.executeQuery("select * from student");
            // 第六步 循環(huán)遍歷結(jié)果集 處理
            while(rs.next()) {
                System.out.println(rs.getString("name"));
                System.out.println(rs.getFloat("grade"));
            }
        }catch(ClassNotFoundException e) {
            e.printStackTrace();
            System.out.println("ClassNotFoundException");
            // 還要進(jìn)行寫入日志操作
        }catch(SQLException e) {
            e.printStackTrace();
            System.out.println("SQLException");
        }finally{
            try{
                // 第七步 關(guān)閉JDBC對象 釋放資源
                rs.close();
                stmt.close();
                conn.close();
            }catch(SQLException e) {
                e.printStackTrace();
            }
            
        }
    }
}

首先是try后兩個(gè)catch分支 分別處理不同異常,try catch后的finally里執(zhí)行關(guān)閉JDBC對象操作(此更符合事件處理邏輯)

又考慮到對象rs stmt為空關(guān)閉會導(dǎo)致異常
改進(jìn)finally中處理辦法:

...
}finally{
    try{
        // 第七步 關(guān)閉JDBC對象
        if(rs != null) {
            rs.close();
        }
        if(stmt != null) {
            stmt.close();
        }
        if(conn != null) {
            conn.close();
        }
    }catch(SQLException e) {
        e.printStackTrace();
    }
}

最終較完美代碼:

import java.sql.*;

public class TestJDBC {
    public static void main(String[] args) {
    
        Connection conn = null;
        Statement stmt = null;
        ResultSet rs = null;
        
        try{
            // 第一步 先加載JDBC的驅(qū)動類
            Class.forName("com.mysql.jdbc.Driver");
            // 第二步 提供JDBC連接的url
            String url = "jdbc:mysql://localhost:3306/itcast";
            String username = "root";
            String password = "root";
            // 第三步 創(chuàng)建數(shù)據(jù)庫的連接
            conn = DriverManager.getConnection(url, username, password);
            // 第四步 創(chuàng)建一個(gè)statement對象
            stmt = conn.createStatement();
            // 第五步 執(zhí)行sql語句
            rs = stmt.executeQuery("select * from student");
            // 第六步 循環(huán)遍歷處理結(jié)果
            while(rs.next()) {
                System.out.println(rs.getString("name"));
                System.out.println(rs.getFloat("grade"));
            }
        }catch(ClassNotFoundException e) {
            e.printStackTrace();
            System.out.println("ClassNotFoundException");
            // 還要進(jìn)行寫入異常操作
        }catch(SQLException e) {
            e.printStackTrace();
            System.out.println("SQLException");
        }finally{
            try{
                // 第七步 關(guān)閉JDBC對象 釋放資源
                if(rs != null) {
                    rs.close();
                }
                if(stmt != null) {
                    stmt.close();
                }
                if(conn != null) {
                    conn.close();
                }
            }catch(SQLException e) {
                e.printStackTrace();
            }
            
        }
    }
}

也可以再優(yōu)化一下結(jié)構(gòu):

import java.sql.*;

public class TestJDBC22 {
    public static void main(String[] args) {
        Connection conn = null;
        Statement stmt = null;
        ResultSet rs = null;
        String Driver = "com.mysql.jdbc.Driver";
        // 對應(yīng) 第二步 
        String url = "jdbc:mysql://localhost:3306/itcast";
        String username = "root";
        String password = "root";
        try{
            // 第一步 先加載JDBC的驅(qū)動類
            Class.forName(Driver);
            // 第二步 提供JDBC連接的url
            
            // 第三步 創(chuàng)建數(shù)據(jù)庫的連接
            conn = DriverManager.getConnection(url, username, password);
            // 第四步 創(chuàng)建一個(gè)statement對象
            stmt = conn.createStatement();
            // 第五步 執(zhí)行sql語句
            rs = stmt.executeQuery("select * from student");
            // 第六步 循環(huán)遍歷處理結(jié)果
            while(rs.next()) {
                System.out.println(rs.getString("name"));
                System.out.println(rs.getFloat("grade"));
            }
        }catch(ClassNotFoundException e) {
            e.printStackTrace();
            System.out.println("ClassNotFoundException");
            // 還要進(jìn)行寫入異常操作
        }catch(SQLException e) {
            e.printStackTrace();
            System.out.println("SQLException");
        }finally{
            try{
                // 第七步 關(guān)閉JDBC對象 釋放資源
                if(rs != null) {
                    rs.close();
                }
                if(stmt != null) {
                    stmt.close();
                }
                if(conn != null) {
                    conn.close();
                }
            }catch(SQLException e) {
                e.printStackTrace();
            }
            
        }
    }
}

重要說明:
將:

import java.sql.DriverManager;
import java.sql.ResultSet;
import com.mysql.jdbc.Connection;
import com.mysql.jdbc.Statement;
...

改為:

import java.sql.*;
...

則代碼中很多不用強(qiáng)轉(zhuǎn)類型:

強(qiáng)轉(zhuǎn)說明.png

不遍歷的話 則大致步驟:


步驟

數(shù)據(jù)插入操作代碼:

import java.sql.*;

public class Test {
    public static void main(String[] args) {
    
        Connection conn = null;
        Statement stmt = null;
 
        try{
            // 第一步 先加載JDBC的驅(qū)動類
            Class.forName("com.mysql.jdbc.Driver");
            // 第二步 提供JDBC連接的url
            String url = "jdbc:mysql://localhost:3306/itcast";
            String username = "root";
            String password = "root";
            // 第三步 創(chuàng)建數(shù)據(jù)庫的連接
            conn = DriverManager.getConnection(url, username, password);
            // 第四步 創(chuàng)建一個(gè)statement對象
            stmt = conn.createStatement();
            // 第五步 執(zhí)行sql語句
            String sql = "insert into student values(0,'七月',23,'男')";
            stmt.executeUpdate(sql);
        }catch(ClassNotFoundException e) {
            e.printStackTrace();
            System.out.println("ClassNotFoundException");
            // 還要進(jìn)行寫入日志等操作 所以要分開兩個(gè)異常類別 都要 catch 
        }catch(SQLException e) {
            e.printStackTrace();
            System.out.println("SQLException");
        }finally{
            try{
                // 第六步 關(guān)閉JDBC對象
                if(stmt != null) {
                    stmt.close();
                }
                if(conn != null) {
                    conn.close();
                }
            }catch(SQLException e) {
                e.printStackTrace();
            }
        }
    }
}

數(shù)據(jù)添加成功.png

批量插入方法:

import java.sql.*;

public class Test {
    public static void main(String[] args) {
    
        Connection conn = null;
        Statement stmt = null;
 
        try{
            // 第一步 先加載JDBC的驅(qū)動類
            Class.forName("com.mysql.jdbc.Driver");
            // 第二步 提供JDBC連接的url
            String url = "jdbc:mysql://localhost:3306/itcast";
            String username = "root";
            String password = "root";
            // 第三步 創(chuàng)建數(shù)據(jù)庫的連接
            conn = DriverManager.getConnection(url, username, password);
            // 第四步 創(chuàng)建一個(gè)statement對象
            stmt = conn.createStatement();
            // 第五步 執(zhí)行sql語句
            String sql = "insert into student values(0,'七月1',23,'男')";
            String sq2 = "insert into student values(0,'八月1',32,'男')";
            stmt.addBatch(sql);
            stmt.addBatch(sq2);
            stmt.executeBatch();
        }catch(ClassNotFoundException e) {
            e.printStackTrace();
            System.out.println("ClassNotFoundException");
            // 還要進(jìn)行寫入日志等操作 所以要分開兩個(gè)異常類別 都要 catch 
        }catch(SQLException e) {
            e.printStackTrace();
            System.out.println("SQLException");
        }finally{
            try{
                // 第六步 關(guān)閉JDBC對象
                if(stmt != null) {
                    stmt.close();
                }
                if(conn != null) {
                    conn.close();
                }
            }catch(SQLException e) {
                e.printStackTrace();
            }
        }
    }
}

此方法中關(guān)鍵語句:

     // 執(zhí)行sql語句
     String sql = "insert into student values(0,'七月1',23,'男')";
     String sq2 = "insert into student values(0,'八月1',32,'男')";
     stmt.addBatch(sql);
     stmt.addBatch(sq2);
     stmt.executeBatch();

用Statement對象中的addBatch() 函數(shù)方法將SQL命令語句都添加到Batch中 然后用executeBatch() 方法整體將Batch 中的語句提交給數(shù)據(jù)庫管理系統(tǒng)。

添加兩條數(shù)據(jù)成功:


添加兩條數(shù)據(jù)成功.png

注:
我們可以使用Statement對象用來做測試 但是在生產(chǎn)環(huán)境下一定要考慮使用 PreparedStatement(見下)


下午

學(xué)習(xí)了 PreparedStatement 對象,用其可以使得update數(shù)據(jù)更靈活:

import java.sql.*;

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

        Connection conn = null;
        PreparedStatement pstmt = null;
        
        try{
            // 第一步 先加載JDBC的驅(qū)動類
            Class.forName("com.mysql.jdbc.Driver");
            // 第二步 提供JDBC連接的url
            String url = "jdbc:mysql://localhost:3306/itcast";
            String username = "root";
            String password = "root";
            // 第三步 創(chuàng)建數(shù)據(jù)庫的連接
            conn = DriverManager.getConnection(url, username, password);
            // 第四步 創(chuàng)建一個(gè)statement對象
            String sql = "insert into student values(?,?,?,?)";
            pstmt = conn.prepareStatement(sql);
            // 第五步 執(zhí)行sql語句
            pstmt.setInt(1,8);
            pstmt.setString(2,"nihao");
            pstmt.setFloat(3, 55);
            pstmt.setString(4,"男");
            
            pstmt.executeUpdate();
        }catch(ClassNotFoundException e) {
            e.printStackTrace();
            System.out.println("ClassNotFoundException");
            // 還要進(jìn)行寫入日志等操作 所以要分開兩個(gè)異常類別 都要 catch 
        }catch(SQLException e) {
            e.printStackTrace();
            System.out.println("SQLException");
        }finally{
            try{
                // 第六步 關(guān)閉JDBC對象
                if(pstmt != null) {
                    pstmt.close();
                }
                if(conn != null) {
                    conn.close();
                }
            }catch(SQLException e) {
                e.printStackTrace();
            }
        }
    }
}

PreparedStatement 批量insert數(shù)據(jù):

import java.sql.*;

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

        Connection conn = null;
        PreparedStatement pstmt = null;

        try{
            // 第一步 先加載JDBC的驅(qū)動類
            Class.forName("com.mysql.jdbc.Driver");
            // 第二步 提供JDBC連接的url
            String url = "jdbc:mysql://localhost:3306/itcast";
            String username = "root";
            String password = "root";
            // 第三步 創(chuàng)建數(shù)據(jù)庫的連接
            conn = DriverManager.getConnection(url, username, password);
            // 第四步 創(chuàng)建一個(gè)statement對象
            String sql = "insert into student values(?,?,?,?)";
            pstmt = conn.prepareStatement(sql);
            // 第五步 執(zhí)行sql語句
            pstmt.setInt(1,9);
            pstmt.setString(2,"9");
            pstmt.setFloat(3, 55);
            pstmt.setString(4,"男");
            pstmt.addBatch();
            
            pstmt.setInt(1,10);
            pstmt.setString(2,"10");
            pstmt.setFloat(3, 68);
            pstmt.setString(4,"男");
            pstmt.addBatch();
            
            pstmt.executeBatch();
        }catch(ClassNotFoundException e) {
            e.printStackTrace();
            System.out.println("ClassNotFoundException");
            // 還要進(jìn)行寫入日志等操作 所以要分開兩個(gè)異常類別 都要 catch 
        }catch(SQLException e) {
            e.printStackTrace();
            System.out.println("SQLException");
        }finally{
            try{
                // 第六步 關(guān)閉JDBC對象
                if(pstmt != null) {
                    pstmt.close();
                }
                if(conn != null) {
                    conn.close();
                }
            }catch(SQLException e) {
                e.printStackTrace();
            }
        }
    }
}

PreparedStatement 查詢:

import java.sql.*;

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

        Connection conn = null;
        PreparedStatement pstmt = null;
        ResultSet rs = null;
        
        try{
            // 第一步 先加載JDBC的驅(qū)動類
            Class.forName("com.mysql.jdbc.Driver");
            // 第二步 提供JDBC連接的url
            String url = "jdbc:mysql://localhost:3306/itcast";
            String username = "root";
            String password = "root";
            // 第三步 創(chuàng)建數(shù)據(jù)庫的連接
            conn = DriverManager.getConnection(url, username, password);
            // 第四步 創(chuàng)建一個(gè)statement對象
            String sql = "select * from student";
            pstmt = conn.prepareStatement(sql);
            // 第五步 執(zhí)行sql語句 獲取結(jié)果集合
            rs = pstmt.executeQuery();
            // 第六步 循環(huán)遍歷處理結(jié)果
            while(rs.next()){
                System.out.println(rs.getInt("id"));
                System.out.println(rs.getString("name"));
                System.out.println(rs.getInt("age"));
            }
        }catch(ClassNotFoundException e) {
            e.printStackTrace();
            System.out.println("ClassNotFoundException");
            // 還要進(jìn)行寫入日志等操作 所以要分開兩個(gè)異常類別 都要 catch 
        }catch(SQLException e) {
            e.printStackTrace();
            System.out.println("SQLException");
        }finally{
            try{
                // 第七步 關(guān)閉JDBC對象
                if(pstmt != null) {
                    pstmt.close();
                }
                if(conn != null) {
                    conn.close();
                }
            }catch(SQLException e) {
                e.printStackTrace();
            }
        }
    }
}

注意PreparedStatement 和 Statement 創(chuàng)建一個(gè)statement對象(第4步) 和 執(zhí)行sql語句(第5步)語句的區(qū)別:

Statement:

String sql = "select * from student";
// 第四步 創(chuàng)建一個(gè)statement對象
stmt = conn.createStatement();
// 第五步 執(zhí)行sql語句
rs = stmt.executeQuery(sql);

PreparedStatement:

String sql = "select * from student";
// 第四步 創(chuàng)建一個(gè)statement對象
pstmt = conn.prepareStatement(sql);
// 第五步 執(zhí)行sql語句 獲取結(jié)果集合
rs = pstmt.executeQuery();

PreparedStatement優(yōu)勢絕不僅僅是更靈活的參數(shù)化查詢
請參見:PreparedStatement VS Statement


拓展閱讀:

1 - 通過JDBC進(jìn)行簡單的增刪改查(以MySQL為例)
2 - JDBC詳解

世界上所有的追求都是因?yàn)闊釔?br> 一枚愛編碼 愛生活 愛分享的IT信徒
— hongXkeX

最后編輯于
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
【社區(qū)內(nèi)容提示】社區(qū)部分內(nèi)容疑似由AI輔助生成,瀏覽時(shí)請結(jié)合常識與多方信息審慎甄別。
平臺聲明:文章內(nèi)容(如有圖片或視頻亦包括在內(nèi))由作者上傳并發(fā)布,文章內(nèi)容僅代表作者本人觀點(diǎn),簡書系信息發(fā)布平臺,僅提供信息存儲服務(wù)。

相關(guān)閱讀更多精彩內(nèi)容

  • JDBC概述 在Java中,數(shù)據(jù)庫存取技術(shù)可分為如下幾類:JDBC直接訪問數(shù)據(jù)庫、JDO技術(shù)、第三方O/R工具,如...
    usopp閱讀 3,639評論 3 75
  • 1. Java基礎(chǔ)部分 基礎(chǔ)部分的順序:基本語法,類相關(guān)的語法,內(nèi)部類的語法,繼承相關(guān)的語法,異常的語法,線程的語...
    子非魚_t_閱讀 34,642評論 18 399
  • 1. 簡介 1.1 什么是 MyBatis ? MyBatis 是支持定制化 SQL、存儲過程以及高級映射的優(yōu)秀的...
    笨鳥慢飛閱讀 6,226評論 0 4
  • 西江月三首 胭脂雪 西江月·整裝待發(fā)游長隆 場上妖嬈舞曲,耳邊繾綣清風(fēng)。曦陽明凈照歡容,更有鳴蟬相送。 往寄多情山...
    胭脂雪er閱讀 501評論 0 0
  • 1、let, const, class, extends, super, arrow functions, tem...
    逍遙g閱讀 444評論 0 1

友情鏈接更多精彩內(nèi)容