JDBC訪問數據庫

JDBC(Java Database Connectivity)是Java中用於連接各種關係型數據庫的API。通過JDBC，我們可以實現對數據庫的增、刪、改、查等操作，以及與數據庫進行通信，獲取數據並進行處理。本文將以JDBC訪問數據庫為中心，從多個方面對其做詳細闡述。

一、JDBC基本概念

JDBC是Java SE中的標準API，它提供了一套用於訪問關係型數據庫的統一接口。我們只需要使用Java代碼編寫訪問數據庫的邏輯，而無需關心數據庫具體的種類和結構。

JDBC的主要組成部分有如下幾個:

• DriverManager：JDBC驅動程序的管理類，負責建立與數據庫的連接。
• Driver：JDBC驅動程序接口，提供了與特定數據庫進行通信的方法。
• Connection：數據庫的連接對象，用於建立Java程序與數據庫之間的通信。
• Statement：用於執行SQL語句的接口，並返回處理結果。
• ResultSet：表示數據庫查詢產生的結果集。

二、連接數據庫

在使用JDBC訪問數據庫之前，我們需要先連接到數據庫。連接過程主要分為下面幾步：

1. 加載數據庫驅動程序
2. 建立連接
3. 執行SQL語句
4. 關閉連接

下面是連接到MySQL數據庫的完整示例代碼：

import java.sql.*;

public class ConnectToMySql {
    public static void main(String[] args) {
        // 1.加載數據庫驅動程序
        try {
            Class.forName("com.mysql.jdbc.Driver");
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        }
        // 2.建立連接
        String url = "jdbc:mysql://127.0.0.1:3306/test";
        String user = "root";
        String password = "123456";
        try {
            Connection connection = DriverManager.getConnection(url, user, password);
            // 3.執行SQL語句
            Statement statement = connection.createStatement();
            String sql = "INSERT INTO user(name, age) VALUES ('Tom', 18)";
            int rows = statement.executeUpdate(sql);
            if(rows > 0){
                System.out.println("插入成功!");
            }else{
                System.out.println("插入失敗!");
            }
            // 4.關閉連接
            statement.close();
            connection.close();
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}

三、執行SQL語句

執行SQL語句是JDBC訪問數據庫的核心部分。JDBC提供了三種執行SQL語句的方式：Statement、PreparedStatement和CallableStatement。其中，Statement是最簡單的一種，用於執行靜態SQL語句，例如：插入、修改、刪除等操作。而PreparedStatement並不是用於執行靜態SQL語句，而是預編譯了某個SQL語句，在程序運行時只需要傳遞參數即可執行該語句。而CallableStatement則是用於調用存儲過程，可以帶有輸入、輸出參數。

下面是使用PreparedStatement執行插入數據的示例代碼：

import java.sql.*;

public class InsertData {
    public static void main(String[] args) {
        String url = "jdbc:mysql://127.0.0.1:3306/test";
        String user = "root";
        String password = "123456";
        try {
            Connection connection = DriverManager.getConnection(url, user, password);
            String sql = "INSERT INTO user(name, age) VALUES (?, ?)";
            PreparedStatement preparedStatement = connection.prepareStatement(sql);
            preparedStatement.setString(1, "Tom");
            preparedStatement.setInt(2, 18);
            int rows = preparedStatement.executeUpdate();
            if(rows > 0){
                System.out.println("插入成功!");
            }else{
                System.out.println("插入失敗!");
            }
            preparedStatement.close();
            connection.close();
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}

四、處理ResultSet

ResultSet是JDBC返回的查詢結果集，在訪問數據庫時，我們通常需要獲取到查詢的數據結果，並對其進行處理。ResultSet提供了多種獲取查詢結果的方法，比如getInt()、getString()等等。下面是獲取查詢數據並輸出的示例代碼：

import java.sql.*;

public class SelectData {
    public static void main(String[] args) {
        String url = "jdbc:mysql://127.0.0.1:3306/test";
        String user = "root";
        String password = "123456";
        try {
            Connection connection = DriverManager.getConnection(url, user, password);
            String sql = "SELECT name, age FROM user";
            Statement statement = connection.createStatement();
            ResultSet resultSet = statement.executeQuery(sql);
            while(resultSet.next()){
                String name = resultSet.getString("name");
                int age = resultSet.getInt("age");
                System.out.println("name: " + name + ", age: " + age);
            }
            resultSet.close();
            statement.close();
            connection.close();
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}

五、異常處理

JDBC在執行SQL語句時，如果出現異常，需要根據異常類型進行相應的處理，防止程序中斷。JDBC提供了SQLException類，用於捕獲SQL執行過程中拋出的異常。下面是捕獲SQLException異常的示例代碼：

import java.sql.*;

public class ExceptionHandler {
    public static void main(String[] args) {
        String url = "jdbc:mysql://127.0.0.1:3306/test";
        String user = "root";
        String password = "123456";
        try {
            Connection connection = DriverManager.getConnection(url, user, password);
            String sql = "INSERT INTO user(name, age) VALUES ('Tom', 'abc')";
            Statement statement = connection.createStatement();
            try {
                int rows = statement.executeUpdate(sql);
                if(rows > 0){
                    System.out.println("插入成功!");
                }else{
                    System.out.println("插入失敗!");
                }
            } catch (SQLException e) {
                // SQL執行出錯了
                System.out.println(e.getMessage());
            }finally {
                statement.close();
                connection.close();
            }
        } catch (SQLException e) {
            // 連接數據庫出錯了
            e.printStackTrace();
        }
    }
}

六、總結

通過本文的介紹，我們可以看出，JDBC是Java中非常重要的一個API，可以用於訪問多種類型的關係型數據庫。在使用JDBC訪問數據庫時，必須先連接到數據庫，然後執行SQL語句，並對返回結果進行處理。同時，異常處理也是JDBC編程中一個不可忽視的問題。學習和掌握JDBC訪問數據庫的技能，對於Java後端開發人員來說具有重要意義。