批量更新工具允许将多个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对象类似。
网友评论