时间:2021-07-01 10:21:17 帮助过:2人阅读
现在可以使用通常的方法创建一个语句对象:
- Statement stat = conn.createStatement();
然后任意多次调用executeUpdate方法:
- <span style="color: #000000;">stat.executeUpdate(command1);
- stat.executeUpdate(command2);
- stat.executeUpdate(command3);
- ...</span>
如果执行了所有命令之后没有出错,则调用commit方法:
- conn.commit();
如果出现错误,则调用:
- conn.rollback();
此时,程序将自动撤销自上次提交以来的所有语句。当事务被SQLException异常中断时,典型的方法就是发起回滚操作。
在使用某些驱动程序时,使用保存点(save point)可以更细粒度地控制回滚操作。创建一个保存点意味着稍候只需返回到这个点,而非事务的开头。例如,
- Statement stat = conn.createStatement(); <span style="color: #008000;">//</span><span style="color: #008000;">开启一个事务;rollback()返回这里</span>
- <span style="color: #000000;">stat.executeUpdate(command1);
- Savepoint svpt </span>= conn.setSavepoint(); <span style="color: #008000;">//</span><span style="color: #008000;">设置保存点;rollback(svpt)返回到这里</span>
- <span style="color: #000000;">stat.executeUpdate(command2);
- </span><span style="color: #0000ff;">if</span>(...) conn.rollback(svpt); <span style="color: #008000;">//</span><span style="color: #008000;">撤销command2产生的影响</span>
- <span style="color: #000000;">...
- conn.commit();</span>
当不再需要保存点时,必须释放它:
- conn.releaseSavepoint(svpt);
假设有一个程序需要执行许多INSERT语句,以便将数据填入数据库表中,此时可以使用批量更新的方法来提高程序性能。在使用批量更新(batch update)时,一个语句序列作为一批操作将同时被收集和提交。
注意:使用DatabaseMetaData接口中的supportsBatchUpdates方法可以获知数据库是否支持这种特性。
处于同一批中的语句可以是INSERT、UPDATE和DELETE等操作,也可以是数据库定义语句,如CREATE TABLE和DROP TABLE。但是,在批量处理中添加SELECT语句会抛出异常(从概念上讲,批量处理中的SELECT语句没有意义,因为它会返回结果集,而不更新数据库)。
为了执行批量处理,首先必须使用通常的办法创建一个Statement对象:
- Statement stat = conn.createStatement();
现在应该调用addBatch方法,而非executeUpdate方法:
- String command = "CREATE TABLE..."<span style="color: #000000;">
- stat.addBatch(command);
- </span><span style="color: #0000ff;">while</span><span style="color: #000000;">(...){
- command </span>= "INSERT INTO ... VALUES("+...+")"<span style="color: #000000;">;
- stat.addBatch(command);
- }</span>
最后,提交整个批量更新语句:
- <span style="color: #0000ff;">int</span>[] counts = stat.executeBatch();
调用executeBatch方法将为所有已提交的语句返回一个记录数的数组。
为了在批量模式下正确地处理错误,必须将批量执行的操作视为单个事务。如果批量更新在执行过程中失败,那么必须将它回滚到批量操作开始之前的状态。
首先,关闭自动提交模式,然后收集批量操作,执行并提交该操作,最后恢复最初的自动提交模式:
- <span style="color: #0000ff;">boolean</span> autoCommit =<span style="color: #000000;"> conn.getAutoCommit();
- conn.setAutoCommit(</span><span style="color: #0000ff;">false</span><span style="color: #000000;">);
- Statement stat </span>=<span style="color: #000000;"> conn.getStatement();
- ...
- </span><span style="color: #008000;">//</span><span style="color: #008000;">keep calling stat.addBatch(...);</span>
- <span style="color: #000000;">...
- stat.executeBatch();
- conn.commit();
- conn.setAutoCommit(autoCommit);</span>
Java数据库编程——事务
标签: