怎么使用MySQL进行JDBC编程与增删改查

1. 概述

JDBC（Java Database Connectivity）是Java语言中用于与数据库进行交互的API。通过JDBC，Java程序可以连接到各种关系型数据库，并执行SQL语句进行数据的增删改查操作。本文将介绍如何使用JDBC连接MySQL数据库，并进行基本的增删改查操作。

2. 准备工作

在开始之前，确保你已经完成以下准备工作：

1. 安装MySQL数据库：确保你已经安装并配置好了MySQL数据库。
2. 下载MySQL JDBC驱动：从MySQL官网下载JDBC驱动（mysql-connector-java），并将其添加到项目的类路径中。
3. 创建数据库和表：在MySQL中创建一个数据库和一张表，用于后续的操作。

假设你已经创建了一个名为testdb的数据库，并在其中创建了一张名为users的表，表结构如下：

CREATE TABLE users (
    id INT PRIMARY KEY AUTO_INCREMENT,
    name VARCHAR(50) NOT NULL,
    email VARCHAR(50) NOT NULL
);

3. JDBC编程步骤

3.1 加载JDBC驱动

在使用JDBC之前，首先需要加载MySQL的JDBC驱动。可以通过Class.forName()方法来加载驱动。

Class.forName("com.mysql.cj.jdbc.Driver");

3.2 建立数据库连接

使用DriverManager.getConnection()方法建立与MySQL数据库的连接。需要提供数据库的URL、用户名和密码。

String url = "jdbc:mysql://localhost:3306/testdb";
String username = "root";
String password = "password";

Connection connection = DriverManager.getConnection(url, username, password);

3.3 创建Statement对象

通过Connection对象创建Statement对象，用于执行SQL语句。

Statement statement = connection.createStatement();

3.4 执行SQL语句

使用Statement对象执行SQL语句。常见的操作包括插入（INSERT）、查询（SELECT）、更新（UPDATE）和删除（DELETE）。

3.4.1 插入数据

String insertSQL = "INSERT INTO users (name, email) VALUES ('John Doe', 'john.doe@example.com')";
int rowsInserted = statement.executeUpdate(insertSQL);
System.out.println(rowsInserted + " row(s) inserted.");

3.4.2 查询数据

String selectSQL = "SELECT * FROM users";
ResultSet resultSet = statement.executeQuery(selectSQL);

while (resultSet.next()) {
    int id = resultSet.getInt("id");
    String name = resultSet.getString("name");
    String email = resultSet.getString("email");
    System.out.println("ID: " + id + ", Name: " + name + ", Email: " + email);
}

3.4.3 更新数据

String updateSQL = "UPDATE users SET email = 'john.doe.new@example.com' WHERE id = 1";
int rowsUpdated = statement.executeUpdate(updateSQL);
System.out.println(rowsUpdated + " row(s) updated.");

3.4.4 删除数据

String deleteSQL = "DELETE FROM users WHERE id = 1";
int rowsDeleted = statement.executeUpdate(deleteSQL);
System.out.println(rowsDeleted + " row(s) deleted.");

3.5 关闭连接

在完成数据库操作后，需要关闭ResultSet、Statement和Connection对象，以释放资源。

resultSet.close();
statement.close();
connection.close();

4. 完整示例代码

以下是一个完整的Java程序示例，展示了如何使用JDBC连接MySQL数据库，并进行增删改查操作。

import java.sql.*;

public class JDBCExample {
    public static void main(String[] args) {
        Connection connection = null;
        Statement statement = null;
        ResultSet resultSet = null;

        try {
            // 加载JDBC驱动
            Class.forName("com.mysql.cj.jdbc.Driver");

            // 建立数据库连接
            String url = "jdbc:mysql://localhost:3306/testdb";
            String username = "root";
            String password = "password";
            connection = DriverManager.getConnection(url, username, password);

            // 创建Statement对象
            statement = connection.createStatement();

            // 插入数据
            String insertSQL = "INSERT INTO users (name, email) VALUES ('John Doe', 'john.doe@example.com')";
            int rowsInserted = statement.executeUpdate(insertSQL);
            System.out.println(rowsInserted + " row(s) inserted.");

            // 查询数据
            String selectSQL = "SELECT * FROM users";
            resultSet = statement.executeQuery(selectSQL);

            while (resultSet.next()) {
                int id = resultSet.getInt("id");
                String name = resultSet.getString("name");
                String email = resultSet.getString("email");
                System.out.println("ID: " + id + ", Name: " + name + ", Email: " + email);
            }

            // 更新数据
            String updateSQL = "UPDATE users SET email = 'john.doe.new@example.com' WHERE id = 1";
            int rowsUpdated = statement.executeUpdate(updateSQL);
            System.out.println(rowsUpdated + " row(s) updated.");

            // 删除数据
            String deleteSQL = "DELETE FROM users WHERE id = 1";
            int rowsDeleted = statement.executeUpdate(deleteSQL);
            System.out.println(rowsDeleted + " row(s) deleted.");

        } catch (ClassNotFoundException | SQLException e) {
            e.printStackTrace();
        } finally {
            // 关闭连接
            try {
                if (resultSet != null) resultSet.close();
                if (statement != null) statement.close();
                if (connection != null) connection.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }
}

5. 总结

通过JDBC，Java程序可以方便地与MySQL数据库进行交互，执行各种SQL操作。本文介绍了JDBC编程的基本步骤，包括加载驱动、建立连接、执行SQL语句以及关闭连接。通过掌握这些基本操作，你可以进一步扩展和优化你的数据库应用程序。