文档章节

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

囚兔
 囚兔
发布于 2016/06/30 13:39
字数 968
阅读 172
收藏 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,其他成功执行的命令依然会提交到数据库,否则不关执行成功与否都不会提交到数据库。

© 著作权归作者所有

共有 人打赏支持
囚兔

囚兔

粉丝 38
博文 86
码字总数 47164
作品 1
南京
程序员
私信 提问
MySQL JDBC 的 BATCH 执行和 rewriteBatchedStatements 参数

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

长源
08/01
0
0
mysql大量数据插入探讨(量变引起质变)

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

soul_mate
2014/04/27
0
0
十个JDBC的最佳实践

JDBC是Java为多种关系型数据库提供的统一的访问接口,以下是我长期使用JDBC总结的十个最佳实践。 JDBC最佳实践1:使用PrearedStatement 任何一个使用过JDBC的Java程序员几乎都知道这个,Pre...

王振威
2012/09/08
6.3K
12
十个JDBC的最佳实践

JDBC是Java为多种关系型数据库提供的统一的访问接口,以下是我长期使用JDBC总结的十个最佳实践。 JDBC最佳实践1:使用PrearedStatement 任何一个使用过JDBC的Java程序员几乎都知道这个,Pre...

王振威
2012/11/26
1K
4
JAVA回滚机制,求大神指点迷津,小弟在此谢过!

上代码 try { // 更改JDBC事务的默认提交方式,默认是true,是自动提交; connection.setAutoCommit(false); m_hashMap = JsonConvert.JsonToObject(jsonContent, HashMap.class); akMxFieldI......

kycp1
2016/04/20
563
6

没有更多内容

加载失败,请刷新页面

加载更多

线下工坊|Blockchain Coding Day:零基础教你开发DAPP(北京)

我们的目标是通过编程学习让你更了解区块链技术。这将对区块链开发初学者一次很好的体验。这里需要强调一下,编程零基础也能学会。 我们将以小组的形式,由教练带领学员完成DAPP开发。每位学...

HiBlock
10分钟前
0
0
查看内存情况

jinfo:可以输出并修改运行时的java 进程的opts。 jps:与unix上的ps类似,用来显示本地的java进程,可以查看本地运行着几个java程序,并显示他们的进程号。 jstat:一个极强的监视VM内存工具。...

Canaan_
11分钟前
0
0
基于对象特征的推荐

(本实验选用数据为真实电商脱敏数据,仅用于学习,请勿商用) 在上一期基于协同过滤的的推荐场景中,我们介绍了如何通过PAI快速搭建一个基于协同过滤方案的推荐系统,这一节会介绍一些如何基...

阿里云官方博客
19分钟前
1
0
Ugly Number(leetcode263)

Write a program to check whether a given number is an ugly number. Ugly numbers are positive numbers whose prime factors only include 2, 3, 5. Example 1: Input: 6Output: true......

woshixin
42分钟前
2
0
深度模型从研者 眼里的 似然估计 & Hessain 海森矩阵 & Fisher Information (费雪信息)

深度模型的训练的基本依据是最小化模型拟合数据的误差。旨在不仅知其然(如何构建和训练一个深度模型),还应知其所以然(为什么这样训练,可以做哪些优化)。我们就会发现,有很多研究者,在...

刘小米_思聪
46分钟前
0
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部