Java程序使用预处理语句的性能提升

2025-04-23 140

Java程序使用预处理语句的性能提升

GreatSQL提供了对服务器端预处理语句（Prepared Statements）的支持。预处理语句可以利用了高效的客户机/服务器二进制协议。使用带有参数值占位符的预处理语句有以下好处:

每次执行时解析语句的开销更少。通常，数据库应用程序处理大量几乎相同的语句，只对语句中的文字值或变量值进行更改，如 SELECT 和 UPDATE 中的 WHERE,UPDATE 语句中的 SET 和 INSERT 语句中的VALUES。
防范SQL注入攻击。参数值可以包含未转义的SQL引号和分隔符。

本文编写Java程序，执行常规SQL语句和预处理语句，对比性能差异，量化预处理语句的性能提升。

1. 程序设计

通过Java程序进行DML操作，每次DML的数量是10万条，每50条一个提交批次。对比执行预处理语句和普通SQL语句，通过执行时间长短，判断执行的性能。

函数 testInsertPerformance 对比 INSERT 性能；
函数 testUpdatePerformance 对比 UPDATE 性能；
函数 testSelectPerformance 对比 SELECT 性能；
函数 testDeletePerformance对比 DELETE 性能；

1.1 测试表

greatsql> CREATE DATABASE IF NOT EXISTS testdb1;
greatsql> USE testdb1;

greatsql> CREATE TABLE IF NOT EXISTS test_table (
    id INT AUTO_INCREMENT PRIMARY KEY,
    col1 INT,
    col2 VARCHAR(100),
    col3 DATETIME
);

1.2 Java程序代码

Java程序比较容易使用预处理SQL语句，主要有两点：

数据库连接字符串中增加useServerPrepStmts=true；
SQL语句使用conn.prepareStatement进行预处理；

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.Statement;
import java.sql.Timestamp;
import java.util.Date;

public class SqlPerformanceTest {

    private static final String URL = "jdbc:mysql://192.168.134.208:3307/testdb1?useServerPrepStmts=true";
    private static final String USER = "testuser";
    private static final String PASSWORD = "testpass";
    private static final int NUM_ITERATIONS = 100000;
    private static final int BATCH_SIZE = 50;

    public static void main(String[] args) {
        try (Connection conn = DriverManager.getConnection(URL, USER, PASSWORD)) {
            // 清空测试表
            clearTable(conn);
            // 测试 INSERT 操作
            testInsertPerformance(conn);
            // 测试 UPDATE 操作
            testUpdatePerformance(conn);
            // 测试 SELECT 操作
            testSelectPerformance(conn);
            // 测试 DELETE 操作
            testDeletePerformance(conn);

        } catch (Exception e) {
            e.printStackTrace();
        } 
    }
    private static void clearTable(Connection conn) throws Exception {
        try (Statement stmt = conn.createStatement()) {
            stmt.execute("TRUNCATE TABLE test_table");
        }
    }
    private static void testInsertPerformance(Connection conn) throws Exception {
        long startTime, endTime;

        // 清空测试表
        clearTable(conn);

       // 普通 SQL 语句
        startTime = System.nanoTime();
        conn.setAutoCommit(false); // 关闭自动提交
        try (Statement stmt = conn.createStatement()) {
            for (int i = 1; i <= NUM_ITERATIONS; i++) {
                stmt.executeUpdate("INSERT INTO test_table (id, col1, col2, col3) VALUES ("+ i + "," + i + ", 'value" + i + "', '" + new Timestamp(new Date().getTime()) + "')");
                if (i % BATCH_SIZE == 0) {
                    conn.commit(); // 每50条记录提交一次事务
                }
            }
            conn.commit(); // 提交剩余的记录
        } finally {
            conn.setAutoCommit(true); // 恢复自动提交
        }
        endTime = System.nanoTime();
        System.out.println("INSERT - Statement: " + (endTime - startTime) / 1000000.0 + " ms");

        // 清空测试表
        clearTable(conn);

        // 预处理 SQL 语句
        startTime = System.nanoTime();
        conn.setAutoCommit(false); // 关闭自动提交
        try (PreparedStatement pstmt = conn.prepareStatement("INSERT INTO test_table (id,col1, col2, col3) VALUES (?, ?, ?, ?)")) {
            for (int i = 1; i <= NUM_ITERATIONS; i++) {
                pstmt.setInt(1, i);
                pstmt.setInt(2, i);
                pstmt.setString(3, "value" + i);
                pstmt.setTimestamp(4, new Timestamp(new Date().getTime()));
                pstmt.executeUpdate();
                if (i % BATCH_SIZE == 0) {
                    conn.commit(); // 每50条记录提交一次事务
                }
            }
            conn.commit(); // 提交剩余的记录
        } finally {        
            conn.setAutoCommit(true); // 恢复自动提交
        }
        endTime = System.nanoTime();
        System.out.println("INSERT - PreparedStatement: " + (endTime - startTime) / 1000000.0 + " ms");
    }

    private static void testUpdatePerformance(Connection conn) throws Exception {
        long startTime, endTime;

        // 普通 SQL 语句
        startTime = System.nanoTime();
        conn.setAutoCommit(false); // 关闭自动提交
        for (int i = 1; i <= NUM_ITERATIONS; i++) {
            try (Statement stmt = conn.createStatement()) {
                stmt.executeUpdate("UPDATE test_table SET col1 = " + i + ", col2 = 'value" + i + "', col3 = '" + new Timestamp(new Date().getTime()) + "' WHERE id = " + i);
                if (i % BATCH_SIZE == 0) {
                    conn.commit(); // 每50条记录提交一次事务
                }
            }
        }
        conn.commit(); // 提交剩余的记录
        endTime = System.nanoTime();
        System.out.println("UPDATE - Statement: " + (endTime - startTime) / 1000000.0 + " ms");

        // 预处理 SQL 语句
        startTime = System.nanoTime();
        conn.setAutoCommit(false); // 关闭自动提交
        try (PreparedStatement pstmt = conn.prepareStatement("UPDATE test_table SET col1 = ?, col2 = ?, col3 = ? WHERE id = ?")) {
            for (int i = 1; i <= NUM_ITERATIONS; i++) {
                pstmt.setInt(1, i);
                pstmt.setString(2, "value" + i);
                pstmt.setTimestamp(3, new Timestamp(new Date().getTime()));
                pstmt.setInt(4, i);
                pstmt.executeUpdate();
                if (i % BATCH_SIZE == 0) {
                    conn.commit(); // 每50条记录提交一次事务
                }
            }
            conn.commit(); // 提交剩余的记录
        } finally {
            conn.setAutoCommit(true); // 恢复自动提交
        }
        endTime = System.nanoTime();
        System.out.println("UPDATE - PreparedStatement: " + (endTime - startTime) / 1000000.0 + " ms");
    }

    private static void testDeletePerformance(Connection conn) throws Exception {
        long startTime, endTime;

        // 普通 SQL 语句
        startTime = System.nanoTime();
        conn.setAutoCommit(false); // 关闭自动提交
        for (int i = 1; i <= NUM_ITERATIONS/2; i++) {
            try (Statement stmt = conn.createStatement()) {
                stmt.executeUpdate("DELETE FROM test_table WHERE id = " + i);
                if (i % BATCH_SIZE == 0) {
                    conn.commit(); // 每50条记录提交一次事务
                }
            }
        }
        conn.commit(); // 提交剩余的记录
        endTime = System.nanoTime();
        System.out.println("DELETE - Statement: " + (endTime - startTime) / 1000000.0 + " ms");

        // 预处理 SQL 语句
        startTime = System.nanoTime();
        conn.setAutoCommit(false); // 关闭自动提交
        try (PreparedStatement pstmt = conn.prepareStatement("DELETE FROM test_table WHERE id = ?")){
            for (int i = NUM_ITERATIONS/2+1; i <= NUM_ITERATIONS; i++) {
                pstmt.setInt(1, i);
                pstmt.executeUpdate();
                if (i % BATCH_SIZE == 0) {
                    conn.commit(); // 每50条记录提交一次事务
                }
            }
            conn.commit(); // 提交剩余的记录
        } finally {
            conn.setAutoCommit(true); // 恢复自动提交
        }
        endTime = System.nanoTime();
        System.out.println("DELETE - PreparedStatement: " + (endTime - startTime) / 1000000.0 + " ms");
    }

    private static void testSelectPerformance(Connection conn) throws Exception {
        long startTime, endTime;

        // 普通 SQL 语句
        startTime = System.nanoTime();
        for (int i = 1; i <= NUM_ITERATIONS; i++) {
            try (Statement stmt = conn.createStatement()) {
                ResultSet rs = stmt.executeQuery("SELECT * FROM test_table WHERE id = " + i);
                while (rs.next()) {
                    // 处理结果集
                }
            }
        }
        endTime = System.nanoTime();
        System.out.println("SELECT - Statement: " + (endTime - startTime) / 1000000.0 + " ms");

        // 预处理 SQL 语句
        startTime = System.nanoTime();
        try (PreparedStatement pstmt = conn.prepareStatement("SELECT * FROM test_table WHERE id = ?")) {
            for (int i = 1; i <= NUM_ITERATIONS; i++) {
                pstmt.setInt(1, i);
                ResultSet rs = pstmt.executeQuery();
                while (rs.next()) {
                    // 处理结果集
                }
            }
        }
        endTime = System.nanoTime();
        System.out.println("SELECT - PreparedStatement: " + (endTime - startTime) / 1000000.0 + " ms");
    }
}

2. 程序编译与运行

编译Java程序

javac -cp .:mysql-connector-j-8.0.32.jar SqlPerformanceTest.java

运行Java程序

java -cp .:mysql-connector-j-8.0.32.jar SqlPerformanceTest

3. 运行结果

$ java -cp .:mysql-connector-j-8.0.32.jar SqlPerformanceTest
INSERT - Statement: 27089.435867 ms
INSERT - PreparedStatement: 24166.424328 ms
UPDATE - Statement: 32034.818767 ms
UPDATE - PreparedStatement: 29688.13851 ms
SELECT - Statement: 23330.719737 ms
SELECT - PreparedStatement: 20430.097589 ms
DELETE - Statement: 14933.753122 ms
DELETE - PreparedStatement: 13325.930952 ms

多运行Java程序，结果接近，按照其中一次进行数据统计：

操作类型	常规SQL语句执行时间（ms）	预处理语句执行时间（ms）	性能提升（%）
INSERT	27089	24166	10.79
UPDATE	32034	29688	7.32
SELECT	23330	20430	12.43
DELETE	14933	13325	10.77
合计	97386	87609	10.04

4. 总结

由于预处理语句比常规SQL语句，节省了SQL语句的解析时间，对于重复执行的SQL语句，使用预处理语句，可以明显地提高执行效率，性能提升约10%。

微信关注我们

原文链接：https://my.oschina.net/GreatSQL/blog/18224216

转载内容版权归作者及来源网站所有！

低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。

WebAssembly 组件模型 — 原因、方法和内容（第 1 部分）

原文作者：Timo Stark -F5专业服务工程师原文链接：WebAssembly 组件模型 — 原因、方法和内容（第 1 部分）转载来源：NGINX 中文官网 NGINX 唯一中文官方社区，尽在nginx.org.cn 如果您有兴趣开始使用 WebAssembly 组件模型，但面对庞大的生态系统不知从何处着手吗？如果是，那么本文正适合您！在本文中，我们将分享一些经验和心得，它们是我们在向 NGINX Unit 中添加对 WebAssembly 组件模型的支持时所获得的——感谢我们强大而活跃的社区。如果您已经熟悉 Wasm 生态系统，或者只是想了解如何编写代码，请关注本帐号，参考本系列博文的第二篇。 WebAssembly 组件模型和 NGINX Unit 在推出第一版 Unit Wasm 语言模块之后，我们做了许多工作。在 2023 年 9 月，我们说过：我们将 WebAssembly 支持作为技术预览版推出，希望尽快代之以 WASI-HTTP 支持。我们在 Unit 1.32.0 中做到了这一点。该版本支持将 WASI 0.2 API 和 wasi:http/...

2025-04-23

196

Notepad-- v3.2.1 已经发布，文本编辑器此版本更新内容包括： windows Notepad--v3.2.1-plugin-Installer.exe 是win10下面的插件版安装包，会关联右键菜单等。 Notepad--v3.2.1-win10-portable.zip 是绿色免安装版本，解压即用，不会关联右键菜单注册表。 MacOS 版本 Notepad--v3.2.1-mac_arm64_12.3.dmg 是macos 12.x 及以后 arm64 m1/m2芯片的版本。第一次安装时，需要在设置偏好里面，放开苹果的安装限制，才能正常识别，请自行放开设置一下。如果还是有问题，参考帖子：#I8JTJN:macOS Sonoma 14.1.1安装提示已损坏:macOS Sonoma 14.1.1安装提示已损坏本次修改： 1）提供国产pinlang的脚本集成运行环境，语法高亮。 2）插件系统框架支持，可使用pinlang脚本开发ndd插件。详情查看：https://gitee.com/cxasm/notepad--/releases/v3.2.1

2025-04-18

234

资源下载

更多资源

Mario

马里奥是站在游戏界顶峰的超人气多面角色。马里奥靠吃蘑菇成长，特征是大鼻子、头戴帽子、身穿背带裤，还留着胡子。与他的双胞胎兄弟路易基一起，长年担任任天堂的招牌角色。

腾讯云软件源

为解决软件依赖安装时官方源访问速度慢的问题，腾讯云为一些软件搭建了缓存服务。您可以通过使用腾讯云软件源站来提升依赖包的安装速度。为了方便用户自由搭建服务架构，目前腾讯云软件源站支持公网访问和内网访问。

Spring

Spring框架（Spring Framework）是由Rod Johnson于2002年提出的开源Java企业级应用框架，旨在通过使用JavaBean替代传统EJB实现方式降低企业级编程开发的复杂性。该框架基于简单性、可测试性和松耦合性设计理念，提供核心容器、应用上下文、数据访问集成等模块，支持整合Hibernate、Struts等第三方框架，其适用范围不仅限于服务器端开发，绝大多数Java应用均可从中受益。

Rocky Linux

Rocky Linux（中文名：洛基）是由Gregory Kurtzer于2020年12月发起的企业级Linux发行版，作为CentOS稳定版停止维护后与RHEL（Red Hat Enterprise Linux）完全兼容的开源替代方案，由社区拥有并管理，支持x86_64、aarch64等架构。其通过重新编译RHEL源代码提供长期稳定性，采用模块化包装和SELinux安全架构，默认包含GNOME桌面环境及XFS文件系统，支持十年生命周期更新。