通过JDBC实现数据的增、删、改、查功能

在Java中，通过JDBC（Java Database Connectivity）可以连接和操作数据库，实现数据的增、删、改、查功能。掌握JDBC的基本使用方法，是Java开发人员处理数据库操作的重要技能之一。本课件将详细介绍如何通过JDBC实现这些操作，并通过代码案例帮助大家深入理解。

1. JDBC基础概念

1.1 JDBC简介

JDBC是Java语言用于操作关系型数据库的API，它提供了一种标准的方式来连接数据库、执行SQL查询、更新数据以及处理结果。JDBC包括四个主要组件：

Connection：表示与数据库的连接。
Statement：用于执行SQL语句。
ResultSet：表示查询结果。
PreparedStatement：用于执行预编译的SQL语句，常用于防止SQL注入。

2. JDBC基本流程

使用JDBC操作数据库的一般流程如下：

加载数据库驱动程序。
获取数据库连接。
创建Statement或PreparedStatement对象。
执行SQL语句。
处理查询结果（对于SELECT查询）。
关闭连接，释放资源。

3. 通过JDBC实现数据的增、删、改、查功能

3.1 数据查询（SELECT）

SELECT语句用于从数据库中查询数据，通常会返回一个ResultSet对象，包含查询结果。

示例：查询所有学生信息

import java.sql.*;

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

        Connection conn = null;
        Statement stmt = null;
        ResultSet rs = null;

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

            // 获取数据库连接
            conn = DriverManager.getConnection(url, username, password);

            // 创建Statement对象
            stmt = conn.createStatement();

            // 执行查询语句
            String sql = "SELECT id, name, age FROM students";
            rs = stmt.executeQuery(sql);

            // 处理查询结果
            while (rs.next()) {
                int id = rs.getInt("id");
                String name = rs.getString("name");
                int age = rs.getInt("age");
                System.out.println("ID: " + id + ", Name: " + name + ", Age: " + age);
            }
        } catch (SQLException | ClassNotFoundException e) {
            e.printStackTrace();
        } finally {
            // 关闭资源
            try {
                if (rs != null) rs.close();
                if (stmt != null) stmt.close();
                if (conn != null) conn.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }
}

中文注释：

连接到school数据库，查询students表中的所有学生信息。
stmt.executeQuery(sql)用于执行查询语句，返回一个ResultSet对象。
使用rs.next()逐行遍历结果集，并输出每个学生的id、name和age。

3.2 数据插入（INSERT）

INSERT语句用于向数据库中插入新的数据。可以使用Statement或PreparedStatement来执行插入操作。

示例：插入一条新的学生记录

import java.sql.*;

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

        Connection conn = null;
        PreparedStatement pstmt = null;

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

            // 获取数据库连接
            conn = DriverManager.getConnection(url, username, password);

            // 准备插入的SQL语句
            String sql = "INSERT INTO students (name, age) VALUES (?, ?)";

            // 创建PreparedStatement对象
            pstmt = conn.prepareStatement(sql);

            // 设置参数
            pstmt.setString(1, "John");
            pstmt.setInt(2, 20);

            // 执行插入操作
            int rowsAffected = pstmt.executeUpdate();
            System.out.println("插入成功，影响的行数: " + rowsAffected);
        } catch (SQLException | ClassNotFoundException e) {
            e.printStackTrace();
        } finally {
            // 关闭资源
            try {
                if (pstmt != null) pstmt.close();
                if (conn != null) conn.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }
}

中文注释：

使用PreparedStatement来执行插入操作，防止SQL注入攻击。
通过pstmt.setString(1, "John")和pstmt.setInt(2, 20)设置插入数据的参数。

3.3 数据更新（UPDATE）

UPDATE语句用于更新数据库中的数据。使用PreparedStatement执行更新操作，可以有效避免SQL注入。

示例：更新学生的年龄

import java.sql.*;

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

        Connection conn = null;
        PreparedStatement pstmt = null;

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

            // 获取数据库连接
            conn = DriverManager.getConnection(url, username, password);

            // 准备更新的SQL语句
            String sql = "UPDATE students SET age = ? WHERE name = ?";

            // 创建PreparedStatement对象
            pstmt = conn.prepareStatement(sql);

            // 设置参数
            pstmt.setInt(1, 22);
            pstmt.setString(2, "John");

            // 执行更新操作
            int rowsAffected = pstmt.executeUpdate();
            System.out.println("更新成功，影响的行数: " + rowsAffected);
        } catch (SQLException | ClassNotFoundException e) {
            e.printStackTrace();
        } finally {
            // 关闭资源
            try {
                if (pstmt != null) pstmt.close();
                if (conn != null) conn.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }
}

中文注释：

更新名为John的学生的age字段为22岁。
使用PreparedStatement来设置更新的参数，避免SQL注入。

3.4 数据删除（DELETE）

DELETE语句用于删除数据库中的数据。与UPDATE类似，使用PreparedStatement来执行删除操作。

示例：删除指定学生记录

import java.sql.*;

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

        Connection conn = null;
        PreparedStatement pstmt = null;

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

            // 获取数据库连接
            conn = DriverManager.getConnection(url, username, password);

            // 准备删除的SQL语句
            String sql = "DELETE FROM students WHERE name = ?";

            // 创建PreparedStatement对象
            pstmt = conn.prepareStatement(sql);

            // 设置参数
            pstmt.setString(1, "John");

            // 执行删除操作
            int rowsAffected = pstmt.executeUpdate();
            System.out.println("删除成功，影响的行数: " + rowsAffected);
        } catch (SQLException | ClassNotFoundException e) {
            e.printStackTrace();
        } finally {
            // 关闭资源
            try {
                if (pstmt != null) pstmt.close();
                if (conn != null) conn.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }
}

中文注释：