Java数据库编程——事务

　　现在可以使用通常的方法创建一个语句对象：

Statement stat = conn.createStatement();

然后任意多次调用executeUpdate方法：

stat.executeUpdate(command1);
stat.executeUpdate(command2);
stat.executeUpdate(command3);
...

如果执行了所有命令之后没有出错，则调用commit方法：

conn.commit();

如果出现错误，则调用：

conn.rollback();

此时，程序将自动撤销自上次提交以来的所有语句。当事务被SQLException异常中断时，典型的方法就是发起回滚操作。

1. 保存点

　　在使用某些驱动程序时，使用保存点（save point）可以更细粒度地控制回滚操作。创建一个保存点意味着稍候只需返回到这个点，而非事务的开头。例如，

Statement stat = conn.createStatement();  //开启一个事务；rollback()返回这里
stat.executeUpdate(command1);
Savepoint svpt = conn.setSavepoint();  //设置保存点；rollback(svpt)返回到这里
stat.executeUpdate(command2);
if(...) conn.rollback(svpt);   //撤销command2产生的影响
...
conn.commit();

　　当不再需要保存点时，必须释放它：

conn.releaseSavepoint(svpt);

2. 批量更新

　　假设有一个程序需要执行许多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..."
stat.addBatch(command);

while(...){
    command = "INSERT INTO ... VALUES("+...+")";
    stat.addBatch(command);
}

　　最后，提交整个批量更新语句：

int[] counts = stat.executeBatch();

　　调用executeBatch方法将为所有已提交的语句返回一个记录数的数组。

　　为了在批量模式下正确地处理错误，必须将批量执行的操作视为单个事务。如果批量更新在执行过程中失败，那么必须将它回滚到批量操作开始之前的状态。

　　首先，关闭自动提交模式，然后收集批量操作，执行并提交该操作，最后恢复最初的自动提交模式：

boolean autoCommit = conn.getAutoCommit();
conn.setAutoCommit(false);
Statement stat = conn.getStatement();
...
//keep calling stat.addBatch(...);
...
stat.executeBatch();
conn.commit();
conn.setAutoCommit(autoCommit);

Java数据库编程——事务

标签：