Java数据库连接如何使用JDBC API？

Java 数据库连接 (JDBC) 是用于 Java 程序与数据库交互的 API。要建立 JDBC 连接，需要：1. 导入 JDBC 驱动程序 JAR 文件。2. 加载并注册驱动程序。3. 创建 Connection 对象。JDBC 允许执行 SQL 查询和更新操作，并提供 PreparedStatement 用于执行更新。在完成所有操作后，应关闭 JDBC 连接以释放资源。使用 JDBC，可以轻松地与数据库交互，例如插入、查询和更新记录。

Java 数据库连接：JDBC API 实战指南

JDBC（Java 数据库连接）是用于 Java 程序与数据库交互的 API。它提供了一种标准的方式来访问不同数据库，包括 MySQL、Oracle、PostgreSQL 等。

设置 JDBC 连接

要建立与数据库的 JDBC 连接，你需要：

1. 导入 JDBC 驱动程序 JAR 文件。
2. 加载并注册驱动程序。
3. 创建 Connection 对象。

import java.sql.*;

public class JdbcExample {

    public static void main(String[] args) {
        // 数据库凭据
        String url = "jdbc:mysql://localhost:3306/database_name";
        String username = "root";
        String password = "password";

        // 加载和注册驱动程序
        try {
            Class.forName("com.mysql.cj.jdbc.Driver");
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
            return;
        }

        // 创建连接
        Connection connection = null;
        try {
            connection = DriverManager.getConnection(url, username, password);
        } catch (SQLException e) {
            e.printStackTrace();
            return;
        }

        // 使用连接执行 SQL 查询或更新操作
        // ...
    }
}

执行 SQL 查询

一旦连接建立，就可以执行 SQL 查询。

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

// 执行查询并获取结果集
ResultSet resultSet = statement.executeQuery("SELECT * FROM table_name");

// 遍历结果集
while (resultSet.next()) {
    // 获取列值
    int id = resultSet.getInt("id");
    String name = resultSet.getString("name");
    
    // 打印结果
    System.out.println("Id: " + id + ", Name: " + name);
}

执行 SQL 更新

要执行 SQL 更新操作（例如插入、更新或删除记录），可以使用 PreparedStatement。

// 创建一个 PreparedStatement
String sql = "INSERT INTO table_name (name, age) VALUES (?, ?)";
PreparedStatement statement = connection.prepareStatement(sql);

// 设置参数
statement.setString(1, "John Doe");
statement.setInt(2, 30);

// 执行更新
int rowCount = statement.executeUpdate();

关闭 JDBC 连接

在完成所有操作后，请务必关闭 JDBC 连接以释放资源。

try {
    connection.close();
} catch (SQLException e) {
    e.printStackTrace();
}

实战案例

假设你有一个 customers 表，包含以下列：

• id（ID）
• name（姓名）
• age（年龄）

使用 JDBC，你可以创建一个 Java 程序来插入一个新客户：

// 添加新客户
String sql = "INSERT INTO customers (name, age) VALUES (?, ?)";
PreparedStatement statement = connection.prepareStatement(sql);
statement.setString(1, "Jane Doe");
statement.setInt(2, 25);
int rowCount = statement.executeUpdate();

// 验证是否成功
if (rowCount > 0) {
    System.out.println("新客户已添加。");
}

然后，你可以通过输出 customers 表中的记录来验证插入是否成功：

// 输出客户
ResultSet resultSet = statement.executeQuery("SELECT * FROM customers");
while (resultSet.next()) {
    int id = resultSet.getInt("id");
    String name = resultSet.getString("name");
    int age = resultSet.getInt("age");
    System.out.println("Id: " + id + ", Name: " + name + ", Age: " + age);
}