JDBC PrepareStatement 的使用（附各种场景 demo）

在 Java 中，与关系型数据库进行交互是非常常见的任务之一。JDBC（Java Database Connectivity）是 Java 平台的一个标准 API，用于连接和操作各种关系型数据库。其中，PreparedStatement 是 JDBC 中的一个重要接口，用于执行预编译的 SQL 语句。

什么是 PreparedStatement

1）PreparedStatement 继承自 Statement ，是 Statement 的一种扩展；

2）PreparedStatement 特点：使用 PreparedStatement 可以执行动态参数化 sql（在 sql 语句中用占位符 ?）；

3）PreparedStatement 原理：在我们调用 PreparedStatement 对象（sqlStatement）的时候，我们需要将一个半成品 sql 语句交给 sqlStatement，sqlStatement 拿着这个 sql 先发送到数据库，进行预编译（检查语法，检查权限），当我们调用 sqlStatement.setXXX() 的时候，再一起把占位符设置的动态参数值一起发送到数据库执行，不用再编译当前的sql语句，这样可以大大的节省时间，提高运行效率。

什么是 SQL 注入风险

一些黑客，将一些特殊的字符通过字符串拼接的方式注入到 sql 语句中，改变 sql 语句原有的运行逻辑，从而威胁到数据库的安全，这种现象叫做 sql 注入。

Statement 和 PreparedStatement 的区别

1）使用 Statement 执行 SQL 语句，是以字符串拼接的方式给 SQL 语句加入参数，这个时候存在 sql 注入风险；

2）使用 PreparedStatement 执行 SQL 语句，是以参数拼接（setXXX() 函数）的方式给 SQL 语句加入参数，预编译的方式能有效防止 SQL 注入；

3）PreparedStatement 和 Statement 的生命周期，都是一次数据库连接，PreparedStatement 的可重用是由于连接池管理器有缓存功能，PreparedStatement 编译时会被记录到列表，并在下次访问时返回；

4）PreparedStatement 能在一次连接中，对数据进行批量更新（Batch 功能），减少服务与数据库的交互次数，网络往返是影响性能的重要指标；

5）Statement 适用于少次或者一次的查询，PreparedStatement 适用于多次或者一次做多量的查询；　　

6）对于只执行一次的 SQL 语句选择 Statement 是最好的，因为只执行一次的 SQL 语句使用 PreparedStatement 反而比 Statement 更耗时；

7）PreparedStatement 代码的可读性高，可维护性好；

创建 PreparedStatement

要创建一个 PreparedStatement 对象，首先需要获得一个 Connection 对象，然后使用 prepareStatement 方法传入 SQL 语句。下面举几个具体示例：

数据准备

create database jdbc;CREATE TABLE t1 (c1 int,c2 int,c3 char(10),PRIMARY KEY (c1),KEY(c2)
);INSERT INTO t1 VALUES (1, 6, '3');
INSERT INTO t1 VALUES (2, 3, '4');
INSERT INTO t1 VALUES (3, 4, '1');
INSERT INTO t1 VALUES (4, 1, '6');
INSERT INTO t1 VALUES (5, 2, '2');
INSERT INTO t1 VALUES (6, 5, '5');
INSERT INTO t1 VALUES (7, 8, '9');
INSERT INTO t1 VALUES (8, 9, '7');
INSERT INTO t1 VALUES (9, 7, '8');

执行 select 语句

下面以执行 select 语句为例，并输出查询结果：

import java.sql.*;public class prepareStatement {public static void main(String[] args) {/* ----------------------------------------------------------------------- */// 1) connection mysqlString url = "jdbc:mysql://172.19.108.205:3306/jdbc";String username = "root";String password = "";// load drivetry {Class.forName("com.mysql.cj.jdbc.Driver");  // mys1ql 8.0 以前版本：Class.forName("com.mysql.jdbc.Driver");System.out.println("load driver succeed!");} catch (ClassNotFoundException e) {e.printStackTrace();System.out.println("load driver fail!");return;}try {Connection connection = DriverManager.getConnection(url, username, password);System.out.println("Connected to the database!");/* ----------------------------------------------------------------------- */// 2) execute SQLtry {String sql = "SELECT * FROM t1 WHERE c1 > ?";   // sql 查询语句使用 ? 作为占位符PreparedStatement preparedStatement = connection.prepareStatement(sql);// set parameterpreparedStatement.setInt(1, 5);     // 此处的 1 是指 sql 中的第 1 个参数// execute queryResultSet resultSet = preparedStatement.executeQuery();// show select resultwhile (resultSet.next()) {int c1 = resultSet.getInt("c1");int c2 = resultSet.getInt("c2");String c3 = resultSet.getString("c3");System.out.println("c1: " + c1 + ", c2: " + c2 + ", c3: " + c3);}} catch (SQLException e) {e.printStackTrace();System.out.println("executeQuery fail!");}connection.close();    // close PreparedStatement} catch (SQLException e) {e.printStackTrace();}}
}

PreparedStatement 允许我们为 SQL 语句中的占位符设置参数值。有多种 setXXX 方法可用于不同数据类型的参数设置，例如 setInt、setString、setDouble 等，其中 setXXX 方法中的第一个参数是指 SQL 语句中的第几个占位符。

执行结果如下：

执行 update 语句

import java.sql.*;public class prepareStatement_update {public static void main(String[] args) {/* ----------------------------------------------------------------------- */// 1) 连接数据库String url = "jdbc:mysql://172.19.108.205:3306/jdbc";String username = "root";String password = "";// load drivetry {Class.forName("com.mysql.cj.jdbc.Driver");  // mys1ql 8.0 以前版本：Class.forName("com.mysql.jdbc.Driver");System.out.println("load driver succeed!");} catch (ClassNotFoundException e) {e.printStackTrace();System.out.println("load driver fail!");return;}try {Connection connection = DriverManager.getConnection(url, username, password);System.out.println("Connected to the database!");/* ----------------------------------------------------------------------- */// 2) execute SQLtry {String sql = "UPDATE t1 SET c3 = ? WHERE c1 = ?";   // sql 查询语句使用 ? 最为占位符PreparedStatement preparedStatement = connection.prepareStatement(sql);// set parameterpreparedStatement.setString(1,"9");preparedStatement.setInt(2, 9);// execute queryint rowCount = preparedStatement.executeUpdate();    // 统计更新的行数// show select resultSystem.out.println("Updated " + rowCount + " rows.");} catch (SQLException e) {e.printStackTrace();System.out.println("executeUpdated fail!");}connection.close();    // close PreparedStatement} catch (SQLException e) {e.printStackTrace();}}
}

执行结果如下：

执行批处理

当需要批量插入或更新记录时，可以采用 Java 的批量更新机制，这一机制允许多条 SQL 语句一次性提交给数据库。通常情况下，批量提交处理比单独提交处理效率要高很多，JDBC 批量处理 SQL 语句主要使用以下三个方法：

  • addBatch(String)：添加需要批量处理的 SQL 语句或参数；
  • executeBatch()：执行批量处理语句；
  • clearBatch():清空缓存的数据；

通常我们会遇到两种批量执行 SQL 语句的情况：

  • 一个 SQL 语句的批量传参；
  • 多条 SQL 语句的批量处理；

批处理的两个重要参数：

  • allowMultiQueries：是否允许一次性执行多条 SQL，默认为 false；
select * from t1;select * from t1;

 注意：因为它允许一次执行多个查询，所以它可能导致应用程序被某些类型的 SQL 注入攻击；

  • rewriteBatchedStatements：是否允许将 SQL 语句批量传给 MySQL，默认为 false；若想让 MySQL 支持批处理，可以将 ?rewriteBatchedStatements=true 写在 url 的后面；
String url = "jdbc:mysql://172.19.108.205:3306/jdbc?rewriteBatchedStatements=true";

下面几种场景是往表 t1 中插入 10000 条记录，然后对比不同插入方式的耗时：

方式一：循环批量传参

 

import java.sql.*;public class prepareStatement_insert {public static void main(String[] args) {/* ----------------------------------------------------------------------- */// 1) connection mysqlString url = "jdbc:mysql://172.19.108.205:3306/jdbc";String username = "root";String password = "";// load drivetry {Class.forName("com.mysql.cj.jdbc.Driver");  // mys1ql 8.0 以前版本：Class.forName("com.mysql.jdbc.Driver");System.out.println("load driver succeed!");} catch (ClassNotFoundException e) {e.printStackTrace();System.out.println("load driver fail!");return;}try {long start = System.currentTimeMillis();    // start timeConnection connection = DriverManager.getConnection(url, username, password);System.out.println("Connected to the database!");/* ----------------------------------------------------------------------- */// 2) execute SQLtry {String insertSql = "INSERT INTO t1 (c1, c2, c3) VALUES (?, ?, ?)";PreparedStatement insertStatement = connection.prepareStatement(insertSql);// set parameterfor (int i =10; i <= 10000; i++) {insertStatement.setInt(1, i);insertStatement.setInt(2, i);insertStatement.setString(3, Integer.toString(i));// execute queryinsertStatement.executeUpdate();}long end = System.currentTimeMillis();System.out.println("cost time：" + (end - start));} catch (SQLException e) {e.printStackTrace();System.out.println("executeUpdated fail!");}connection.close();} catch (SQLException e) {e.printStackTrace();}}
}

执行结果如下：

说明：从执行结果可知，方式一批量处理时，耗时：34886

方式二：批处理函数

使用 executeBatch 批量执行；

import java.sql.*;public class prepareStatement_insert2 {public static void main(String[] args) {/* ----------------------------------------------------------------------- */// 1) connection mysqlString url = "jdbc:mysql://172.19.108.205:3306/jdbc?rewriteBatchedStatements=true";String username = "root";String password = "";// load drivetry {Class.forName("com.mysql.cj.jdbc.Driver");  // mys1ql 8.0 以前版本：Class.forName("com.mysql.jdbc.Driver");System.out.println("load driver succeed!");} catch (ClassNotFoundException e) {e.printStackTrace();System.out.println("load driver fail!");return;}try {long start = System.currentTimeMillis();    // start timeConnection connection = DriverManager.getConnection(url, username, password);System.out.println("Connected to the database!");/* ----------------------------------------------------------------------- */// 2) execute SQLtry {String insertSql = "INSERT INTO t1 (c1, c2, c3) VALUES (?, ?, ?)";PreparedStatement insertStatement = connection.prepareStatement(insertSql);// set parameterfor (int i =10; i <= 10000; i++) {insertStatement.setInt(1, i);insertStatement.setInt(2, i);insertStatement.setString(3, Integer.toString(i));insertStatement.addBatch();     //  add sqlif(i % 1000 == 0) {insertStatement.executeBatch();     // execute sqlinsertStatement.clearBatch();   // clean batch}}long end = System.currentTimeMillis();System.out.println("cost time：" + (end - start));} catch (SQLException e) {e.printStackTrace();System.out.println("executeUpdated fail!");}connection.close();} catch (SQLException e) {e.printStackTrace();}}
}

执行结果如下：

说明：从执行结果可知，方式一批量处理时，耗时：2585

方式三：统一提交事务

使用 setAutoCommit(false) 关闭事务自提交，等待数据批量插入结束后，统一 commit；

import java.sql.*;public class prepareStatement_insert3 {public static void main(String[] args) {/* ----------------------------------------------------------------------- */// 1) connection mysqlString url = "jdbc:mysql://172.19.108.205:3306/jdbc?rewriteBatchedStatements=true";String username = "root";String password = "";// load drivetry {Class.forName("com.mysql.cj.jdbc.Driver");  // mys1ql 8.0 以前版本：Class.forName("com.mysql.jdbc.Driver");System.out.println("load driver succeed!");} catch (ClassNotFoundException e) {e.printStackTrace();System.out.println("load driver fail!");return;}try {long start = System.currentTimeMillis();    // start timeConnection connection = DriverManager.getConnection(url, username, password);System.out.println("Connected to the database!");/* ----------------------------------------------------------------------- */// 2) execute SQLtry {connection.setAutoCommit(false);String insertSql = "INSERT INTO t1 (c1, c2, c3) VALUES (?, ?, ?)";PreparedStatement insertStatement = connection.prepareStatement(insertSql);// set parameterfor (int i =10; i <= 10000; i++) {insertStatement.setInt(1, i);insertStatement.setInt(2, i);insertStatement.setString(3, Integer.toString(i));insertStatement.addBatch();     //  add sqlif(i % 1000 == 0) {insertStatement.executeBatch();     // execute sqlinsertStatement.clearBatch();   // clean batch}}connection.commit();long end = System.currentTimeMillis();System.out.println("cost time：" + (end - start));} catch (SQLException e) {e.printStackTrace();System.out.println("executeUpdated fail!");}connection.close();} catch (SQLException e) {e.printStackTrace();}}
}

执行结果如下：

说明：从执行结果可知，方式一批量处理时，耗时：1900

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/616206.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

护眼灯有蓝光吗？没有蓝光的护眼灯推荐

护眼灯有蓝光吗？没有蓝光的护眼灯推荐

现在的家长对于孩子的学习还是十分重视的&#xff0c;不仅会选择给他们报各种补习班、兴趣班&#xff0c;在学习设备方面也是尽可能地提供最好的&#xff0c;不管是各种文具还是良好的用光环境。为了拥有良好的光线条件&#xff0c;保护好孩子们的稚嫩的眼睛&#xff0c;他们会…
阅读更多...
强化学习应用（一）：基于Q-learning的无人机物流路径规划研究（提供Python代码）

强化学习应用（一）：基于Q-learning的无人机物流路径规划研究（提供Python代码）

一、Q-learning简介 Q-learning是一种强化学习算法&#xff0c;用于解决基于马尔可夫决策过程&#xff08;MDP&#xff09;的问题。它通过学习一个价值函数来指导智能体在环境中做出决策&#xff0c;以最大化累积奖励。 Q-learning算法的核心思想是通过不断更新一个称为Q值的…
阅读更多...
C语言——（printf和scanf介绍）

C语言——（printf和scanf介绍）

一.printf 1.基本用法 printf&#xff08;&#xff09;的作用是将参数文本输出的屏幕。如下&#xff1b; 2.占位符 printf&#xff08;&#xff09;可以在输出文本中指定占位符 &#xff0c;“占位符”&#xff0c;也就是这个位置可以用其他值代入。 如&#xff1a; …
阅读更多...
基于 IDEA 创建 Maven 的 Java SE 工程和 Java Web 工程

基于 IDEA 创建 Maven 的 Java SE 工程和 Java Web 工程

一、概念简介 Maven 工程相对之前的项目&#xff0c;多出一组 gavp 属性&#xff0c;gav 需要我们在创建项目的时候指定&#xff0c;p 有默认值&#xff0c;我们先行了解下这组属性的含义。 Maven 中的 GAVP 是指 GroupId、ArtifactId、Version、Packaging 等四个属性的缩写&am…
阅读更多...
刚买的助听器就弄丢了，不想白配，快来看看这8大助听器防丢小技巧

刚买的助听器就弄丢了，不想白配，快来看看这8大助听器防丢小技巧

我们知道助听器可以让听损人士重新听到美妙的声音和享受沟通的乐趣。但是&#xff0c;助听器也是一种很贵的物品&#xff0c;如果不小心弄丢了&#xff0c;就会让人心痛不已。 更有甚者&#xff0c;有些人因为害怕丢失助听器&#xff0c;而不敢佩戴助听器&#xff0c;错过了听力…
阅读更多...
解决Windows11 “我们无法设置移动热点”

解决Windows11 “我们无法设置移动热点”

目录 问题复现解决办法①启动网络适配器②打开移动热点③共享网络连接④连接移动热点总结 问题复现 因为交换机上网口限制&#xff0c;开发环境暂时没有WIFI设备&#xff0c;只有一根网线和一台笔记本电脑。于是开启笔记本电脑的WiFi共享服务。结果提示 “我们无法设置移动热点…
阅读更多...
7-35 有理数均值 分数 20

7-35 有理数均值 分数 20

每日一言 我们把世界看错&#xff0c;反说它欺骗了我们。 --飞鸟集 题目 本题要求编写程序&#xff0c;计算N个有理数的平均值。 输入格式&#xff1a; 输入第一行给出正整数N&#xff08;≤100&#xff09;&#xff1b;第二行中按照a1/b1 a2/b2 …的格式给出N个分数形式的…
阅读更多...
应急管理蓝皮书 |《应急预案数字化建设现状和发展建议》下篇

应急管理蓝皮书 |《应急预案数字化建设现状和发展建议》下篇

导读 《应急预案数字化建设现状和发展建议》&#xff1a;297-313页 《中国应急管理发展报告》系列蓝皮书由中央党校&#xff08;国家行政学院&#xff09;应急管理培训中心&#xff08;中欧应急管理学院&#xff09;联合社会科学文献出版社研创出版&#xff0c;本着“权威前沿…
阅读更多...
asp.net core项目发布到 iis上

asp.net core项目发布到 iis上

我们都知道与传统asp.net 项目比较&#xff0c;ASP.NET Core则完全不同&#xff0c;它并不是运行在IIS的工作进程中&#xff0c;而是独立运行的。它运行于控制台应用程序之中&#xff0c;控制台中则运行了Kestrel Web服务器组件。Kestrel作为一款.NET Web服务器的实现&#xff…
阅读更多...
【计算机网络】--集线器，路由器，交换机对比

【计算机网络】--集线器，路由器，交换机对比

&#x1f3b5;1.集线器 &#x1f308;1.1集线器概念 集线器是一种网络设备&#xff0c;广泛应用于计算机局域网环境中。它通常具有多个以太网接口&#xff0c;用于将多个计算机或其他网络设备连接在一起&#xff0c;形成一个网络拓扑结构。 &#x1f308;2.集线器的作用 集线器…
阅读更多...
2024年CES展会都有些啥？亮点集锦都在这里

2024年CES展会都有些啥？亮点集锦都在这里

&#x1f4a1; 大家好&#xff0c;我是可夫小子&#xff0c;《小白玩转ChatGPT》专栏作者&#xff0c;关注AIGC、读书和自媒体。 CES在科技界是一场盛会&#xff0c;被誉为科技界的春晚&#xff0c;展会上前沿的技术、概念的产品吸引不少关注。2024年CES是在2023年大语言模型…
阅读更多...
uniapp 实战 -- 创建 uni-admin 项目，部署到 uniCloud 前端网页托管（免费云空间）

uniapp 实战 -- 创建 uni-admin 项目，部署到 uniCloud 前端网页托管（免费云空间）

创建 uni-admin 项目 可见 只能创建一个超级管理员&#xff0c;创建过后&#xff0c;登录页将不再显示 注册管理员账号 部署到 uniCloud 前端网页托管 部署成功&#xff0c;访问地址可预览效果&#xff01; https://static-mp-7b65169e-151f-4fbb-a5ba-2125d4f56e3f.next.bs…
阅读更多...
俩万字详解C++STL期末复习知识点（C++STL课本源码私信可得）

俩万字详解C++STL期末复习知识点（C++STL课本源码私信可得）

邸老师复习建议 复习注意事项 1 不考死记硬背的题&#xff0c;比如名词解释。 2 选择题重点考核宏观性、综合性的问题&#xff0c;比如&#xff1a;把电话通讯录存入容器&#xff0c;该选哪一个容器&#xff1f; 3 选择题重点考核理解性的问题&#xff0c;比如&#xff0c;…
阅读更多...
TCP/IP 网络模型

TCP/IP 网络模型

TCP/IP 网络通常是由上到下分成 4 层&#xff0c;分别是应用层&#xff0c;传输层&#xff0c;网络层和网络接口层。 应用层 应用层专注于为用户提供应用功能&#xff0c;比如 HTTP、FTP、Telnet、DNS、SMTP等。我们电脑或手机使用的应用软件都是在应用层实现。应用层是不用去关…
阅读更多...
波动，热传导，扩散方程建立

波动，热传导，扩散方程建立

数学物理方程是从自然科学的各个领域和工程技术领域中导出的偏微分方程和积分方程.在这些以偏微分方程为基础的数学模型中&#xff0c;二阶线性偏微分方程中的三个典型方程与定解条件的建立、解法及其应用&#xff0e;描述振动和波动过程的波动方程、描述输运过程的热传导&…
阅读更多...
【grpc】利用protobuf实现java或kotlin调用python脚本，含实现过程和全部代码

【grpc】利用protobuf实现java或kotlin调用python脚本，含实现过程和全部代码

前言 在一些特殊场景中&#xff0c;我们可能需要使用java或者其他任意语言调用python脚本或sdk等。本文的需求衍生也不例外于此&#xff0c;python端有sdk&#xff0c;但只能在python中调用&#xff0c;于是就有了本文章。 常见的调用方式如jython、python提供http rest接口、…
阅读更多...
照片模糊如何变清晰不妨试试这款软件吧

照片模糊如何变清晰不妨试试这款软件吧

很多人希望能把模糊的图片或照片变得很清晰&#xff0c;或者把一个只有几十KB的小图变成有几M大小的高清大图。一般来说&#xff0c;一张模糊或打了马赛克的图片本身很多细节信息就没有或被删除了&#xff0c;就像一本书缺了很多页&#xff0c;我们是可能百分百的还原出它原来的…
阅读更多...
知道IP怎么反查域名？这几个方法一查一个准！

知道IP怎么反查域名？这几个方法一查一个准！

知道网络IP怎么反查出真实域名来&#xff1f;给大家分享几个我常用的方法&#xff0c;就算你不懂技术你都能查得出来&#xff01; 一、fofa 这是一个白帽黑客非常喜欢用的社工平台&#xff0c;只要你输入IP就能查到很多背后的信息。 传送门&#xff1a;https://fofa.info 二…
阅读更多...
GPT Store开业大吉：一场AI技术与创新的盛宴

GPT Store开业大吉：一场AI技术与创新的盛宴

就在1.11 日&#xff0c;ChatGPT 正式上线 GPT Store &#xff01; OpenAI CEO 山姆奥特曼第一时间确认了这个消息&#xff1a; 自从GPTs的概念提出以来&#xff0c;短短两个月内&#xff0c;全球用户已经创造了超过300万个GPTs。 点击 GPT Store 或者进入ChatGpt页面&am…
阅读更多...
【Vue】引入路径正确，不影响正常运行但文件爆红

【Vue】引入路径正确，不影响正常运行但文件爆红

现象&#xff1a;引入路径正确但文件爆红&#xff0c;不影响运行但不美观&#xff08;按住Ctrl可以跳转到该文件&#xff0c;关闭后过段时间再打开还是爆红&#xff09; 原因 &#xff08;1&#xff09;相对路径使用了不正确的大小写 &#xff08;2&#xff09;项目不支持force…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023