JDBC - 事务

如果您的 JDBC 连接处于自动提交模式（默认情况下），则每个 SQL 语句在完成时都会提交到数据库。

对于简单的应用程序，这可能很好，但是您可能希望关闭自动提交并管理自己的事务，原因有三个：

提高性能。
维护业务流程的完整性。
使用分布式事务。

事务使您能够控制是否以及何时将更改应用于数据库。它将单个 SQL 语句或一组 SQL 语句视为一个逻辑单元，如果任何语句失败，则整个事务失败。

要启用手动事务支持而不是 JDBC 驱动程序默认使用的自动提交模式，请使用 Connection 对象的setAutoCommit()方法。如果将布尔值 false 传递给 setAutoCommit()，则关闭自动提交。您可以传递布尔值 true 以将其重新打开。

例如，如果您有一个名为 conn 的 Connection 对象，请编写以下代码以关闭自动提交：

conn.setAutoCommit(false);

提交和回滚

完成后要提交更改，请在连接对象上调用commit()方法，如下所示：

conn.commit( );

否则，要回滚使用名为 conn 的 Connection 进行的数据库更新，请使用以下代码：

conn.rollback( );

以下示例说明了提交和回滚对象的使用：

try{
   //Assume a valid connection object conn
   conn.setAutoCommit(false);
   Statement stmt = conn.createStatement();
   
   String SQL = "INSERT INTO Employees  " +
                "VALUES (106, 20, 'Rita', 'Tez')";
   stmt.executeUpdate(SQL);  
   //Submit a malformed SQL statement that breaks
   String SQL = "INSERTED IN Employees  " +
                "VALUES (107, 22, 'Sita', 'Singh')";
   stmt.executeUpdate(SQL);
   // If there is no error.
   conn.commit();
}catch(SQLException se){
   // If there is any error.
   conn.rollback();
}

在这种情况下，以上任何 INSERT 语句都不会成功，并且所有内容都将回滚。

为了更好地理解，让我们学习提交和回滚 - 示例代码。

使用保存点

新的 JDBC 3.0 保存点接口为您提供了额外的交易控制。大多数现代 DBMS 都支持其环境中的保存点，例如 Oracle 的 PL/SQL。

设置保存点时，您定义了事务中的一个逻辑回滚点。如果保存点之后发生错误，您可以使用回滚方法撤消所有更改或仅撤消保存点之后进行的更改。

Connection 对象有两个新方法可帮助您管理保存点：

setSavepoint(String savepointName) - 定义一个新的保存点。它还会返回一个 Savepoint 对象。
releaseSavepoint(Savepoint savepointName) - 删除保存点。请注意，它需要一个 Savepoint 对象作为参数。此对象通常是 setSavepoint() 方法生成的保存点。

有一个rollback (String savepointName)方法，它将工作回滚到指定的保存点。

以下示例说明了 Savepoint 对象的使用：

try{
   //Assume a valid connection object conn
   conn.setAutoCommit(false);
   Statement stmt = conn.createStatement();
   
   //set a Savepoint
   Savepoint savepoint1 = conn.setSavepoint("Savepoint1");
   String SQL = "INSERT INTO Employees " +
                "VALUES (106, 20, 'Rita', 'Tez')";
   stmt.executeUpdate(SQL);  
   //Submit a malformed SQL statement that breaks
   String SQL = "INSERTED IN Employees " +
                "VALUES (107, 22, 'Sita', 'Tez')";
   stmt.executeUpdate(SQL);
   // If there is no error, commit the changes.
   conn.commit();

}catch(SQLException se){
   // If there is any error.
   conn.rollback(savepoint1);
}

在这种情况下，以上任何 INSERT 语句都不会成功，并且所有内容都将回滚。

为了更好地理解，让我们学习保存点 - 示例代码。

打印页面