第十四章 批量更新(Batch Updates)

批量更新工具允许将多个SQL语句一次提交到数据源进行处理。 提交多个SQL语句,而不是单独提交可以大大提高性能。 Statement,PreparedStatement和CallableStatement对象可用于提交批量更新

14.1 批量更新说明

14.1.1 Statements

批量更新工具允许Statement对象将一组异构SQL语句作为单个单元或批处理一起提交给底层数据源

由于JDBC 2.0 API,Statement对象能够跟踪可以一起提交执行的命令列表(或批处理)。 创建Statement对象时,其关联批次为空。 应用程序通过调用方法Statement.addBatch并为其添加要添加的SQL语句,一次向命令添加一个语句的批处理。 任何添加到批处理的命令都必须返回一个简单的更新计数,不能返回一个ResultSet。

如果一个应用程序决定不提交一批为一个语句构造的命令,它可以调用方法Statement.clearBatch清除所有命令的批次

在代码示例14-1中,将虚拟公司数据库中插入新员工所需的所有SQL语句作为单个批次提交

con.setAutoCommit(false);
Statement stmt = con.createStatement();
stmt.addBatch("INSERT INTO employees VALUES (1000, 'Joe Jones')");
stmt.addBatch("INSERT INTO departments VALUES (260, 'Shoe')");
stmt.addBatch("INSERT INTO emp_dept VALUES (1000, 260)");
// submit a batch of update commands for execution
int[] updateCounts = stmt.executeBatch();

在该示例中,自动提交模式被禁用,以防止在调用Statement.executeBatch时驱动程序提交事务。 禁用自动提交允许应用程序在发生错误的情况下决定是否提交事务,并且批处理中的某些命令无法成功处理。 因此,在批量更新时,应始终关闭自动提交。 当发生错误并且auto-commit为true时,executeBatch的提交行为总是被实现定义

在一批语句中设置保存点是不可能的,以便部分恢复。 如果在方法executeBatch被调用之前的任何时候设置了一个保存点,那么在已经添加到批处理的任何语句都被执行之前被设置

尽管本节的重点是使用Statement对象进行批量更新,但下面的讨论也适用于PreparedStatement和CallableStatement对象

笔记:如果您的数据库支持返回可能超过Integer.MAX_VALUE的更新计数,则使用方法executeLargeBatch

14.1.2 成功执行

Statement.executeBatch方法将语句的批处理提交给底层数据源以执行。 批次命令按照批次的顺序执行(至少在逻辑上)。 当批处理中的所有命令成功执行时,executeBatch方法返回一个整数数组,其中包含批处理中每个命令的一个条目

数组中的条目根据命令的处理顺序进行排序(再次与命令最初添加到批处理的顺序相同)。 当批处理中的所有命令都已成功执行时,更新计数数组中的条目可能具有以下值:

  • 0或更大:该命令被成功处理,该值是一个更新计数,指示数据库中受命令执行影响的行数
  • Statement.SUCCESS_NO_INFO:该命令已成功处理,但受影响的行数未知

调用方法executeBatch将打开调用Statement对象的当前结果集。 executeBatch返回后,该语句的批次将重置为空。 当语句的批处理为非空时,executeQuery,executeUpdate和execute方法的行为是实现定义的。

只有DDL和DML命令才能返回简单的更新计数。 如果批处理中的任何命令无法正常执行或命令尝试返回结果集,那么executeBatch将抛出BatchUpdateException。 当抛出BatchUpdateException时,应用程序可以调用BatchUpdateException.getUpdateCounts方法来获取描述批处理执行结果的更新计数的整数数组

笔记:关于Statement.getGeneratedKeys是否会在调用executeBatch或executeLargeBatch方法后返回生成的值是实现定义的

14.1.3 执行期间处理故障

执行命令失败后,JDBC驱动程序可能会或可能不会继续处理批处理剩余的命令。 但是,JDBC驱动程序必须始终提供与特定数据源相同的行为。 例如,驱动程序在一个批次发生故障后无法继续处理,而不能继续处理另一个批次

如果驱动程序在第一次失败后停止处理,则由BatchUpdateException.getUpdateCounts方法返回的数组将始终包含比批处理中的语句少的条目。 由于语句按照添加到批处理的顺序执行,如果数组包含N个元素,这意味着在调用executeBatch时,批处理中的前N个元素被成功处理。

当驱动程序在出现故障时继续处理时,方法BatchUpdateException.getUpdateCounts返回的数组中的元素数量将等于批处理中的命令数。 当抛出BatchUpdateException对象并且驱动程序在失败后继续处理时,更新计数数组将包含以下BatchUpdateException常量

  • Statement.EXECUTE_FAILED :该命令无法成功执行。 对于由于某些原因无法处理的命令也会返回此值 - 这样的命令会隐式失败

在故障后不继续处理的JDBC驱动程序从未在更新计数数组中返回Statement.EXECUTE_FAILED。 这种类型的驱动程序只需返回一个包含成功处理的每个命令的条目的状态数组

基于JDBC技术的应用程序可以区分一个继续处理故障之后的JDBC驱动程序,而不是通过检查BatchUpdateException.getUpdateCounts返回的数组的大小。 继续处理的JDBC驱动程序总是返回一个包含批次中每个元素的一个条目的数组。 失败后不继续处理的JDBC驱动程序将始终返回一个数组,其数量少于批处理中的命令数

如果您的数据库支持返回可能超过Integer.MAX_VALUE的更新计数,请使用方法BatchUpdateException.getLargeUpdateCounts

14.1.4 PreparedStatement Objects

当使用PreparedStatement对象时,批处理中的命令由参数化的SQL语句和相关参数组组成。 批处理更新工具与PreparedStatement对象一起使用,将多组输入参数值与单个PreparedStatement对象相关联。 然后可以将参数值集合及其相关联的参数化更新命令发送到底层数据源引擎,以作为单个单元执行

将两个新的员工记录作为单个批次插入到数据库中。 PreparedStatement接口设置器方法用于创建每个参数集,每个员工一个。 PreparedStatement.addBatch方法将一组参数添加到当前命令中

con.setAutoCommit(false);
PreparedStatement stmt = con.prepareStatement(
"INSERT INTO employees VALUES (?, ?)");
stmt.setInt(1, 2000);
stmt.setString(2, "Kelly Kaufmann");stmt.addBatch();
stmt.setInt(1, 3000);
stmt.setString(2, "Bill Barnes");
stmt.addBatch();
// submit the batch for execution
int[] updateCounts = stmt.executeBatch();

最后,调用PreparedStatement.executeBatch方法将更新提交给底层数据源。 调用此方法将清除该语句的关联命令列表。 PreparedStatement.executeBatch返回的数组包含批处理中每组参数的元素,与Statement对象的情况类似。 每个元素包含更新计数或通用“成功”指示符SUCCESS_NO_INFO

在PreparedStatement对象的情况下,错误处理与Statement对象的错误处理相同。 一旦发生错误,某些驱动程序可能会停止处理,而其他驱动程序可能会继续处理批次的其余部分

与Statement对象一样,BatchUpdateException.getUpdateCounts返回的数组中的元素数指示驱动程序是否在故障后继续处理。 相同的三个数组元素值是可能的:0或更高,Statement.SUCCESS_NO_INFO或Statement.EXECUTE_FAILED。 数组中条目的顺序与将命令添加到批次的顺序相同。

如果您的数据库支持返回可能超过Integer.MAX_VALUE的更新计数,请使用executeLargeBatch和BatchUpdateException.getLargeUpdateCounts

14.1.5 CallableStatement Objects

批处理更新工具与CallableStatement对象一样,与PreparedStatement对象一样。 多组输入参数值可能与CallableStatement对象相关联,并一起发送到底层数据源

使用具有可调用语句的批量更新工具调用的存储过程必须返回最多一个更新计数,否则返回数组元素值将为Statement.SUCCESS_NO_INFO。 另外,可批量存储过程可能没有OUT或INOUT参数。 如果违反限制,CallableStatement.executeBatch方法将抛出SQLException,而不是SQLException的子类。 错误处理与PreparedStatement对象类似。

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 219,753评论 6 508
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 93,668评论 3 396
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 166,090评论 0 356
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 59,010评论 1 295
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 68,054评论 6 395
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 51,806评论 1 308
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 40,484评论 3 420
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 39,380评论 0 276
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 45,873评论 1 319
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 38,021评论 3 338
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 40,158评论 1 352
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 35,838评论 5 346
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 41,499评论 3 331
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 32,044评论 0 22
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 33,159评论 1 272
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 48,449评论 3 374
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 45,136评论 2 356

推荐阅读更多精彩内容

  • 本节介绍Statement接口及其子类PreparedStatement和CallableStatement。 它...
    zlb阅读 1,165评论 0 0
  • 1. Java基础部分 基础部分的顺序:基本语法,类相关的语法,内部类的语法,继承相关的语法,异常的语法,线程的语...
    子非鱼_t_阅读 31,647评论 18 399
  • 本人的环境为Myeclipse10、MySQL5.7.15 本文包括:简介JDBC编程步骤打通数据库程序详解—Dr...
    廖少少阅读 3,948评论 7 39
  • JDBC简介 SUN公司为了简化、统一对数据库的操作,定义了一套Java操作数据库的规范,称之为JDBC。JDBC...
    奋斗的老王阅读 1,520评论 0 51
  • 偶尔在翻书的时候看到了《广陵散》于是到网易云搜了这首曲子,古琴古筝,各有各的韵味。听了古筝版,甚觉惊艳,不禁想到了...
    PhoenixChen阅读 99评论 0 0