如何在Java中实现数据库查询？

1. JDBC简介

Java数据库连接（JDBC）是Java语言中用来规范客户端程序如何访问数据库的应用程序接口，提供了诸如查询和更新数据库中数据的方法。

2. 环境准备

确保已经安装了合适的JDBC驱动程序，对于MySQL数据库，需要下载并安装MySQL Connector/J。

添加JDBC驱动到项目的类路径中。

3. 建立数据库连接

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
public class DatabaseConnection {
    private static final String URL = "jdbc:mysql://localhost:3306/mydatabase";
    private static final String USER = "username";
    private static final String PASSWORD = "password";
    public static Connection getConnection() throws SQLException {
        return DriverManager.getConnection(URL, USER, PASSWORD);
    }
}

4. 执行查询

import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.Statement;
import java.sql.SQLException;
public class QueryDatabase {
    public static void main(String[] args) {
        try (Connection connection = DatabaseConnection.getConnection();
             Statement statement = connection.createStatement()) {
            String query = "SELECT * FROM users";
            ResultSet resultSet = statement.executeQuery(query);
            while (resultSet.next()) {
                int id = resultSet.getInt("id");
                String name = resultSet.getString("name");
                System.out.println("ID: " + id + ", Name: " + name);
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}

5. 使用PreparedStatement防止SQL注入

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
public class PreventSQLInjection {
    public static void main(String[] args) {
        try (Connection connection = DatabaseConnection.getConnection()) {
            String query = "SELECT * FROM users WHERE name = ?";
            PreparedStatement preparedStatement = connection.prepareStatement(query);
            preparedStatement.setString(1, "John Doe");
            ResultSet resultSet = preparedStatement.executeQuery();
            while (resultSet.next()) {
                int id = resultSet.getInt("id");
                String name = resultSet.getString("name");
                System.out.println("ID: " + id + ", Name: " + name);
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}

6. 关闭资源

确保在完成数据库操作后关闭所有资源，包括ResultSet、Statement和Connection，可以使用trywithresources语句自动关闭资源。

7. 常见问题与解答

问题1：如何处理数据库连接异常？

解答：当尝试建立数据库连接时，可能会遇到各种异常，如网络问题、认证失败等，为了处理这些异常，可以在代码中使用trycatch块捕获SQLException，并根据需要进行处理，例如打印错误信息或抛出自定义异常。

问题2：如何使用预编译的SQL语句来提高性能？

解答：预编译的SQL语句（也称为PreparedStatement）可以提高数据库查询的性能，因为它们允许数据库预先编译和优化SQL语句，从而减少了每次执行时解析和编译的时间，预编译的SQL语句还可以帮助防止SQL注入攻击，因为它们将参数作为字面量而不是直接插入到SQL语句中，在上面的示例中，我们使用了PreparedStatement来演示如何创建预编译的SQL语句。