Java JDBC批量执行executeBatch方法详解-6ren

Java JDBC批量执行executeBatch方法详解

转载作者：qq735679552 更新时间：2022-09-27 22:32:09

CFSDN坚持开源创造价值，我们致力于搭建一个资源共享平台，让每一个IT人在这里找到属于你的精彩世界.

这篇CFSDN的博客文章Java JDBC批量执行executeBatch方法详解由作者收集整理，如果你对这篇文章有兴趣，记得点赞哟.

JDBC事务

在数据库中,所谓事务是指一组逻辑操作单元,使数据从一种状态变换到另一种状态。为确保数据库中数据的一致性,数据的操纵应当是离散的成组的逻辑单元:当它全部完成时,数据的一致性可以保持,而当这个单元中的一部分操作失败,整个事务应全部视为错误,所有从起始点以后的操作应全部回退到开始状态.

事务的操作:先定义开始一个事务,然后对数据作修改操作,这时如果提交(COMMIT),这些修改就永久地保存下来,如果回退(ROLLBACK),数据库管理系统将放弃您所作的所有修改而回到开始事务时的状态.

事务的ACID属性

1. 原子性（Atomicity）原子性是指事务是一个不可分割的工作单位，事务中的操作要么都发生，要么都不发生。。

2. 一致性（Consistency）事务必须使数据库从一个一致性状态变换到另外一个一致性状态。(数据不被破坏) 。

3. 隔离性（Isolation）事务的隔离性是指一个事务的执行不能被其他事务干扰，即一个事务内部的操作及使用的数据对并发的其他事务是隔离的，并发执行的各个事务之间不能互相干扰.

4. 持久性（Durability）。

持久性是指一个事务一旦被提交，它对数据库中数据的改变就是永久性的，接下来的其他操作和数据库故障不应该对其有任何影响.

在JDBC中，事务默认是自动提交的，每次执行一个 SQL 语句时，如果执行成功，就会向数据库自动提交，而不能回滚。

为了让多个 SQL 语句作为一个事务执行:

执行语句前调用 Connection 对象的 setAutoCommit(false); 以取消自动提交事务
在所有的 SQL 语句都成功执行后，调用 commit(); 方法提交事务
在出现异常时，调用 rollback(); 方法回滚事务。

JDBC批量执行

当需要成批插入或者更新记录时。可以采用Java的批量更新机制，这一机制允许多条语句一次性提交给数据库批量处理。通常情况下比单独提交处理更有效率。

JDBC的批量处理语句包括下面两个方法:

addBatch(String)：添加需要批量处理的SQL语句或是参数；。

executeBatch();执行批量处理语句；。

clearBatch();清除批量打包。

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

多条SQL语句的批量处理；。

 
    ? 
   
         for 
         ( 
         int 
         i =  
         1 
         ; i <  
         5000 
         ; i++) { 
        
         sql =  
         "insert into person(id,name,email) values(" 
         + i 
         ",'name" 
         + i +  
         "','email" 
         + i +  
         "')" 
         ; 
        
         stmt.addBatch(sql); 
        
         if 
         ((i+ 
         1 
         )% 
         1000 
         == 
         0 
         ){ 
        
         //批量处理 
        
         stmt.executeBatch(); 
        
         //清除stmt中积攒的参数列表 
        
         stmt.clearBatch(); 
        
         } 
        
         }

一个SQL语句的批量传参；。

 
    ? 
   
         for 
         ( 
         int 
         i= 
         1 
         ;i< 
         100000 
         ;i++){ 
        
         pstmt.setInt( 
         1 
         , i); 
        
         pstmt.setString( 
         2 
         ,  
         "name" 
         +i); 
        
         pstmt.setString( 
         3 
         ,  
         "email" 
         +i); 
        
         pstmt.addBatch(); 
        
         if 
         ((i+ 
         1 
         )% 
         1000 
         == 
         0 
         ){ 
        
         //批量处理 
        
         pstmt.executeBatch(); 
        
         //清空pstmt中积攒的sql 
        
         pstmt.clearBatch(); 
        
         } 
        
         }

JDBC执行SQL语句，有两个处理的接口，一个PreparedStatement,Statement,一般操作JDBC比较用得多的还是PreparedStatement 。

不过在执行批量，PreparedStatement有点不够Statement 。

 
    ? 
   
         ps = conn.prepareStatement(sql); 
        
         for 
         ( 
         int 
         i =  
         0 
         ;i< 
         10 
         ;i++){ 
        
         ps.setString( 
         1 
         , 
         "1" 
         ); 
        
         //PreparedStatement批处理方式一 
        
         ps.addBatch(); 
        
         } 
        
         //PreparedStatement批处理方式二 
        
         ps.addBatch( 
         "静态SQL" 
         ); 
        
         ps.executeBatch();

这个是正常执行的。

可是把PreparedStatement放到里面就没效了，以下:

 
    ? 
   
         for 
         ( 
         int 
         i =  
         0 
         ;i< 
         10 
         ;i++){ 
        
         ps = conn.prepareStatement(sql); 
        
         ps.setString( 
         1 
         , 
         "1" 
         ); 
        
         ps.addBatch(); 
        
         } 
        
         ps.executeBatch();

Statement适合循环赋值到sql，代码以下:

 
    ? 
   
         Statement st = conn.createStatement(); 
        
         for 
         ( 
         int 
         i =  
         0 
         ;i< 
         10 
         ;i++){ 
        
         st.addBatch( 
         "静态sql.........." 
         ); 
        
         } 
        
         st.executeBatch();

这个是正常执行所有的语句。

总结：造成这样的原因是

Statement st = conn.createStatement();这里可以不放SQL语句。

ps = conn.prepareStatement(sql);这个一定要放初始SQL语句。

JDBC的批处理不能加入select语句，否则会抛异常:

java.sql.BatchUpdateException: Can not issue SELECT via executeUpdate(). at com.MySQL.jdbc.StatementImpl.executeBatch(StatementImpl.java:1007) 。

到此这篇关于Java JDBC批量执行executeBatch方法详解的文章就介绍到这了,更多相关Java JDBC批量执行executeBatch内容请搜索我以前的文章或继续浏览下面的相关文章希望大家以后多多支持我！。

原文链接：https://www.cnblogs.com/shizhijie/p/7458813.html 。

最后此篇关于Java JDBC批量执行executeBatch方法详解的文章就讲到这里了,如果你想了解更多关于Java JDBC批量执行executeBatch方法详解的内容请搜索CFSDN的文章或继续浏览相关文章，希望大家以后支持我的博客！。

文章推荐： Spring使用@Autowired注解静态实例对象方式

文章推荐： ObjectMapper 如何忽略字段大小写

文章推荐： c/c++ 标准库 bind 函数详解

文章推荐：解决@Autowired注入static接口的问题

Ruby 方法() 方法
我想了解 Ruby 方法 methods() 是如何工作的。我尝试使用“ruby 方法”在 Google 上搜索，但这不是我需要的。我也看过 ruby-doc.org，但我没有找到这种方法。
VBS教程：方法-Test 方法
Test 方法对指定的字符串执行一个正则表达式搜索，并返回一个 Boolean 值指示是否找到匹配的模式。 object.Test(string) 参数 object 必选项。总是一个
VBS教程：方法-Replace 方法
Replace 方法替换在正则表达式查找中找到的文本。 object.Replace(string1, string2) 参数 object 必选项。总是一个 RegExp 对象的名称。
VBS教程：方法-Raise 方法
Raise 方法生成运行时错误 object.Raise(number, source, description, helpfile, helpcontext) 参数 object 应为
VBS教程：方法-Execute 方法
Execute 方法对指定的字符串执行正则表达式搜索。 object.Execute(string) 参数 object 必选项。总是一个 RegExp 对象的名称。 string
VBS教程：方法-Clear 方法
Clear 方法清除 Err 对象的所有属性设置。 object.Clear object 应为 Err 对象的名称。说明在错误处理后，使用 Clear 显式地清除 Err 对象。此
VBS教程：方法-CopyFile 方法
CopyFile 方法将一个或多个文件从某位置复制到另一位置。 object.CopyFile source, destination[, overwrite] 参数 object 必选
VBS教程：方法-Copy 方法
Copy 方法将指定的文件或文件夹从某位置复制到另一位置。 object.Copy destination[, overwrite] 参数 object 必选项。应为 File 或 F
VBS教程：方法-Close 方法
Close 方法关闭打开的 TextStream 文件。 object.Close object 应为 TextStream 对象的名称。说明下面例子举例说明如何使用 Close 方
VBS教程：方法-BuildPath 方法
BuildPath 方法向现有路径后添加名称。 object.BuildPath(path, name) 参数 object 必选项。应为 FileSystemObject 对象的名称
VBS教程：方法-GetFolder 方法
GetFolder 方法返回与指定的路径中某文件夹相应的 Folder 对象。 object.GetFolder(folderspec) 参数 object 必选项。应为 FileSy
VBS教程：方法-GetFileName 方法
GetFileName 方法返回指定路径（不是指定驱动器路径部分）的最后一个文件或文件夹。 object.GetFileName(pathspec) 参数 object 必选项。应为
VBS教程：方法-GetFile 方法
GetFile 方法返回与指定路径中某文件相应的 File 对象。 object.GetFile(filespec) 参数 object 必选项。应为 FileSystemObject
VBS教程：方法-GetExtensionName 方法
GetExtensionName 方法返回字符串，该字符串包含路径最后一个组成部分的扩展名。 object.GetExtensionName(path) 参数 object 必选项。应
VBS教程：方法-GetDriveName 方法
GetDriveName 方法返回包含指定路径中驱动器名的字符串。 object.GetDriveName(path) 参数 object 必选项。应为 FileSystemObjec
VBS教程：方法-GetDrive 方法
GetDrive 方法返回与指定的路径中驱动器相对应的 Drive 对象。 object.GetDrive drivespec 参数 object 必选项。应为 FileSystemO
VBS教程：方法-GetBaseName 方法
GetBaseName 方法返回字符串，其中包含文件的基本名 (不带扩展名), 或者提供的路径说明中的文件夹。 object.GetBaseName(path) 参数 object 必
VBS教程：方法-GetAbsolutePathName 方法
GetAbsolutePathName 方法从提供的指定路径中返回完整且含义明确的路径。 object.GetAbsolutePathName(pathspec) 参数 object
VBS教程：方法-FolderExists 方法
FolderExists 方法如果指定的文件夹存在，则返回 True；否则返回 False。 object.FolderExists(folderspec) 参数 object 必选项
VBS教程：方法-FileExists 方法
FileExists 方法如果指定的文件存在返回 True；否则返回 False。 object.FileExists(filespec) 参数 object 必选项。应为 FileS

qq735679552

个人简介

我是一名优秀的程序员,十分优秀！

作者热门文章

滴滴打车优惠券免费领取

全站热门文章

首页

博学

6Ren·AI

商城