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

2024-01-13 04:52
文章标签 使用 jdbc 场景 demo preparestatement

本文主要是介绍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

这篇关于JDBC PrepareStatement 的使用（附各种场景 demo）的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/600308。

相关文章

C语言中联合体union的使用

C语言中联合体union的使用

本文编辑整理自： http://bbs.chinaunix.net/forum.php?mod=viewthread&tid=179471 一、前言 “联合体”(union）与“结构体”(struct)有一些相似之处。但两者有本质上的不同。在结构体中,各成员有各自的内存空间, 一个结构变量的总长度是各成员长度之和。而在“联合”中,各成员共享一段内存空间, 一个联合变量
阅读更多...
Tolua使用笔记（上）

Tolua使用笔记（上）

目录   1.准备工作 2.运行例子 01.HelloWorld：在C#中，创建和销毁Lua虚拟机 和 简单调用。 02.ScriptsFromFile：在C#中，对一个lua文件的执行调用 03.CallLuaFunction：在C#中，对lua函数的操作 04.AccessingLuaVariables：在C#中，对lua变量的操作 05.LuaCoroutine：在Lua中，
阅读更多...
Vim使用基础篇

Vim使用基础篇

本文内容大部分来自 vimtutor，自带的教程的总结。在终端输入vimtutor 即可进入教程。 先总结一下，然后再分别介绍正常模式，插入模式，和可视模式三种模式下的命令。 目录 看完以后的汇总 1.正常模式（Normal模式） 1.移动光标 2.删除 3.【:】输入符 4.撤销 5.替换 6.重复命令【. ; ,】 7.复制粘贴 8.缩进 2.插入模式 INSERT
阅读更多...
详细分析Springmvc中的@ModelAttribute基本知识（附Demo）

详细分析Springmvc中的@ModelAttribute基本知识（附Demo）

目录 前言1. 注解用法1.1 方法参数1.2 方法1.3 类 2. 注解场景2.1 表单参数2.2 AJAX请求2.3 文件上传 3. 实战4. 总结 前言 将请求参数绑定到模型对象上，或者在请求处理之前添加模型属性 可以在方法参数、方法或者类上使用 一般适用这几种场景： 表单处理：通过 @ModelAttribute 将表单数据绑定到模型对象上预处理逻辑：在请求处理之前
阅读更多...
Lipowerline5.0 雷达电力应用软件下载使用

Lipowerline5.0 雷达电力应用软件下载使用

1.配网数据处理分析 针对配网线路点云数据，优化了分类算法，支持杆塔、导线、交跨线、建筑物、地面点和其他线路的自动分类；一键生成危险点报告和交跨报告；还能生成点云数据采集航线和自主巡检航线。 获取软件安装包联系邮箱:2895356150@qq.com，资源源于网络，本介绍用于学习使用，如有侵权请您联系删除！ 2.新增快速版，简洁易上手 支持快速版和专业版切换使用，快速版界面简洁，保留主
阅读更多...
如何免费的去使用connectedpapers？

如何免费的去使用connectedpapers？

免费使用connectedpapers 1. 打开谷歌浏览器2. 按住ctrl+shift+N,进入无痕模式3. 不需要登录（也就是访客模式）4. 两次用完，关闭无痕模式（继续重复步骤 2 - 4） 1. 打开谷歌浏览器 2. 按住ctrl+shift+N,进入无痕模式 输入网址：https://www.connectedpapers.com/ 3. 不需要登录（也就是
阅读更多...
亮相WOT全球技术创新大会，揭秘火山引擎边缘容器技术在泛CDN场景的应用与实践

亮相WOT全球技术创新大会，揭秘火山引擎边缘容器技术在泛CDN场景的应用与实践

2024年6月21日-22日，51CTO“WOT全球技术创新大会2024”在北京举办。火山引擎边缘计算架构师李志明受邀参与，以“边缘容器技术在泛CDN场景的应用和实践”为主题，与多位行业资深专家，共同探讨泛CDN行业技术架构以及云原生与边缘计算的发展和展望。 火山引擎边缘计算架构师李志明表示：为更好地解决传统泛CDN类业务运行中的问题，火山引擎边缘容器团队参考行业做法，结合实践经验，打造火山
阅读更多...
Toolbar+DrawerLayout使用详情结合网络各大神

Toolbar+DrawerLayout使用详情结合网络各大神

最近也想搞下toolbar+drawerlayout的使用。结合网络上各大神的杰作，我把大部分的内容效果都完成了遍。现在记录下各个功能效果的实现以及一些细节注意点。 这图弹出两个菜单内容都是仿QQ界面的选项。左边一个是drawerlayout的弹窗。右边是toolbar的popup弹窗。 开始实现步骤详情： 1.创建toolbar布局跟drawerlayout布局 <?xml vers
阅读更多...
C#中，decimal类型使用

C#中，decimal类型使用

在Microsoft SQL Server中numeric类型，在C#中使用的时候，需要用decimal类型与其对应，不能使用int等类型。 SQL：numeric C#：decimal
阅读更多...
探索Elastic Search：强大的开源搜索引擎，详解及使用

探索Elastic Search：强大的开源搜索引擎，详解及使用

🎬 鸽芷咕：个人主页  🔥 个人专栏: 《C++干货基地》《粉丝福利》 ⛺️生活的理想，就是为了理想的生活! 引入 全文搜索属于最常见的需求，开源的 Elasticsearch （以下简称 Elastic）是目前全文搜索引擎的首选，相信大家多多少少的都听说过它。它可以快速地储存、搜索和分析海量数据。就连维基百科、Stack Overflow、
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2