【Java 进阶篇】JDBC查询操作详解

本是古典何须时尚 2023-10-16 17:28 182阅读 0赞

![在这里插入图片描述][9dcdc1b986224d2e95f5f37ac8a00517.png]

在数据库编程中，查询是一项非常常见且重要的操作。JDBC（Java Database Connectivity）提供了丰富的API来执行各种类型的查询操作。本篇博客将详细介绍如何使用JDBC进行查询操作，包括连接数据库、创建查询语句、执行查询、处理结果集等方面的内容。无论你是初学者还是有一定经验的开发者，都可以从中获得有价值的信息。

### 准备工作 ###

在进行JDBC查询操作之前，我们需要进行一些准备工作：

1.  **安装数据库驱动程序**：首先，确保你已经安装了与你使用的数据库相对应的JDBC驱动程序。不同数据库有不同的JDBC驱动，你需要下载并将其添加到你的项目中。
2.  **创建数据库**：如果还没有数据库，可以使用数据库管理工具（如MySQL Workbench）创建一个数据库，然后在该数据库中创建表格并插入一些数据，以便进行查询操作的演示。
3.  **导入JDBC库**：在Java项目中，你需要导入JDBC库，通常是`java.sql`包下的类和接口。

### 连接数据库 ###

在进行任何数据库操作之前，首先需要建立与数据库的连接。连接数据库是通过`Connection`对象来完成的。以下是连接到数据库的基本步骤：

import java.sql.Connection;
    import java.sql.DriverManager;
    import java.sql.SQLException;
    
    public class JDBCDemo {
        
        public static void main(String[] args) {
        
            // JDBC连接URL，其中mydatabase是数据库名
            String jdbcUrl = "jdbc:mysql://localhost:3306/mydatabase";
            String username = "your_username";
            String password = "your_password";
    
            try {
        
                // 创建数据库连接
                Connection connection = DriverManager.getConnection(jdbcUrl, username, password);
    
                // 在此处执行查询操作
    
                // 关闭连接
                connection.close();
            } catch (SQLException e) {
        
                e.printStackTrace();
            }
        }
    }

在上面的代码中，我们首先指定了数据库的连接URL、用户名和密码。然后，通过`DriverManager.getConnection()`方法创建了与数据库的连接，并在最后关闭了连接。请替换`jdbcUrl`、`username`和`password`为你自己的数据库信息。

### 创建查询语句 ###

一旦建立了数据库连接，我们就可以创建查询语句。查询语句是使用`Statement`或`PreparedStatement`对象来执行的。这里我们介绍两种常见的创建查询语句的方式。

#### 使用Statement ####

import java.sql.Connection;
    import java.sql.DriverManager;
    import java.sql.SQLException;
    import java.sql.Statement;
    
    public class JDBCDemo {
        
        public static void main(String[] args) {
        
            String jdbcUrl = "jdbc:mysql://localhost:3306/mydatabase";
            String username = "your_username";
            String password = "your_password";
    
            try {
        
                Connection connection = DriverManager.getConnection(jdbcUrl, username, password);
    
                // 创建Statement对象
                Statement statement = connection.createStatement();
    
                // 在此处执行查询操作
    
                // 关闭连接和Statement
                statement.close();
                connection.close();
            } catch (SQLException e) {
        
                e.printStackTrace();
            }
        }
    }

上述代码中，我们通过`connection.createStatement()`方法创建了一个`Statement`对象，它用于执行SQL语句。这种方式适用于静态的SQL查询。

#### 使用PreparedStatement ####

import java.sql.Connection;
    import java.sql.DriverManager;
    import java.sql.PreparedStatement;
    import java.sql.SQLException;
    
    public class JDBCDemo {
        
        public static void main(String[] args) {
        
            String jdbcUrl = "jdbc:mysql://localhost:3306/mydatabase";
            String username = "your_username";
            String password = "your_password";
    
            try {
        
                Connection connection = DriverManager.getConnection(jdbcUrl, username, password);
    
                // 创建PreparedStatement对象，可以使用占位符
                String sql = "SELECT * FROM students WHERE age > ?";
                PreparedStatement preparedStatement = connection.prepareStatement(sql);
    
                // 设置占位符的值
                preparedStatement.setInt(1, 18);
    
                // 在此处执行查询操作
    
                // 关闭连接和PreparedStatement
                preparedStatement.close();
                connection.close();
            } catch (SQLException e) {
        
                e.printStackTrace();
            }
        }
    }

在上述代码中，我们使用`connection.prepareStatement()`方法创建了一个`PreparedStatement`对象，它可以包含占位符。这种方式适用于需要动态生成SQL查询的情况，同时也有助于防止SQL注入攻击。

### 执行查询 ###

一旦创建了查询语句，我们就可以执行查询操作了。执行查询的方式主要有两种：使用`executeQuery()`方法执行查询并返回结果集，以及使用`executeUpdate()`方法执行更新操作。

#### 使用`executeQuery()` ####

import java.sql.Connection;
    import java.sql.DriverManager;
    import java.sql.ResultSet;
    import java.sql.SQLException;
    import java.sql.Statement;
    
    public class JDBCDemo {
        
        public static void main(String[] args) {
        
            String jdbcUrl = "jdbc:mysql://localhost:3306/mydatabase";
            String username = "your_username";
            String password = "your_password";
    
            try {
        
                Connection connection = DriverManager.getConnection(jdbcUrl, username, password);
                Statement statement = connection.createStatement();
    
                // 执行查询操作，将结果存储在ResultSet对象中
                String query = "SELECT * FROM students";
                ResultSet resultSet = statement.executeQuery(query);
    
                // 遍历结果集并处理数据
                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);
                }
    
                // 关闭连接、Statement和ResultSet
                resultSet.close();
                statement.close();
                connection.close();
            } catch (SQLException e) {
        
                e.printStackTrace();
            }
        }
    }

在上面的代码中，我们使用`executeQuery()`方法执行了一个查询操作，并将结果存储在`ResultSet`对象中。然后，我们通过遍历`ResultSet`来访问查询结果的每一行。

#### 使用`executeUpdate()` ####

import java.sql.Connection;
    import java.sql.DriverManager;
    import java.sql.SQLException;
    import java.sql.Statement;
    
    public class JDBCDemo {
        
        public static void main(String[] args) {
        
            String jdbcUrl = "jdbc:mysql://localhost:3306/mydatabase";
            String username = "your_username";
            String password = "your_password";
    
            try {
        
                Connection connection = DriverManager.getConnection(jdbcUrl, username, password);
                Statement statement = connection.createStatement();
    
                // 执行更新操作，返回受影响的行数
                String update = "UPDATE students SET age = 20 WHERE id = 1";
                int rowsAffected = statement.executeUpdate(update);
    
                System.out.println("Rows affected: " + rowsAffected);
    
                // 关闭连接和Statement
                statement.close();
                connection.close();
            } catch (SQLException e) {
        
                e.printStackTrace();
            }
        }
    }

在上述代码中，我们使用`executeUpdate()`方法执行了一个更新操作，例如更新表中的某些数据。它返回受影响的行数，以便我们知道操作的结果。

### 处理结果集 ###

一旦我们执行了查询操作并获得了结果集，就需要对结果集进行处理。常见的处理方式包括遍历结果集、提取数据以及关闭结果集。

// 遍历结果集并处理数据
    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);
    }
    
    // 提取数据
    if (resultSet.next()) {
        
        int id = resultSet.getInt("id");
        String name = resultSet.getString("name");
        int age = resultSet.getInt("age");
    }
    
    // 关闭结果集
    resultSet.close();

遍历结果集时，我们使用`next()`方法来移动到结果集的下一行。然后，使用`getXXX()`方法（例如`getInt()`、`getString()`）来提取数据。最后，使用`close()`方法关闭结果集。

### 异常处理 ###

在进行任何数据库操作时，务必进行异常处理以处理潜在的错误情况。在上述代码示例中，我们使用了`try-catch`块来捕获`SQLException`异常，并在异常发生时打印错误信息。

try {
        
        // 执行数据库操作
    } catch (SQLException e) {
        
        e.printStackTrace();
    }

这样可以确保在遇到问题时能够及时识别和解决。

### 总结 ###

本篇博客介绍了如何使用JDBC进行查询操作的基本步骤，包括连接数据库、创建查询语句、执行查询操作和处理结果集。希望这些示例能够帮助你更好地理解和使用JDBC进行数据库查询操作。在实际开发中，你可以根据自己的需求和数据库类型来编写相应代码，来完成自己的需求。

<table> 
 <tbody> 
  <tr> 
   <td> <strong><font>作者信息</font></strong><br> <br> <font> 作者 ： 繁依Fanyi</font><br> <font>CSDN：</font> <a href="https://blog.csdn.net/qq_21484461?spm=1000.2115.3001.5343" rel="nofollow"><font>https://techfanyi.blog.csdn.net</font></a><br> <font>掘金：</font><a href="https://juejin.cn/user/4154386571867191" rel="nofollow"><font>https://juejin.cn/user/4154386571867191</font></a> </td> 
  </tr> 
 </tbody> 
</table>

[9dcdc1b986224d2e95f5f37ac8a00517.png]: https://img-blog.csdnimg.cn/9dcdc1b986224d2e95f5f37ac8a00517.png