四万字详解：Java 开发中使用 JDBC 技术操作 MySQL 数据库

2023-09-19 05:23:55

JDBC：Java 中连接数据库的桥梁

在 Java 开发领域，连接和操作数据库是不可避免的。JDBC（Java Database Connectivity）技术成为 Java 程序与数据库世界之间的桥梁，提供了一种通用的方式来访问和操纵各种数据库，如 MySQL、Oracle 和 SQL Server。

JDBC 技术简介

JDBC 是一种 Java API，它提供了一组与数据库无关的接口，使 Java 程序能够连接、查询和修改数据库数据。JDBC 的优点在于它的跨平台性、可移植性、安全性以及与各种数据库的兼容性。

JDBC 基本步骤

连接和操作数据库的 JDBC 基本步骤如下：

导入 JDBC 驱动： 导入特定数据库的 JDBC 驱动程序包，例如 mysql-connector-java。
建立数据库连接： 使用 DriverManager 类建立与数据库的连接。
创建 Statement 对象： 用来执行 SQL 查询或更新。
执行 SQL 语句： 使用 Statement 对象执行 SQL 查询或更新，并获取结果。
处理结果： 遍历结果集，获取数据并进行处理。
关闭数据库连接： 最后释放资源并关闭数据库连接。

JDBC 常用方法

JDBC 提供了丰富的 API 方法，用于对数据库进行操作，包括：

executeQuery()： 执行 SQL 查询并返回结果集。
executeUpdate()： 执行 SQL 更新语句，例如插入、更新或删除，并返回受影响的行数。
addBatch()： 将 SQL 语句添加到批处理中。
executeBatch()： 执行批处理中的所有 SQL 语句。
getConnection()： 获取数据库连接。
createStatement()： 创建 Statement 对象。
prepareStatement()： 创建 PreparedStatement 对象，用于预编译 SQL 语句。
close()： 关闭数据库连接或 Statement 对象。

代码示例

以下是一个连接 MySQL 数据库并执行查询的代码示例：

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

public class JDBCExample {

    public static void main(String[] args) {
        // 数据库连接参数
        String url = "jdbc:mysql://localhost:3306/mydb";
        String user = "root";
        String password = "mypassword";

        // 建立数据库连接
        Connection connection = null;
        try {
            connection = DriverManager.getConnection(url, user, password);
        } catch (SQLException e) {
            System.out.println("连接数据库失败：" + e.getMessage());
            return;
        }

        // 创建 Statement 对象
        Statement statement = null;
        try {
            statement = connection.createStatement();
        } catch (SQLException e) {
            System.out.println("创建 Statement 对象失败：" + e.getMessage());
            return;
        }

        // 执行 SQL 查询
        ResultSet resultSet = null;
        try {
            resultSet = statement.executeQuery("SELECT * FROM users");
        } catch (SQLException e) {
            System.out.println("执行 SQL 查询失败：" + e.getMessage());
            return;
        }

        // 处理结果集
        try {
            while (resultSet.next()) {
                System.out.println("ID: " + resultSet.getInt("id"));
                System.out.println("用户名: " + resultSet.getString("username"));
            }
        } catch (SQLException e) {
            System.out.println("处理结果集失败：" + e.getMessage());
            return;
        }

        // 关闭数据库连接
        try {
            resultSet.close();
            statement.close();
            connection.close();
        } catch (SQLException e) {
            System.out.println("关闭数据库连接失败：" + e.getMessage());
        }
    }
}