JDBC - 提交和回滾示例

上一頁
下一頁

以下是示例，它使用了commit 和rollback，這些在事務教程中進行了描述。

此示例程式碼是根據前面章節中完成的環境和資料庫設定編寫的。

使用 Commit 語句將插入的行持久化到表中的示例

在這個例子中，我們有六個靜態字串，包含資料庫連線 URL、使用者名稱、密碼、SELECT 查詢和兩個 INSERT 查詢。插入查詢用於在 Employees 表中插入兩條記錄，而 Select 查詢將用於獲取所有員工。現在，使用 DriverManager.getConnection() 方法，我們準備了一個數據庫連線。使用 setAutoCommit(false)，我們將自動提交設定為 false，預設情況下為 true。連線準備就緒後，我們使用 connection.createStatement() 方法建立了一個 Statement 物件。在建立 Statement 物件時，我們使用 ResultSet 型別為 TYPE_SCROLL_INSENSITIVE 和 CONCUR_READ_ONLY。然後使用 statement.executeUpdate() 執行 INSERT 查詢。現在，使用 commit() 方法，更改將持久化到資料庫。

我們定義了一個 printResultSet() 方法，它以結果集作為引數，迭代它並列印結果集的所有記錄。所有更改提交後，將呼叫 printResultSet() 方法以列印所有記錄，以驗證插入的記錄是否可用。

將以下示例複製並貼上到 JDBCCommitTransactionExample.java 中，編譯並執行如下：

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

public class JDBCCommitTransactionExample {
   static final String DB_URL = "jdbc:mysql:///TUTORIALSPOINT";
   static final String USER = "guest";
   static final String PASS = "guest123";
   static final String QUERY = "SELECT id, first, last, age FROM Employees";
   static final String INSERT_QUERY = "INSERT INTO Employees (first, last, age) values('Rita', 'Tez', 20)";
   static final String INSERT_QUERY_2 = "INSERT INTO Employees (first, last, age) values('Sita', 'Singh', 20)";

   public static void printResultSet(ResultSet rs) throws SQLException{
      // Ensure we start with first row
      rs.beforeFirst();
      while(rs.next()){
         // Display values
         System.out.print("ID: " + rs.getInt("id"));
         System.out.print(", Age: " + rs.getInt("age"));
         System.out.print(", First: " + rs.getString("first"));
         System.out.println(", Last: " + rs.getString("last"));
      }
      System.out.println();
   }

   public static void main(String[] args) {

      Connection conn = null;
      Statement stmt = null;
      try{
         // Open a connection
         System.out.println("Connecting to database...");
         conn = DriverManager.getConnection(DB_URL,USER,PASS);

         // Set auto commit as false.
         conn.setAutoCommit(false);

         // Execute a query to create statment with
         // required arguments for RS example.
         System.out.println("Creating statement...");
         stmt = conn.createStatement(
            ResultSet.TYPE_SCROLL_INSENSITIVE,
            ResultSet.CONCUR_UPDATABLE);

         // INSERT a row into Employees table
         System.out.println("Inserting one row....");
         stmt.executeUpdate(INSERT_QUERY);  

         // INSERT one more row into Employees table
         System.out.println("Inserting another row....");
         stmt.executeUpdate(INSERT_QUERY_2);

         // Commit data here.
         System.out.println("Commiting data here....");
         conn.commit();

         // Now list all the available records.
         ResultSet rs = stmt.executeQuery(QUERY);
         System.out.println("List result set for reference....");
         printResultSet(rs);

         // Clean-up environment
         rs.close();
         stmt.close();
         conn.close();
      }catch(SQLException se){
         se.printStackTrace();
         // If there is an error then rollback the changes.
         System.out.println("Rolling back data here....");
         try{
            if(conn!=null)
               conn.rollback();
            }catch(SQLException se2){
               se2.printStackTrace();
            }
         }catch(Exception e){
            e.printStackTrace();
         }finally{
            // finally block used to close resources
         try{
            if(stmt!=null)
               stmt.close();
         }catch(SQLException se2){
            se2.printStackTrace();
         } 
            try{
               if(conn!=null)
                  conn.close();
            }catch(SQLException se){
               se.printStackTrace();
         }
      }		   
   }
}

輸出

現在讓我們編譯上述示例，如下所示：

C:\>javac JDBCCommitTransactionExample.java
C:\>

當您執行JDBCCommitTransactionExample時，它會產生以下結果：

C:\>java JDBCCommitTransactionExample
Connecting to database...
Creating statement...
Inserting one row....
Inserting another row....
Commiting data here....
List result set for reference....
ID: 1, Age: 23, First: Zara, Last: Ali
ID: 2, Age: 30, First: Mahnaz, Last: Fatma
ID: 3, Age: 35, First: Zaid, Last: Khan
ID: 4, Age: 33, First: Sumit, Last: Mittal
ID: 5, Age: 40, First: John, Last: Paul
ID: 6, Age: 20, First: Rita, Last: Tez
ID: 7, Age: 20, First: Sita, Last: Singh
C:\>

使用 Rollback 語句還原表中插入行的示例

在這個例子中，我們有六個靜態字串，包含資料庫連線 URL、使用者名稱、密碼、SELECT 查詢和兩個 INSERT 查詢。插入查詢用於在 Employees 表中插入兩條記錄，而 Select 查詢將用於獲取所有員工。其中一個插入查詢無效，因為 Employee1 表不存在。現在，使用 DriverManager.getConnection() 方法，我們準備了一個數據庫連線。使用 setAutoCommit(false)，我們將自動提交設定為 false，預設情況下為 true。連線準備就緒後，我們使用 connection.createStatement() 方法建立了一個 Statement 物件。在建立 Statement 物件時，我們使用 ResultSet 型別為 TYPE_SCROLL_INSENSITIVE 和 CONCUR_READ_ONLY。然後使用 statement.executeUpdate() 執行 INSERT 查詢。

由於第二個 INSERT 查詢無效，因此將引發 SQLException。我們處理了異常，並使用 rollback() 方法還原更改。

我們定義了一個 printResultSet() 方法，它以結果集作為引數，迭代它並列印結果集的所有記錄。所有更改提交後，將呼叫 printResultSet() 方法以列印所有記錄，以驗證插入的記錄是否已還原。

將以下示例複製並貼上到 JDBCRollbackTransactionExample.java 中，編譯並執行如下：

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

public class JDBCRollbackTransactionExample {
   static final String MYSQL_URL = "jdbc:mysql:///TUTORIALSPOINT";
   static final String USER_NAME = "guest";
   static final String PASSWORD = "guest123";
   static final String INSERT_QUERY1 = "INSERT INTO Employees (first, last, age) values('Jeevan', 'Rao', 35)";
   static final String INSERT_QUERY2 = "INSERT INTO Employees11 (first, last, age) values('Aditya', 'Chaube', 40)";
   static final String SELECT_QUERY = "SELECT id, age, first, last FROM Employees";

   public static void printResultSet(ResultSet rs) throws SQLException{
      // Ensure we start with first row
      rs.beforeFirst();
      while(rs.next()){
         // Display values
         System.out.print("ID: " + rs.getInt("id"));
         System.out.print(", Age: " + rs.getInt("age"));
         System.out.print(", First: " + rs.getString("first"));
         System.out.println(", Last: " + rs.getString("last"));
      }
      System.out.println();
   }

   public static void main(String[] args) {
      Connection conn = null;
      Statement stmt = null;
      ResultSet rs = null;
      try{
         // Open database connection
         conn = DriverManager.getConnection(MYSQL_URL,USER_NAME,PASSWORD);
         System.out.println(" Connection established with TUTORIALSPOINT database.");

         conn.setAutoCommit(false);
         stmt = conn.createStatement(
            ResultSet.TYPE_SCROLL_INSENSITIVE,
            ResultSet.CONCUR_UPDATABLE);

         System.out.println("Before inserting a row into Employees table");
         stmt.executeUpdate(INSERT_QUERY1);  
         System.out.println("Inserted a row into Employees table");
         stmt.executeUpdate(INSERT_QUERY2);

         System.out.println("Before committing 2 inserts.");
         conn.commit();
         System.out.println(" After committing 2 inserts.");

         rs = stmt.executeQuery(SELECT_QUERY);
         System.out.println("List ALL records of Employees table..");

         printResultSet(rs);

         // Clean-up resources
         rs.close();
         stmt.close();
         conn.close();
      }catch(SQLException se){
         se.printStackTrace();
         System.out.println("If error has occured, discard changes");
         try{
            if(conn!=null)
               conn.rollback();
               //Checking if records are in 'before-insert' state. 
               rs = stmt.executeQuery(SELECT_QUERY);
               System.out.println("List ALL records of Employees table..");
               printResultSet(rs);
               // Clean-up resources
               rs.close();
               stmt.close();
               conn.close();
         }catch(SQLException se){      
            se.printStackTrace();
            System.out.println("If error has occured, discard changes");
            try{
               if(conn!=null)
                  conn.rollback();

               // Checking if records are in 'before-insert' state. 
               rs = stmt.executeQuery(SELECT_QUERY);
               System.out.println("List ALL records of Employees table..");

               printResultSet(rs);
            }
            catch(SQLException se2){
               se2.printStackTrace();
            }catch(Exception e){
               e.printStackTrace();
            }finally{
               try{
                  if(rs != null){
                     rs.close();
                  }
               }catch(SQLException se1){
                  se1.printStackTrace();
               }
               try{
                  if(stmt!=null)
                     stmt.close();
               }catch(SQLException se2){
                  se2.printStackTrace();
               } 
               try{
                  if(conn!=null)
                     conn.close();
               }catch(SQLException se){
                  se.printStackTrace();
               }
            }		   
         }
      }
   }
}

輸出

現在讓我們編譯上述示例，如下所示：

C:\>javac JDBCRollbackTransactionExample.java
C:\>

當您執行JDBCRollbackTransactionExample時，它會產生以下結果：

C:\>java JDBCRollbackTransactionExample
Connection established with TUTORIALSPOINT database.
Before inserting a row into Employees table
Inserted a row into Employees table
java.sql.SQLSyntaxErrorException: Table 'tutorialspoint.employees11' doesn't exist
at com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:112)
...	
If error has occured, discard changes
List ALL records of Employees table..
ID: 1, Age: 18, First: Zara, Last: Ali
ID: 2, Age: 25, First: Mahnaz, Last: Fatma
ID: 3, Age: 30, First: Zaid, Last: Khan
ID: 4, Age: 28, First: Sumit, Last: Mittal
ID: 7, Age: 20, First: Rita, Last: Tez
ID: 8, Age: 20, First: Sita, Last: Singh

C:\>
jdbc-transactions.htm
列印頁面
上一頁
下一頁
廣告

© . All rights reserved.