正文

学会Java JDBC更新查询：轻松掌握数据库数据修改技巧

/0 浏览量
1021

在Java编程中，JDBC（Java Database Connectivity）是一种用于执行SQL语句的API，它允许Java程序与各种关系型数据库进行连接和交互。今天，我们就来探讨如何使用JDBC进行数据库的更新和查询操作，帮助你轻松掌握数据库数据修改技巧。

1. JDBC概述

首先，让我们简单回顾一下JDBC的基本概念。JDBC提供了以下几种基本操作：

  • 连接数据库（Connection）
  • 创建SQL语句（Statement或PreparedStatement）
  • 执行SQL语句（executeQuery、executeUpdate、execute）
  • 处理结果集（ResultSet）
  • 关闭连接（close）

2. 更新数据库数据

2.1 使用Statement更新数据

要使用Statement更新数据库数据，首先需要创建一个连接，然后创建一个Statement对象，并使用executeUpdate方法执行更新操作。

以下是一个使用Statement更新数据的示例代码：

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

public class UpdateExample {
    public static void main(String[] args) {
        Connection conn = null;
        Statement stmt = null;

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

            // 创建数据库连接
            conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/testdb", "username", "password");

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

            // 执行更新操作
            String sql = "UPDATE employees SET salary = salary + 1000 WHERE id = 1";
            int rowsUpdated = stmt.executeUpdate(sql);

            // 输出更新结果
            System.out.println("Rows updated: " + rowsUpdated);
        } catch (ClassNotFoundException e) {
            System.out.println("JDBC Driver not found.");
            e.printStackTrace();
        } catch (SQLException e) {
            System.out.println("Database error.");
            e.printStackTrace();
        } finally {
            // 关闭资源
            try {
                if (stmt != null) stmt.close();
                if (conn != null) conn.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }
}

2.2 使用PreparedStatement更新数据

在实际应用中，使用PreparedStatement可以避免SQL注入攻击，并且可以更好地处理数据。以下是一个使用PreparedStatement更新数据的示例代码：

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

public class PreparedStatementExample {
    public static void main(String[] args) {
        Connection conn = null;
        PreparedStatement pstmt = null;

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

            // 创建数据库连接
            conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/testdb", "username", "password");

            // 创建PreparedStatement对象
            String sql = "UPDATE employees SET salary = salary + ? WHERE id = ?";
            pstmt = conn.prepareStatement(sql);

            // 设置参数
            pstmt.setInt(1, 1000);
            pstmt.setInt(2, 1);

            // 执行更新操作
            int rowsUpdated = pstmt.executeUpdate();

            // 输出更新结果
            System.out.println("Rows updated: " + rowsUpdated);
        } catch (ClassNotFoundException e) {
            System.out.println("JDBC Driver not found.");
            e.printStackTrace();
        } catch (SQLException e) {
            System.out.println("Database error.");
            e.printStackTrace();
        } finally {
            // 关闭资源
            try {
                if (pstmt != null) pstmt.close();
                if (conn != null) conn.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }
}

3. 查询数据库数据

在完成更新操作后，你可能还需要查询数据库以验证更新结果。以下是一个使用JDBC查询数据的示例代码：

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

public class QueryExample {
    public static void main(String[] args) {
        Connection conn = null;
        PreparedStatement pstmt = null;
        ResultSet rs = null;

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

            // 创建数据库连接
            conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/testdb", "username", "password");

            // 创建PreparedStatement对象
            String sql = "SELECT * FROM employees WHERE id = ?";
            pstmt = conn.prepareStatement(sql);

            // 设置参数
            pstmt.setInt(1, 1);

            // 执行查询操作
            rs = pstmt.executeQuery();

            // 处理查询结果
            while (rs.next()) {
                int id = rs.getInt("id");
                String name = rs.getString("name");
                double salary = rs.getDouble("salary");
                System.out.println("ID: " + id + ", Name: " + name + ", Salary: " + salary);
            }
        } catch (ClassNotFoundException e) {
            System.out.println("JDBC Driver not found.");
            e.printStackTrace();
        } catch (SQLException e) {
            System.out.println("Database error.");
            e.printStackTrace();
        } finally {
            // 关闭资源
            try {
                if (rs != null) rs.close();
                if (pstmt != null) pstmt.close();
                if (conn != null) conn.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }
}

4. 总结

通过本文的介绍，相信你已经掌握了使用Java JDBC进行数据库更新和查询的基本技巧。在实际开发中，合理运用这些技巧可以大大提高你的工作效率。希望本文对你有所帮助！

-- 展开阅读全文 --