executeQuery()详解

发布时间：2023-05-19

一、executeQuery()简介

在Java编程语言中，当我们需要执行SQL查询语句时，executeQuery()方法是非常有用的工具，它允许Java程序员在数据库中发出SQL语句，并返回结果集。 executeQuery()是Java JDBC API中的一个成员方法，用于向数据库发出查询语句，并返回结果集，其具体形式如下：

ResultSet executeQuery(String sql) throws SQLException

在执行完成SQL语句后，executeQuery()方法返回一个表示数据行和列的ResultSet对象。结果集包含符合查询条件的所有行。

二、executeQuery()使用注意事项

在使用executeQuery()方法前，需要先创建数据库连接，如下所示：

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

其中，url、username和password对应所连接的数据库的URL、用户名和密码。 接下来，需要使用Statement对象来执行SQL查询语句，并返回ResultSet结果集，如下所示：

Statement stmt = conn.createStatement();
ResultSet rs = stmt.executeQuery(sql);

需要注意的是，当executeQuety()方法执行完毕之后，ResultSet对象的光标位于第一行之前，需要使用next()方法移动ResultSet对象光标到第一行，如下所示：

while(rs.next()) {
   //获取ResultSet中每个字段的值
}

在遍历ResultSet记录时，需要使用ResultSet接口提供的getXXX()方法来获取每个字段的值，其中XXX可以是Int、String、Double等Java中的基本数据类型。

三、executeQuery()使用示例

下面是一个使用executeQuery()方法查询数据库并返回结果集的示例：

import java.sql.*;
public class ExecuteQueryExample {
    public static void main(String[] args) {
        String url = "jdbc:mysql://localhost:3306/example_db";
        String username = "root";
        String password = "123456";
        try {
            Connection conn = DriverManager.getConnection(url, username, password);
            String sqlQuery = "SELECT * FROM employees";
            Statement stmt = conn.createStatement();
            ResultSet rs = stmt.executeQuery(sqlQuery);
            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);
            }
            rs.close();
            stmt.close();
            conn.close();
        } catch(SQLException e) {
            e.printStackTrace();
        }
    }
}

该示例中，我们使用executeQuery()方法查询了employees表中的所有记录，并将查询结果输出到控制台。

四、executeQuery()方法的异常处理

在使用executeQuery()方法时，我们需要注意SQL语句的正确性，如果SQL语句有误，执行过程中会抛出SQLException异常，需要捕获该异常并进行处理。

try {
   //执行SQL查询语句
} catch(SQLException e) {
   e.printStackTrace();
}

另外，在使用executeQuery()方法时，还需要注意ResultSet对象的关闭。ResultSet对象是由Statement对象打开的，因此当使用完ResultSet对象后，需要调用ResultSet对象的close()方法来关闭该对象：

ResultSet rs = stmt.executeQuery(sqlQuery);
while(rs.next()) {
   //获取ResultSet中每个字段的值
}
rs.close();
stmt.close();
conn.close();

五、executeQuery()方法的重载

在Java JDBC API中，executeQuery()方法有多种重载形式，可以提供不同的参数类型来支持不同的SQL语句执行方式。 executeQuery()方法的具体重载方式如下：

ResultSet executeQuery(String sql) throws SQLException
ResultSet executeQuery() throws SQLException
ResultSet executeQuery(String sql, int autoGeneratedKeys) throws SQLException
ResultSet executeQuery(String sql, int[] columnIndexes) throws SQLException
ResultSet executeQuery(String sql, String[] columnNames) throws SQLException

其中，executeQuery()方法的无参形式直接返回Statement对象执行的上一次查询结果：

ResultSet rs = stmt.executeQuery();
while(rs.next()) {
   //获取ResultSet中每个字段的值
}
rs.close();
stmt.close();
conn.close();

六、总结

在Java编程语言中，executeQuery()方法是非常有用的工具，它允许Java程序员在数据库中发出SQL语句，并返回结果集。为了正确使用executeQuery()方法，我们需要特别注意SQL语句的正确性、ResultSet对象的移动、关闭及异常处理等问题。

推荐文章