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語句和數據表處理等操作。