【Java 进阶篇】JDBC Statement：执行 SQL 语句的重要接口_百度小程序

什么是 JDBC Statement？

Statement接口是JDBC的一部分，它允许我们向数据库发送SQL查询和更新语句，并从数据库中获取结果。Statement接口有多个子接口和实现类，常用的有以下几种：

Statement：用于执行普通的SQL语句，不带有参数。
PreparedStatement：用于执行预编译的SQL语句，可以带有参数，防止SQL注入攻击。

CallableStatement：用于执行数据库存储过程。

在本文中，我们将主要关注Statement接口及其用法。

创建 JDBC Statement 对象

在执行SQL语句之前，首先需要创建Statement对象。Statement对象通常与Connection对象关联，通过Connection对象的createStatement()方法创建。下面是创建Statement对象的示例代码：

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.sql.Statement;
public class StatementExample {
    public static void main(String[] args) {
        // JDBC连接参数
        String url = "jdbc:mysql://localhost:3306/mydatabase";
        String username = "root";
        String password = "password";
        
        // 创建Connection对象
        try (Connection connection = DriverManager.getConnection(url, username, password)) {
            // 创建Statement对象
            Statement statement = connection.createStatement();
            
            // 在此处执行SQL语句
            
            // 关闭Statement
            statement.close();
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}

在上述代码中，我们首先创建了一个Connection对象，然后使用createStatement()方法创建了一个Statement对象。需要注意的是，我们在try-with-resources块中创建了Connection和Statement对象，这样在退出块时会自动关闭这些资源，无需手动关闭。

执行 SQL 查询语句

一旦创建了Statement对象，我们可以使用它来执行SQL查询语句。以下是一个简单的示例，演示如何执行SELECT查询并处理查询结果：

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
public class SelectExample {
    public static void main(String[] args) {
        // JDBC连接参数
        String url = "jdbc:mysql://localhost:3306/mydatabase";
        String username = "root";
        String password = "password";
        
        try (Connection connection = DriverManager.getConnection(url, username, password)) {
            // 创建Statement对象
            Statement statement = connection.createStatement();
            
            // 执行SQL查询语句
            String sql = "SELECT * FROM employees";
            ResultSet resultSet = statement.executeQuery(sql);
            
            // 处理查询结果
            while (resultSet.next()) {
                int id = resultSet.getInt("id");
                String name = resultSet.getString("name");
                double salary = resultSet.getDouble("salary");
                System.out.println("ID: " + id + ", Name: " + name + ", Salary: " + salary);
            }
            
            // 关闭ResultSet和Statement
            resultSet.close();
            statement.close();
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}

在上述代码中，我们使用executeQuery()方法执行SELECT查询语句，然后使用ResultSet对象遍历查询结果。最后，我们关闭了ResultSet和Statement对象，释放资源。

执行 SQL 更新语句

除了查询，Statement对象还可以用于执行SQL更新语句，如INSERT、UPDATE和DELETE。以下是一个示例，演示如何执行INSERT语句来插入新数据：

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.sql.Statement;
public class InsertExample {
    public static void main(String[] args) {
        // JDBC连接参数
        String url = "jdbc:mysql://localhost:3306/mydatabase";
        String username = "root";
        String password = "password";
        
        try (Connection connection = DriverManager.getConnection(url, username, password)) {
            // 创建Statement对象
            Statement statement = connection.createStatement();
            
            // 执行SQL更新语句
            String sql = "INSERT INTO employees (name, salary) VALUES ('John', 50000)";
            int rowsAffected = statement.executeUpdate(sql);
            
            if (rowsAffected > 0) {
                System.out.println("Insertion successful. Rows affected: " + rowsAffected);
            } else {
                System.out.println("Insertion failed.");
            }
            
            // 关闭Statement
            statement.close();
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}

在上述代码中，我们使用executeUpdate()方法执行INSERT语句，并检查受影响的行数来确定是否插入成功。

防止 SQL 注入攻击

在使用Statement执行SQL语句时，要注意防止SQL注入攻击。SQL注入攻击是一种常见的网络安全威胁，它可以通过恶意构造的输入来破坏数据库操作。为了防止SQL注入攻击，应该使用PreparedStatement而不是Statement来执行带有参数的SQL语句。PreparedStatement允许将参数绑定到SQL语句中，从而避免直接拼接用户输入，如下所示：

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) {
        // JDBC连接参数
        String url = "jdbc:mysql://localhost:3306/mydatabase";
        String username = "root";
        String password = "password";
        
        try (Connection connection = DriverManager.getConnection(url, username, password)) {
            // 创建PreparedStatement对象
            String sql = "INSERT INTO employees (name, salary) VALUES (?, ?)";
            PreparedStatement preparedStatement = connection.prepareStatement(sql);
            
            // 设置参数
            preparedStatement.setString(1, "Alice");
            preparedStatement.setDouble(2, 60000);
            
            // 执行SQL更新语句
            int rowsAffected = preparedStatement.executeUpdate();
            
            if (rowsAffected > 0) {
                System.out.println("Insertion successful. Rows affected: " + rowsAffected);
            } else {
                System.out.println("Insertion failed.");
            }
            
            // 关闭PreparedStatement
            preparedStatement.close();
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}

在上述代码中，我们使用PreparedStatement来执行INSERT语句，并使用setString()和setDouble()方法设置参数值。这样可以确保用户输入不会被误解为SQL代码，提高了安全性。

总结

Statement接口是JDBC中执行SQL语句的关键接口之一。通过创建Statement对象，我们可以执行查询和更新等各种数据库操作。然而，为了提高安全性，建议在执行SQL语句时使用PreparedStatement，尤其是涉及用户输入的情况下。希望本文能够帮助您更好地理解JDBC中的Statement接口以及如何使用它来与数据库进行交互。

作者信息

作者：繁依Fanyi

CSDN： https://techfanyi.blog.csdn.net

掘金：https://juejin.cn/user/4154386571867191

网站建设策划方案书学平面设计后悔死了公司网站制作需要多少钱工程建设项目审批管理系统东莞推广网站排名珠海网站制作公司

上一篇：SQL连接的理解和使用（内连接：自然连接&等值连接，外连接：左连接&右连接&全外连接）

下一篇：银河麒麟服务器系统安装KVM和创建KVM虚拟机