JDBC提供了数据库batch处理的能力,在数据大批量操作(新增、删除等)的情况下可以大幅度提升系统的性能。
// 关闭自动执行
con.setAutoCommit(false);
Statement stmt = con.createStatement();
禁用了自动执行模式,从而在调用 Statement.executeBatch() 时可以防止 JDBC 执行事务处理。禁用自动执行使得应用程序能够在发生错误及批处理中的某些命令不能执行时决定是否执行事务处理。因此,当进行批处理更新时,通常应该关闭自动执行。
在JDBC 2.0 中,Statement 对象能够记住可以一起提交执行的命令列表。创建语句时,与它关联的命令列表为空。Statement.addBatch() 方法为调用语句的命令列表添加一个元素。如果批处理中包含有试图返回结果集的命令,则当调用 Statement. executeBatch() 时,将抛出 SQLException。
只有 DDL 和 DML 命令(它们只返回简单的更新计数)才能作为批处理的一部分来执行。如果应用程序决定不提交已经为某语句构
造的命令批处理,则可以调用方法 Statement.clearBatch()(以上没有显示)来重新设置批处理。
Statement.executeBatch() 方法将把命令批处理提交给基本 DBMS 来执行。命令的执行将依照在批处理中的添加顺序来进行。ExecuteBatch() 为执行的命令返回更新计数数组。数组中对应于批处理中的每个命令都包含了一项,而数组中各元素依据命令的执行顺序(这还是和命令的最初添加顺序相同)来排序。调用executeBatch() 将关闭发出调用的 Statement 对象的当前结果集(如果有一个结果集是打开的)。executeBatch() 返回后,将重新将语句的内部批处理命令列表设置为空。
如果批处理中的某个命令无法正确执行,则 ExecuteBatch() 将抛出BatchUpdateException。可以调用BatchUpdateException.getUpdateCounts() 方法来为批处理中成功执行的命令返回更新计数的整型数组。因为当有第一个命令返回错误时,Statement.executeBatch() 就中止,而且这些命令是依据它们在批处理中的添加顺序而执行的。所以如果 BatchUpdateException.getUpdateCounts() 所返回的数组包含 N 个元素,这就意味着在调用 executeBatch() 时批处理中的前 N 个命令被成功执行。
1 try { 2 int row; 3 Connection connection = null; 4 // 关闭自动提交 5 connection.setAutoCommit(false); 6 String sql = "insert into tb_student(id,name,sex,age) values(?,?,?,?)"; 7 PreparedStatement preparedStatement = (PreparedStatement) connection.prepareStatement(sql); 8 Random random = new Random(); 9 for (int i = 0; i < 10; i++) { 10 preparedStatement.setInt(1, i + 1); 11 preparedStatement.setString(2, "学生" + i); 12 preparedStatement.setBoolean(3, i % 2 == 0 ? true : false); 13 preparedStatement.setInt(4, random.nextInt(5) + 10); 14 preparedStatement.addBatch(); //将for循环的一组参数添加到添加PreparedStatement对象的批处理命令中 15 } 16 int[] rows = preparedStatement.executeBatch(); //PreparedStatement对象的批处理SQL提交给数据库,返回跟新计数的数组 17 row = rows.length; 18 } catch (Exception e) { 19 e.printStackTrace(); 20 }
返回: 10
也可以采用下面方式添加:
stmt.addBatch("insert into employee(id,name,sex,phone) values(1,"qg",1,"**********")");