《mysql篇》--JDBC编程

MySQL与JDBC编程

Java数据库连接（JDBC）是Java语言中用于与数据库进行交互的API。通过JDBC，Java程序能够连接到数据库，执行SQL查询，并处理结果集。本文将以MySQL数据库为例，介绍如何使用JDBC进行数据库操作。

一、环境准备

在开始编程之前，确保你已经安装了MySQL数据库和JDK环境。此外，需要下载MySQL的JDBC驱动，通常是一个名为 mysql-connector-java-x.x.x.jar 的JAR文件。将该JAR文件包含在你的Java项目的类路径中。

二、JDBC基本流程

使用JDBC访问MySQL数据库的一般步骤如下：

1. 导入JDBC包。
2. 注册JDBC驱动。
3. 建立数据库连接。
4. 创建数据库操作对象。
5. 执行SQL语句。
6. 处理结果集。
7. 关闭连接。

三、示例代码

以下是一个简单的示例，展示如何使用JDBC连接MySQL数据库，并进行增、查操作。

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

public class MySQLJDBCExample {
    // 数据库URL，用户名和密码
    static final String DB_URL = "jdbc:mysql://localhost:3306/your_database_name";
    static final String USER = "your_username";
    static final String PASSWORD = "your_password";

    public static void main(String[] args) {
        Connection connection = null;
        PreparedStatement preparedStatement = null;
        ResultSet resultSet = null;

        try {
            // 1. 注册JDBC驱动
            Class.forName("com.mysql.cj.jdbc.Driver");

            // 2. 建立数据库连接
            connection = DriverManager.getConnection(DB_URL, USER, PASSWORD);
            System.out.println("数据库连接成功！");

            // 3. 执行插入操作
            String insertSQL = "INSERT INTO users (name, age) VALUES (?, ?)";
            preparedStatement = connection.prepareStatement(insertSQL);
            preparedStatement.setString(1, "张三");
            preparedStatement.setInt(2, 25);
            int rowsInserted = preparedStatement.executeUpdate();
            if (rowsInserted > 0) {
                System.out.println("插入成功！");
            }

            // 4. 执行查询操作
            String querySQL = "SELECT * FROM users";
            preparedStatement = connection.prepareStatement(querySQL);
            resultSet = preparedStatement.executeQuery();

            // 5. 处理结果集
            while (resultSet.next()) {
                int id = resultSet.getInt("id");
                String name = resultSet.getString("name");
                int age = resultSet.getInt("age");
                System.out.println("用户ID: " + id + ", 姓名: " + name + ", 年龄: " + age);
            }

        } catch (ClassNotFoundException e) {
            System.out.println("JDBC驱动未找到！");
            e.printStackTrace();
        } catch (SQLException e) {
            System.out.println("数据库操作错误！");
            e.printStackTrace();
        } finally {
            // 6. 关闭连接
            try {
                if (resultSet != null) resultSet.close();
                if (preparedStatement != null) preparedStatement.close();
                if (connection != null) connection.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }
}

四、代码解析

1. 导入JDBC包：使用 import java.sql.* 导入所有需要的JDBC类。
2. 数据库连接：使用 DriverManager.getConnection() 方法建立与数据库的连接，并通过URL、用户名和密码来鉴权。
3. 执行SQL语句：通过 PreparedStatement 对象执行插入和查询操作。使用 executeUpdate() 方法执行SQL DML语句（如INSERT、UPDATE、DELETE），使用 executeQuery() 方法执行SQL查询（SELECT语句），并返回 ResultSet 结果集。
4. 处理结果集：遍历 ResultSet 以获取查询结果。
5. 关闭连接：在finally块中关闭数据库连接、预处理语句和结果集，以避免资源泄漏。

五、总结

通过以上示例，我们可以看出，JDBC为Java与MySQL数据库的交互提供了强大的支持。掌握JDBC的使用方法后，我们就能够在Java应用中灵活地执行各种数据库操作。随着对JDBC的深入学习，可以扩展为更复杂的应用，例如使用连接池、事务处理等。希望本篇文章对你理解JDBC编程有所帮助！