Java連接MySQL資料庫示例

一、準備工作

在進行Java連接MySQL資料庫之前，需要進行一些準備工作：

1、下載MySQL驅動包

可以到MySQL官網下載最新的MySQL Connector/J驅動包。下載完畢後，將其解壓縮到本地磁碟中。

2、安裝MySQL伺服器

在安裝伺服器時，需要給伺服器設置一個賬號和密碼。這個賬號和密碼將用於在Java程序中連接MySQL伺服器。

3、創建資料庫

在MySQL中，可以通過命令行或者其他MySQL查詢工具創建資料庫。在創建完畢後，需要記住資料庫的名稱。

二、連接MySQL資料庫

在Java中連接MySQL資料庫需要先載入MySQL驅動程序，然後根據資料庫連接信息創建連接對象，並建立連接。以下是具體實現：

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

public class MySQLConnectionExample {

    public static void main(String[] args) {
        Connection conn = null;
        try {
            Class.forName("com.mysql.jdbc.Driver");
            conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/testdb", "username", "password");
            if(conn != null) {
                System.out.println("Connected to the database");
            }
        } catch (SQLException ex) {
            System.out.println("An error occurred while connecting MySQL database");
            ex.printStackTrace();
        } catch (ClassNotFoundException ex) {
            System.out.println("MySQL Driver not found");
            ex.printStackTrace();
        }
    }
}

其中，conn = DriverManager.getConnection(url, user, password)方法用於建立與MySQL資料庫的連接，方法的三個參數分別表示連接URL、MySQL資料庫連接用戶名和密碼。在連接MySQL資料庫之前，需要先通過Class.forName()方法註冊MySQL驅動程序。

三、關閉連接對象

連接MySQL資料庫後，需要關閉連接對象，以釋放資源。以下是具體實現：

...
finally {
    if(conn != null) {
        try {
            conn.close();
        } catch (SQLException ex) {
            ex.printStackTrace();
        }
    }
}
...

在finally模塊中關閉連接對象，並釋放資源。

四、執行SQL語句

連接MySQL資料庫之後，可以通過Java程序執行SQL語句。以下是具體實現：

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

public class MySQLQueryExample {

    public static void main(String[] args) {
        Connection conn = null;
        Statement stmt = null;
        ResultSet rs = null;
        
        try {
            Class.forName("com.mysql.jdbc.Driver");
            conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/testdb", "username", "password");
            if(conn != null) {
                System.out.println("Connected to the database");
            }
            
            stmt = conn.createStatement();
            rs = stmt.executeQuery("SELECT employee_id, first_name, last_name FROM employees");
            while (rs.next()) {
                System.out.println(rs.getString("employee_id") + "  " +
                                   rs.getString("first_name") + "  " + rs.getString("last_name"));
            }
        } catch (SQLException ex) {
            System.out.println("An error occurred while connecting MySQL database");
            ex.printStackTrace();
        } catch (ClassNotFoundException ex) {
            System.out.println("MySQL Driver not found");
            ex.printStackTrace();
        } finally {
            if(rs != null) {
                try {
                    rs.close();
                } catch (SQLException ex) {
                    ex.printStackTrace();
                }
            }
            if(stmt != null) {
                try {
                    stmt.close();
                } catch (SQLException ex) {
                    ex.printStackTrace();
                }
            }
            if(conn != null) {
                try {
                    conn.close();
                } catch (SQLException ex) {
                    ex.printStackTrace();
                }
            }
        }
    }
}

在此處，通過stmt.executeQuery(sql)方法執行查詢SQL語句，並將查詢結果存儲在ResultSet對象rs中。使用rs.next()方法遍歷查詢結果。在查詢完畢後，需要關閉Statement對象和ResultSet對象，釋放資源。

五、數據表處理

在MySQL資料庫中，可以通過Java程序創建數據表，也可以對數據表進行增、刪、改、查等操作。以下是一個簡單的數據表處理程序：

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

public class MySQLTableExample {

    public static void main(String[] args) {
        Connection conn = null;
        Statement stmt = null;
        
        try {
            Class.forName("com.mysql.jdbc.Driver");
            conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/testdb", "username", "password");
            if(conn != null) {
                System.out.println("Connected to the database");
            }
            
            stmt = conn.createStatement();
            String sql = "CREATE TABLE employees " +
                        "(id INTEGER not NULL, " +
                        " first_name VARCHAR(255), " +
                        " last_name VARCHAR(255), " +
                        " age INTEGER, " +
                        " PRIMARY KEY ( id ))";
            stmt.executeUpdate(sql);
            System.out.println("Table created successfully...");
        } catch (SQLException ex) {
            System.out.println("An error occurred while connecting MySQL database");
            ex.printStackTrace();
        } catch (ClassNotFoundException ex) {
            System.out.println("MySQL Driver not found");
            ex.printStackTrace();
        } finally {
            if(stmt != null) {
                try {
                    stmt.close();
                } catch (SQLException ex) {
                    ex.printStackTrace();
                }
            }
            if(conn != null) {
                try {
                    conn.close();
                } catch (SQLException ex) {
                    ex.printStackTrace();
                }
            }
        }
    }
}

在此處，通過stmt.executeUpdate(sql)方法創建數據表，並在數據表中定義了ID、Name、Age三個欄位。執行完畢後，關閉Statement對象和Connection對象，釋放資源。

六、小結

Java連接MySQL資料庫需要先下載MySQL驅動包，安裝MySQL伺服器，並創建資料庫。然後，通過Java程序實現連接MySQL資料庫、執行SQL語句和數據表處理等操作。