JDBC实现数据库增删改查功能

下面是关于JDBC实现数据库增删改查功能的详细攻略。

1. 前置知识

在学习JDBC之前，需要先掌握以下知识：

• Java基础知识
• SQL语言基础知识
• 数据库基础知识

2. JDBC简介

Java Database Connectivity (JDBC) 是Java语言操作数据库的标准接口，它提供了一组不依赖于特定数据库管理系统的通用API，使得我们能够通过Java程序连接到任何兼容JDBC标准的关系型数据库，并执行增删改查等相关操作。

JDBC的API主要由以下接口和类组成：

• DriverManager：用于获取数据库连接。
• Connection：代表一个数据库连接。
• Statement：用于执行静态SQL语句并返回结果。
• PreparedStatement：用于执行动态SQL语句并返回结果。
• ResultSet：代表一个查询结果集。

3. JDBC的使用步骤

使用JDBC完成对关系型数据库的增删改查通常要完成以下步骤：

1. 加载数据库驱动程序。

在使用JDBC时，首先需要通过Class.forName()方法加载相应数据库的JDBC驱动程序，例如MySQL的驱动程序就是com.mysql.jdbc.Driver。

示例：

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

1. 通过DriverManager获取数据源连接。

在加载完驱动程序之后，需要通过DriverManager.getConnection()方法获取到与数据库的连接，该方法需要传递具体的数据库连接参数，如数据库的URL、用户名、密码等。

示例：

String url = "jdbc:mysql://localhost:3306/mydatabase"; // 数据库URL
String user = "root"; // 用户名
String password = "123456"; // 密码

Connection conn = DriverManager.getConnection(url, user, password);

1. 执行SQL语句。

在获取到数据源连接之后，就可以执行SQL语句了。使用JDBC可以通过两种方式执行SQL语句，一种是使用Statement对象执行静态SQL语句，另一种是使用PreparedStatement对象执行动态SQL语句。

执行静态SQL语句的示例：

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

String sql = "INSERT INTO employees (emp_name, emp_age, emp_salary) VALUES ('Lucy', 25, 3500)"; // SQL语句
stmt.executeUpdate(sql); // 执行SQL语句

执行动态SQL语句的示例：

PreparedStatement pstmt = conn.prepareStatement("INSERT INTO employees (emp_name, emp_age, emp_salary) VALUES (?, ?, ?)"); // 创建PreparedStatement对象

pstmt.setString(1, "Lucy"); // 设置第1个参数的值为"Lucy"
pstmt.setInt(2, 25); // 设置第2个参数的值为25
pstmt.setDouble(3, 3500); // 设置第3个参数的值为3500

pstmt.executeUpdate(); // 执行SQL语句

1. 处理SQL语句执行结果。

在执行SQL语句之后，需要根据具体的需求处理SQL语句执行结果，比如获取查询结果集或者判断执行是否成功等。

获取查询结果集的示例：

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

ResultSet rs = stmt.executeQuery("SELECT * FROM employees"); // 执行查询操作并获取结果集

while (rs.next()) { // 遍历结果集
    int id = rs.getInt("emp_id");
    String name = rs.getString("emp_name");
    int age = rs.getInt("emp_age");
    double salary = rs.getDouble("emp_salary");

    // 处理结果
}

rs.close(); // 关闭结果集

判断执行是否成功的示例：

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

int result = stmt.executeUpdate("DELETE FROM employees WHERE emp_id = 1"); // 执行SQL语句并获取执行结果

if (result > 0) {
    System.out.println("执行成功");
} else {
    System.out.println("执行失败");
}

1. 关闭资源。

在使用完JDBC之后，需要关闭相关资源，包括连接、语句以及结果集等。

示例：

rs.close(); // 关闭结果集
stmt.close(); // 关闭语句
conn.close(); // 关闭连接

4. 示例应用

下面是一个简单的示例，展示如何使用JDBC实现一个简单的增删改查操作。

import java.sql.*;

public class JdbcDemo {

    public static void main(String[] args) throws SQLException, ClassNotFoundException {

        // 加载MySQL驱动程序
        Class.forName("com.mysql.jdbc.Driver");

        // 获取数据库连接
        String url = "jdbc:mysql://localhost:3306/mydatabase";
        String user = "root";
        String password = "123456";

        Connection conn = DriverManager.getConnection(url, user, password);

        // 插入数据
        PreparedStatement pstmt = conn.prepareStatement("INSERT INTO employees (emp_name, emp_age, emp_salary) VALUES (?, ?, ?)");
        pstmt.setString(1, "Lucy");
        pstmt.setInt(2, 25);
        pstmt.setDouble(3, 3500);

        pstmt.executeUpdate();

        // 更新数据
        Statement stmt = conn.createStatement();
        String sql = "UPDATE employees SET emp_salary = 4000 WHERE emp_name = 'Lucy'";
        stmt.executeUpdate(sql);

        // 查询数据
        ResultSet rs = stmt.executeQuery("SELECT * FROM employees");
        while (rs.next()) {
            int id = rs.getInt("emp_id");
            String name = rs.getString("emp_name");
            int age = rs.getInt("emp_age");
            double salary = rs.getDouble("emp_salary");

            System.out.println("编号：" + id + "，姓名：" + name + "，年龄：" + age + "，薪资：" + salary);
        }

        // 删除数据
        sql = "DELETE FROM employees WHERE emp_name = 'Lucy'";
        stmt.executeUpdate(sql);

        // 关闭资源
        rs.close();
        pstmt.close();
        stmt.close();
        conn.close();
    }
}

另外，还可以使用JDBC连接其他数据库，如Oracle、SQL Server等，只需要相应地更改驱动程序及连接参数即可。