文档章节

JDBC批量提交SQL的几点问题解答

囚兔
 囚兔
发布于 2016/06/30 13:39
字数 968
阅读 158
收藏 2

1. 疑问

  • 问题一:Statement的executeBatch方法是否会执行commit操作,是否还需要再执行一次commit()?
  • 问题二:执行批量操作的过程中,如果其中有部分命令执行失败,其他执行成功的命令是否会提交到数据库?

2. 环境

    测试采用MySQL数据库,创建如下表;

CREATE TABLE `batch_test` (
`id`  int(11) NOT NULL ,
PRIMARY KEY (`id`)
)

3. 测试

3.1. 问题一测试

    测试代码:

Connection conn = null;
Statement stmt = null;

try {
    conn = DBUtils.getConnection();
    conn.setAutoCommit(false);

    stmt = conn.createStatement();
    stmt.addBatch("INSERT INTO batch_test(id) VALUES (1)");
    stmt.addBatch("INSERT INTO batch_test(id) VALUES (2)");
    stmt.addBatch("INSERT INTO batch_test(id) VALUES (3)");

    stmt.executeBatch();
} catch (SQLException e) {
    e.printStackTrace();
} finally {
    DBUtils.close(conn, stmt);
}

    结果:

mysql> select * from batch_test;
Empty set

    修改代码,增加commit()

Connection conn = null;
Statement stmt = null;

try {
    conn = DBUtils.getConnection();
    conn.setAutoCommit(false);

    stmt = conn.createStatement();
    stmt.addBatch("INSERT INTO batch_test(id) VALUES (1)");
    stmt.addBatch("INSERT INTO batch_test(id) VALUES (2)");
    stmt.addBatch("INSERT INTO batch_test(id) VALUES (3)");

    stmt.executeBatch();

    // ************
    conn.commit();

} catch (SQLException e) {
    e.printStackTrace();
} finally {
    DBUtils.close(conn, stmt);
}

    结果:

mysql> select * from batch_test;
+----+
| id |
+----+
|  1 |
|  2 |
|  3 |
+----+
3 rows in set

对比上面两个测试,说明在执行executeBatch()后必须再执行commit(), executeBatch不会执行commit操作;

3.2. 问题二测试

    接着3.1的测试数据,目前表batch_test中已经有三条记录,id字段是主键,并且已经存在三个值(1,2,3),我再依次添加4条insert命令,id值顺序为(4,5,1,6),当执行executeBatch时第三条记录(id=1)应该会失败,且抛出异常。

    代码如下:

try {
    conn = DBUtils.getConnection();
    conn.setAutoCommit(false);

    stmt = conn.createStatement();
    stmt.addBatch("INSERT INTO batch_test(id) VALUES (4)");
    stmt.addBatch("INSERT INTO batch_test(id) VALUES (5)");
    stmt.addBatch("INSERT INTO batch_test(id) VALUES (1)");
    stmt.addBatch("INSERT INTO batch_test(id) VALUES (6)");

    stmt.executeBatch();
    System.out.println("executeBatch");

    conn.commit();
    System.out.println("commit");

} catch (BatchUpdateException e) {
    e.printStackTrace();
    System.out.println("UpdateCounts -> " + Arrays.toString(e.getUpdateCounts()));
} catch (SQLException e) {
    e.printStackTrace();
} finally {
    DBUtils.close(conn, stmt);
}

    执行executeBatch()时抛异常BatchUpdateException,输出:

java.sql.BatchUpdateException: Duplicate entry '1' for key 'PRIMARY'
    at com.mysql.jdbc.StatementImpl.executeBatch(StatementImpl.java:1110)
    at com.tiza.test.db.BatchExecTest.main(BatchExecTest.java:26)
    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
    at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
    at java.lang.reflect.Method.invoke(Method.java:606)
    at com.intellij.rt.execution.application.AppMain.main(AppMain.java:144)
UpdateCounts -> [1, 1, -3, 1]

结果:

mysql> select * from batch_test;
+----+
| id |
+----+
|  1 |
|  2 |
|  3 |
+----+
3 rows in set

    根据结果可知,批量操作当出现一条SQL命令失败,会抛异常,并且UpdateCounts显示,除了id=1的记录执行失败,其他三条都成功了。 但是这里抛异常后就没有执行commit,那如果执行commit是不是三条成功的(id=4,id=5,id=6)就会提交到数据库?

    进一步测试,在抛BatchUpdateException后依然做commit,代码如下:

Connection conn = null;
Statement stmt = null;

try {
    conn = DBUtils.getConnection();
    conn.setAutoCommit(false);

    stmt = conn.createStatement();
    stmt.addBatch("INSERT INTO batch_test(id) VALUES (4)");
    stmt.addBatch("INSERT INTO batch_test(id) VALUES (5)");
    stmt.addBatch("INSERT INTO batch_test(id) VALUES (1)");
    stmt.addBatch("INSERT INTO batch_test(id) VALUES (6)");

    stmt.executeBatch();
    System.out.println("executeBatch");

    conn.commit();
    System.out.println("commit");

} catch (BatchUpdateException e) {
    e.printStackTrace();
    System.out.println("UpdateCounts -> " + Arrays.toString(e.getUpdateCounts()));

    // **********************
    try {
        conn.commit();
    } catch (SQLException e1) {
        e1.printStackTrace();
    }
    // **********************

} catch (SQLException e) {
    e.printStackTrace();
} finally {
    DBUtils.close(conn, stmt);
}

    输出:

java.sql.BatchUpdateException: Duplicate entry '1' for key 'PRIMARY'
    at com.mysql.jdbc.StatementImpl.executeBatch(StatementImpl.java:1110)
    at com.tiza.test.db.BatchExecTest.main(BatchExecTest.java:26)
    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
    at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
    at java.lang.reflect.Method.invoke(Method.java:606)
    at com.intellij.rt.execution.application.AppMain.main(AppMain.java:144)
UpdateCounts -> [1, 1, -3, 1]

    结果:

mysql> select * from batch_test;
+----+
| id |
+----+
|  1 |
|  2 |
|  3 |
|  4 |
|  5 |
|  6 |
+----+
6 rows in set

至此问题二答案已经出来了,批量提交过程中虽然在执行executeBatch时当部分命令出现异常,但是只要继续执行commit,其中成功执行的命令还是会commit到数据库的。

4. 总结

问题一:Statement的executeBatch方法是否会执行commit操作,是否还需要再执行一次commit()?

答: executeBatch不会执行commit,在执行完executeBatch后必须再执行commit;

 

问题二:执行批量操作的过程中,如果其中有部分命令执行失败,其他执行成功的命令是否会提交到数据库?

答: 批量操作执行executeBatch时部分命令执行失败会抛BatchUpdateException异常,但是只要继续执行commit,其他成功执行的命令依然会提交到数据库,否则不关执行成功与否都不会提交到数据库。

© 著作权归作者所有

共有 人打赏支持
囚兔

囚兔

粉丝 39
博文 86
码字总数 47164
作品 1
南京
程序员
mysql大量数据插入探讨(量变引起质变)

分类:见Visio图 关于大量数据导入是应注意以下几点: 分批导入,导入一批后最后提交(commit),可以使用jdbc的(executeBatch)批量处理但是注意它的最大上限,否则只会执行一部分sql语句,超...

soul_mate
2014/04/27
0
0
MySQL JDBC 的 BATCH 执行和 rewriteBatchedStatements 参数

本来以为这是一个已解决的问题,但是发现有同学不知道,所以写一下。 经常使用 MySQL 的同学可能知道,默认情况下 MySQL JDBC 驱动是不支持 BATCH 的: 在真正执行的时候,MySQL JDBC 驱动仍...

长源
08/01
0
0
mybaties的批量增删改查及普通增删改查

数据库: create table school( id int(11) not null auto_increment comment '主键', name varchar(20) comment '学校名称', address varchar(100) comment '学校地址', create_time datati......

成长中的菜鸟
2015/01/29
0
0
大型互联网架构必备技术——性能调优专题

性能调优 深入内核,直击故障 ,拒绝蒙圈 性能优化如何理解 1、性能基准 2、什么是性能优化 3、衡量标准 JVM调优 1、Jvm虚拟机内存剖析 2、垃圾收集器 3、实战调优案例与解决方案 4、Jvm运行...

Java高级架构
04/15
0
0
第 13 章 批量处理(Batch processing)

第 13 章 批量处理(Batch processing) 使用Hibernate将 100 000 条记录插入到数据库的一个很自然的做法可能是这样的 Session session = sessionFactory.openSession();Transaction tx = se...

扁-哥
2013/03/28
0
0

没有更多内容

加载失败,请刷新页面

加载更多

TypeScript基础入门之声明合并(二)

转发 TypeScript基础入门之声明合并(二) 声明合并 合并命名空间 与接口类似,同名的命名空间也将合并其成员。 由于名称空间同时创建了名称空间和值,因此我们需要了解它们是如何合并的。 要合...

durban
14分钟前
0
0
centos7系统安装sersync+rsync实现服务器同步功能

centos7系统安装sersync+rsync实现服务器同步功能 MQ_douer0人评论21708人阅读2017-04-08 15:49:03 一、为什么要用sersync+rsync架构? 1、sersync是基于inotify开发的,类似于inotify-tools...

linjin200
15分钟前
1
0
Windows下安装phpRedis扩展

Windows下安装phpRedis扩展 通常在做PHP程序测试时,会用到Redis。而一般测试都是在Windows下进行的,所以需要在Windows环境下安装phpRedis扩展,用以支持php对Redis的访问。 工具/原料 php调...

梦梦阁
20分钟前
1
0
HTTPConnectionPool(host:XX)Max retries exceeded with url 解决方法

HTTPConnectionPool(host:XX)Max retries exceeded with url 解决方法 在做双十一压测时,高并发调用requests时报错.问题解决方法 问题原因 是因为在每次数据传输前客户端要和服务器建立TCP...

_Change_
24分钟前
0
0
iosdfgh

复制 IO流 (***** 了解 *****) 1.1 概述 之前我们学习了 File 类,这个类中有很多操作文件本身的方法, File类它只能操作文件或文件夹,并不能去访问文件中的数据。真正保存数据的是文件,数据...

码农屌丝
26分钟前
1
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部