使用Java連接MySQL數據庫

Java是一種面向對象的編程語言，它既可以開發桌面應用程序，也可以開發Web應用程序。其中，連接數據庫是Java應用程序中常用的一個功能。MySQL是一種流行的關係型數據庫，本文介紹如何使用Java連接MySQL數據庫。

一、環境準備

在開始使用Java連接MySQL數據庫之前，需要先做一些環境準備：

1、下載並安裝MySQL：從MySQL官網上下載，安裝後啟動MySQL服務。

2、下載並安裝Java開發工具包（JDK）：從Oracle官網下載，並配置環境變量。

3、下載並添加MySQL的JDBC驅動器：下載地址為http://dev.mysql.com/downloads/connector/j/，將其中的mysql-connector-java-x.x.xx.jar文件添加到classpath中。

二、連接MySQL數據庫

下面是一個簡單的Java程序，用於連接MySQL數據庫：

import java.sql.*;

public class MySQLDemo {
    public static void main(String[] args) {
        Connection conn = null;
        Statement stmt = null;
        try {
            //連接MySQL數據庫
            Class.forName("com.mysql.jdbc.Driver");
            conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/test", "用戶名", "密碼");
            System.out.println("連接成功！");

            //執行SQL查詢
            stmt = conn.createStatement();
            ResultSet rs = stmt.executeQuery("SELECT * FROM user");
            while (rs.next()) {
                System.out.println(rs.getInt("id") + "\t" + rs.getString("name") + "\t" + rs.getInt("age"));
            }
        } catch (ClassNotFoundException e) {
            System.out.println("ClassNotFoundException：" + e.getMessage());
        } catch (SQLException e) {
            System.out.println("SQLException：" + e.getMessage());
        } finally {
            try {
                if (stmt != null) stmt.close();
                if (conn != null) conn.close();
            } catch (SQLException e) {
                System.out.println("SQLException：" + e.getMessage());
            }
        }
    }
}

上述程序包含以下幾個步驟：

1、加載JDBC驅動器：在程序代碼中加載MySQL的JDBC驅動器，使用Class.forName()方法。

2、連接MySQL數據庫：使用DriverManager.getConnection()方法連接MySQL數據庫，需要傳入數據庫URL、用戶名和密碼。

3、執行SQL查詢：通過Connection對象創建Statement對象，並使用executeQuery()方法執行SELECT查詢語句。

4、關閉資源：在finally塊中關閉Statement和Connection對象。

三、支持事務處理

MySQL支持事務處理，Java程序也可以通過JDBC API實現對MySQL的事務處理。下面是一個示例代碼：

import java.sql.*;

public class MySQLTransactionDemo {
    public static void main(String[] args) {
        Connection conn = null;
        Statement stmt = null;
        try {
            //連接MySQL數據庫
            Class.forName("com.mysql.jdbc.Driver");
            conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/test", "用戶名", "密碼");
            System.out.println("連接成功！");

            //開啟事務處理
            conn.setAutoCommit(false);

            //執行SQL插入語句
            stmt = conn.createStatement();
            stmt.executeUpdate("INSERT INTO user(name, age) VALUES('張三', 20)");
            stmt.executeUpdate("INSERT INTO user(name, age) VALUES('李四', 22)");

            //提交事務
            conn.commit();

            System.out.println("插入成功！");
        } catch (ClassNotFoundException e) {
            System.out.println("ClassNotFoundException：" + e.getMessage());
        } catch (SQLException e) {
            //回滾事務
            try {
                if (conn != null) conn.rollback();
            } catch (SQLException ex) {
                System.out.println("SQLException：" + ex.getMessage());
            }
            System.out.println("SQLException：" + e.getMessage());
        } finally {
            try {
                if (stmt != null) stmt.close();
                if (conn != null) conn.close();
            } catch (SQLException e) {
                System.out.println("SQLException：" + e.getMessage());
            }
        }
    }
}

在上述示例代碼中，我們調用了Connection對象的setAutoCommit(false)方法，將自動提交事務關閉。之後，我們執行了兩個SQL插入語句，如果其中一個插入失敗，則會執行rollback()方法回滾之前的操作。如果兩個插入操作都成功，則執行commit()方法提交事務。

四、使用連接池

為了提高應用程序的性能和可靠性，使用連接池是一個不錯的選擇。連接池允許程序重複利用現有的數據庫連接，而不是每次都創建新的連接。下面是一個使用連接池的示例代碼：

import java.sql.*;
import org.apache.commons.dbcp2.*;

public class MySQLPoolDemo {
    public static void main(String[] args) {
        Connection conn = null;
        try {
            //創建連接池
            BasicDataSource ds = new BasicDataSource();
            ds.setDriverClassName("com.mysql.jdbc.Driver");
            ds.setUrl("jdbc:mysql://localhost:3306/test");
            ds.setUsername("用戶名");
            ds.setPassword("密碼");

            //獲取連接
            conn = ds.getConnection();
            System.out.println("連接成功！");

            //執行SQL查詢
            Statement stmt = conn.createStatement();
            ResultSet rs = stmt.executeQuery("SELECT * FROM user");
            while (rs.next()) {
                System.out.println(rs.getInt("id") + "\t" + rs.getString("name") + "\t" + rs.getInt("age"));
            }

            //釋放連接
            conn.close();
            System.out.println("已釋放連接！");
        } catch (SQLException e) {
            System.out.println("SQLException：" + e.getMessage());
        }
    }
}

使用連接池的主要步驟如下：

1、導入連接池的jar包：本示例中使用了Apache Commons DBCP連接池。

2、創建連接池：使用BasicDataSource類創建連接池，並設置數據庫URL、用戶名和密碼。

3、獲取連接：使用ds.getConnection()方法獲取連接。

4、執行SQL查詢：通過Connection對象創建Statement對象，並使用executeQuery()方法執行SELECT查詢語句。

5、釋放連接：在finally塊中關閉Connection對象。

總結

本文介紹了如何使用Java連接MySQL數據庫。我們講解了基本的連接MySQL數據庫的步驟，以及如何支持事務處理和使用連接池。這些知識點是Java應用程序開發中非常重要的一部分，希望本文能夠給Java初學者提供幫助。