当前位置： 首页 > news >正文

JDBC的 PreparedStatement 的用法和解释

news 2025/7/22 0:20:08

文章目录

  • 前言
  • 1、封装数据库连接和关闭操作
    • 数据库配置文件 config.properties
  • 2、批量添加操作
  • 3、查询操作
  • 4、修改和删除操作
  • 总结

前言

  • PreparedStatement是预编译的,对于批量处理可以大大提高效率. 也叫JDBC存储过程

1、封装数据库连接和关闭操作

package org.springblade.modules.data.util;import lombok.extern.slf4j.Slf4j;import java.io.IOException;
import java.io.InputStream;
import java.sql.*;
import java.util.*;/*** 数据库连接工具类*/
@Slf4j
public class JdbcOracleTemplatedct {private static String url;private static String username;private static String password;private static String driver;static {// 加载配置文件InputStream is = JdbcOracleTemplatedct.class.getClassLoader().getResourceAsStream("config.properties");Properties pro = new Properties();try {pro.load(is);url = pro.getProperty("jdbc3.url");username = pro.getProperty("jdbc3.username");password = pro.getProperty("jdbc3.password");driver = pro.getProperty("jdbc3.driverClassName");} catch (IOException e) {e.printStackTrace();log.info(e.getMessage(), e);log.info("加载配置文件失败!");}// 注册驱动try {Class.forName(driver);} catch (ClassNotFoundException e) {e.printStackTrace();log.info(e.getMessage(), e);}}public static Connection getConnection() {Connection conn = null;try {conn = DriverManager.getConnection(url, username, password);// 把jdbc 链接 设置成 非自动提交conn.setAutoCommit(false);} catch (SQLException e) {e.printStackTrace();log.info(e.getMessage(), e);log.info("获得链接失败!");}return conn;}public static void closeAll(Statement stmt, Connection conn) {if (stmt != null) {try {stmt.close();} catch (SQLException e) {e.printStackTrace();}}if (conn != null) {try {conn.close();// 关闭} catch (SQLException e) {e.printStackTrace();}}}public static void closeResAll(ResultSet rs, Statement stmt, Connection conn) {if (rs != null) {try {rs.close();// 关闭} catch (SQLException e) {e.printStackTrace();}}if (stmt != null) {try {stmt.close();} catch (SQLException e) {e.printStackTrace();}}if (conn != null) {try {conn.close();// 关闭} catch (SQLException e) {e.printStackTrace();}}}public static boolean createTable(String sqltemplet) {Connection conn = getConnection();long starttime = System.currentTimeMillis();Statement statement = null;boolean isok = false;try {try {statement = conn.createStatement();} catch (SQLException e) {e.printStackTrace();log.info(e.getMessage(), e);log.info("执行批处理时    创建预状态通道失败!");}statement.executeUpdate(sqltemplet);isok = true;log.info(" 执行成功一次,总使用时间："+ (System.currentTimeMillis() - starttime) + "ms");} catch (SQLException e) {e.printStackTrace();log.info(e.getMessage(), e);log.info("在 预 状 态 通 道 下 执 行 批 出 操 作 失 败!");} finally {closeAll(statement, conn);}return isok;}/*** 基于预状态通道执行批处理操作** @param sqltemplet* @param params* @return*/public static boolean batchData(String sqltemplet, List<List<Object>> params) {Connection conn = getConnection();long starttime = System.currentTimeMillis();PreparedStatement statement = null;boolean isok = false;try {try {statement = conn.prepareStatement(sqltemplet);} catch (SQLException e) {e.printStackTrace();log.info(e.getMessage(), e);log.info("执行批处理时    创建预状态通道失败!");}if (params != null && !params.isEmpty()) {for (List<Object> plist : params) {int size = plist.size();for (int i = 0; i < size; i++) {statement.setObject(i + 1, plist.get(i));}statement.addBatch();}statement.executeBatch();conn.commit();statement.clearParameters();isok = true;log.info(" 执行成功一次,总使用时间："+ (System.currentTimeMillis() - starttime) + "ms");}} catch (SQLException e) {e.printStackTrace();log.info(e.getMessage(), e);log.info("在 预 状 态 通 道 下 执 行 批 出 操 作 失 败!");try {conn.rollback();} catch (SQLException e1) {e1.printStackTrace();}} finally {closeAll(statement, conn);}return isok;}/*** 基于预状态通道执行批处理操作** @param sqltemplet* @param params* @return*/public synchronized  static boolean batchAllData(String sqltemplet,List<List<Object>> params) {try {Thread.sleep(500);} catch (InterruptedException e2) {e2.printStackTrace();}Connection conn = getConnection();long starttime = System.currentTimeMillis();PreparedStatement statement = null;boolean isok = false;try {try {statement = conn.prepareStatement(sqltemplet);} catch (SQLException e) {e.printStackTrace();log.info(e.getMessage(), e);log.info("执行批处理时    创建预状态通道失败!");}if (params != null && !params.isEmpty()) {int size2 = params.size();for (int j = 0; j < size2; j++) {List<Object> plist = params.get(j);int size = plist.size();for (int i = 0; i < size; i++) {statement.setObject(i + 1, plist.get(i));}statement.addBatch();if (j % 1000 == 0) {statement.executeBatch();conn.commit();statement.clearParameters();}}statement.executeBatch();conn.commit();statement.clearParameters();isok = true;log.info(" 执行成功一次,总使用时间："+ (System.currentTimeMillis() - starttime) + "ms");}} catch (SQLException e) {e.printStackTrace();log.info(e.getMessage(), e);log.info("在 预 状 态 通 道 下 执 行 批 出 操 作 失 败!");try {conn.rollback();} catch (SQLException e1) {e1.printStackTrace();}} finally {closeAll(statement, conn);}return isok;}public static List<Map<String, Object>> selectAll(String querysql) {List<Map<String, Object>> list = new ArrayList<>();long starttime = System.currentTimeMillis();Connection conn = getConnection();Statement statement = null;ResultSet rs = null;try {statement = conn.createStatement();rs = statement.executeQuery(querysql);ResultSetMetaData data = rs.getMetaData();int columnCount = data.getColumnCount();// System.out.println(columnCount);while (rs.next()) {int i = 1;Map<String, Object> map = new HashMap<String, Object>();while (i <= columnCount) {String name = data.getColumnName(i);// System.out.println(name + " : " + rs.getObject(i));if (rs.getObject(i) == null || "".equals(rs.getObject(i))) {map.put(name, "");} else {map.put(name, rs.getObject(i));}i++;}list.add(map);}log.info(" 执行成功一次,总使用时间："+ (System.currentTimeMillis() - starttime) + "ms");} catch (SQLException e) {e.printStackTrace();log.info(e.getMessage(), e);} finally {closeResAll(rs, statement, conn);}return list;}public static void batchUpdate(String sql) {Connection conn = null;Statement ps = null;try {conn = getConnection();ps = conn.createStatement();int executeUpdate = ps.executeUpdate(sql);conn.commit();} catch (SQLException e) {e.printStackTrace();log.error(e.getMessage(), e);try {conn.rollback();} catch (SQLException e1) {log.error(e1.getMessage(), e1);}} finally {try {ps.close();} catch (SQLException e) {log.error(e.getMessage(), e);}try {conn.close();} catch (SQLException e) {log.error(e.getMessage(), e);}}}
}

数据库配置文件 config.properties

jdbc3.driverClassName = oracle.jdbc.OracleDriver
jdbc3.url = jdbc:oracle:thin:@172.0.0.1:1521:rdt1
jdbc3.username = root
jdbc3.password = root

2、批量添加操作

public static void main(String[] args) {Connection conn = JdbcOracleTemplatedct.getConnection();PreparedStatement statement = null;String insertSql = "INSERT INTO your_table (column1, column2) VALUES (?, ?)";try {statement = conn.prepareStatement(insertSql);// 假设我们要插入10条数据for (int i = 1; i <= 10; i++) {statement.setString(1, "Value" + i + "Column1");statement.setInt(2, i);statement.addBatch(); // 将SQL语句添加到批处理中}// 执行批处理int[] count = statement.executeBatch();System.out.println("插入了" + count.length + "条数据");} catch (SQLException e) {e.printStackTrace();log.error("添加执行失败", e);} finally {if (statement != null) {try {statement.close();} catch (SQLException e) {e.printStackTrace();}}}}

3、查询操作

  • 如果执行的是查询操作，使用executeQuery方法，并处理结果集。
ResultSet resultSet = statement.executeQuery();
while (resultSet.next()) {// 处理结果集
}

4、修改和删除操作

int rowsAffected = statement.executeUpdate();

总结

  • 通过使用PreparedStatement和executeBatch，你可以提高Java应用程序与数据库交互的性能。特别是当你需要执行大量的增删改操作时，批处理可以显著减少与数据库的交互次数，从而提高效率。同时，注意正确处理资源（如Connection、PreparedStatement、ResultSet）的打开和关闭，以及异常处理，以确保代码的健壮性。

如果此篇文章有帮助到您, 希望打大佬们能关注、点赞、收藏、评论支持一波，非常感谢大家！
如果有不对的地方请指正!!!

http://www.lryc.cn/news/354928.html

相关文章：

  • LeetCode 面试150
  • xmake+xrepo自建仓库添加交叉编译工具链
  • 论文阅读》学习了解自己：一个粗略到精细的个性化对话生成的人物感知训练框架 AAAI 2023
  • [Java EE] 网络编程与通信原理(三):网络编程Socket套接字(TCP协议)
  • MyBatis懒加载数据（大批量数据处理）
  • MySQL--联合索引应用细节应用规范
  • 【spring boot+Lazy ORM+mysql】开发一个数据库管理系统实现对应数据库数据查看和修改
  • 知识分享：隔多久查询一次网贷大数据信用报告比较好?
  • 【Day8：JAVA字符串的学习】
  • jetcache缓存
  • SQLSyntaxErrorException: FUNCTION dbname.to_timestamp does not exist
  • Borel-Cantelli 引理
  • 算法训练营第四十一天 | LeetCode 509 斐波那契数列、LeetCode 70 爬楼梯、LeetCode 746 使用最小花费爬楼梯
  • 网络其他重要协议（DNS、ICMP、NAT）
  • 利用PyCSP3库（含大量全局约束）进行组合约束建模
  • 解决updateByExample时属性值异常的问题（部分属性值没有使用占位符?进行占位，而是变成了属性的名称）
  • [C++][algorithm][Eigen] 基于Eigen实现Softmax函数
  • 一招教大家，如何移除受保护的excel工作表的编辑权限限制？
  • Python 全栈体系【四阶】（五十三）
  • 民国漫画杂志《时代漫画》第27期.PDF
  • 图论（四）—最短路问题（Dijkstra）
  • 用友NC linkVoucher SQL注入漏洞复现
  • 部署Prometheus + Grafana实现监控数据指标
  • GEE27：遥感数据可用数据源计算及条带号制作
  • FURNet问题
  • 抖音小店怎么对接达人合作？达人带货的细节分享，附邀约达人话术
  • 迈向未来：Web3 技术开发的无限可能
  • Python应用开发——30天学习Streamlit Python包进行APP的构建（2）
  • Leecode热题100---46：全排列（递归）
  • Android 多语言