上一节:
下一节:

  JDBC - 事务

  • 简述

    如果您的 JDBC 连接处于自动提交模式（默认情况下），则每个 SQL 语句在完成后都会提交到数据库。
    对于简单的应用程序来说这可能没问题，但是您可能想要关闭自动提交并管理您自己的交易的三个原因 -
    • 以提高性能。
    • 维护业务流程的完整性。
    • 使用分布式事务。
    事务使您能够控制是否以及何时将更改应用于数据库。它将单个 SQL 语句或一组 SQL 语句视为一个逻辑单元，如果任何语句失败，则整个事务失败。
    要启用手动事务支持而不是JDBC 驱动程序默认使用的自动提交模式，请使用 Connection 对象的setAutoCommit()方法。如果将布尔值 false 传递给 setAutoCommit()，则关闭自动提交。您可以传递一个布尔值 true 以再次打开它。
    例如，如果您有一个名为 conn 的 Connection 对象，请编写以下代码以关闭自动提交 - 
    

conn.setAutoCommit(false);

  • 提交和回滚

    完成更改并希望提交更改后，请调用 commit() 连接对象的方法如下 - 
    

conn.commit( );
    否则，要回滚使用名为 conn 的连接对数据库进行的更新，请使用以下代码 - 
    

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 Savepoint 接口为您提供了额外的事务控制。大多数现代 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 语句都不会成功，所有内容都将回滚。
上一节:
下一节: