Java事務管理學習之詳解JDBC的範例程式碼

這篇文章主要介紹了Java事務管理學習之JDBC的相關資料，文中介紹的非常詳細，相信對大家具有一定的參考價值，需要的朋友們下面來一起看看吧。

什麼是Java事務

#通常的觀念認為，交易只與資料庫相關。

事務必須服從ISO/IEC所製定的ACID原則。 ACID是原子性（atomicity）、一致性（consistency）、隔離性（isolation）和持久性（durability）的縮寫。事務的原子性表示事務執行過程中的任何失敗都會導致事務所所做的任何修改失效。一致性表示當交易執行失敗時，所有被該交易影響的資料都應該恢復到事務執行前的狀態。隔離性表示在事務執行過程中對資料的修改，在事務提交之前對其他事務不可見。持久性表示已提交的資料在交易執行失敗時，資料的狀態都應該正確。

通俗的理解，事務是一組原子操作單元，從資料庫角度說，就是一組SQL指令，要麼全部執行成功，若因為某個原因其中一條指令執行有錯誤，則撤銷先前執行過的所有指令。更簡答的說就是：要麼全部執行成功，要麼撤銷不執行。

既然事務的概念從資料庫而來，那麼Java事務是什麼？之間有什麼關聯？

實際上，一個Java應用系統，如果要操作資料庫，則透過JDBC來實現的。增加、修改、刪除都是透過對應方法間接來實現的，事務的控制也隨之轉移到Java程式碼中。因此，資料庫操作的事務習慣上就稱為Java事務。

事務的特性：

1) 原子性（atomicity）：交易是資料庫的邏輯工作單位，而且必須是原子工作單位，對於其資料修改，要麼全部執行，要麼全部不執行。

2) 一致性（consistency）：交易在完成時，必須是所有的資料都保持一致狀態。在相關資料庫中，所有規則都必須套用於交易的修改，以保持所有資料的完整性。

3) 隔離性（isolation）：一個交易的執行不能被其他事務所影響。

4) 持久性（durability）：一個交易一旦提交，事物的操作便永久性的保存在DB中。即使此時再執行回滾操作也無法撤銷所做的變更。

交易(Transaction):是並發控制的單元，是使用者定義的一個操作序列。這些操作要嘛都做，要嘛都不做，是一個不可分割的工作單位。透過事務，sql server 能將邏輯相關的一組操作綁定在一起，以便伺服器 保持資料的完整性。事務通常以begin transaction開始，以commit或rollback結束。 Commint表示提交，即提交交易的所有操作。具體地說就是將事務中所有對資料的更新寫回磁碟上的實體資料庫中去，事務正常結束。 Rollback表示回滾，即在交易運作的過程中發生了某種故障，事務不能繼續進行，系統將事務中對資料庫的所有已完成的操作全部撤消，滾回到事務開始的狀態。

自動提交交易：每個單獨的語句都是一個交易。每個語句後面都隱含一個commit。 （預設）

明確交易：以begin transaction顯示開始，以commit或rollback結束。

隱含交易：當連線以隱式交易模式進行操作時，sql server資料庫引擎執行個體會在提交或回溯目前交易後自動啟動新交易。無須描述事物的開始，只需提交或回滾每個事務。但每個事務仍以commit或rollback明確結束。連線將隱性交易模式設定為開啟之後，當資料庫引擎實例首次執行下列任何語句時，都會自動啟動一個隱式交易：alter table，insert，create，open ，delete，revoke ，drop ，select， fetch ，truncate table，grant，update在發出commit或rollback語句之前，該事務將保持有效。在第一個交易被提交或回滾之後，下次當連線執行以上任何語句時，資料庫引擎執行個體都會自動啟動一個新交易。此實例將不斷地產生隱性事務鏈，直到隱性事務模式關閉為止。

JDBC交易管理

在使用JDBC的時候， 如何進行交易的管理。直接看一下程式碼

範例程式碼

/** 
 * @Title: JDBCTrans.java 
 * @Package com.oscar999.trans 
 * @Description: 
 * @author XM 
 * @date Feb 14, 2017 4:38:27 PM 
 * @version V1.0 
 */ 
package com.oscar999.trans; 
 
import java.sql.Connection; 
import java.sql.DriverManager; 
import java.sql.SQLException; 
import java.sql.Statement; 
 
/** 
 * @author 
 * 
 */ 
public class JDBCTrans { 
 
 public JDBCTrans() { 
 
 } 
 
 /** 
 * 
 * @param sHostName 
 * @param sPortNumber 
 * @param sSid 
 * @param userName 
 * @param password 
 * @return 
 * @throws SQLException 
 */ 
 public Connection getConnection(String sHostName, String sPortNumber, String sSid, String userName, String password) throws SQLException { 
 Connection conn = null; 
 String url = getOraclURL(sHostName, sPortNumber, sSid); 
 conn = DriverManager.getConnection(url,userName,password); 
 return conn; 
 } 
 
 /** 
 * 
 * @param conn 
 * @param sql 
 * @throws SQLException 
 */ 
 public void add(Connection conn, String sql) throws SQLException { 
 Statement stmt = null; 
 try { 
  stmt = conn.createStatement(); 
  stmt.execute(sql); 
 } catch (SQLException e) { 
  // TODO Auto-generated catch block 
  e.printStackTrace(); 
 } finally { 
  if (stmt != null) 
  stmt.close(); 
 } 
 } 
 
 /** 
 * @param args 
 */ 
 public static void main(String[] args) { 
 // TODO Auto-generated method stub 
 String sHostName = ""; 
 String sPortNumber = ""; 
 String sSid = ""; 
 String userName = ""; 
 String password = ""; 
 
 sHostName = ""; 
 sPortNumber = ""; 
 sSid = ""; 
 userName = ""; 
 password = ""; 
 
 try { 
  Class.forName("oracle.jdbc.driver.OracleDriver"); 
 } catch (ClassNotFoundException e1) { 
  // TODO Auto-generated catch block 
  e1.printStackTrace(); 
 } 
  
 JDBCTrans jdbcTrans = new JDBCTrans(); 
 Connection conn = null; 
 try {  
  conn = jdbcTrans.getConnection(sHostName, sPortNumber, sSid, userName, password); 
  conn.setAutoCommit(false);// can't insert, update 
  
  //1. add SQL 
  String addSQL = "insert into TEST_TABLE values('name1','value1')"; 
  jdbcTrans.add(conn,addSQL); 
  
 } catch (SQLException e) { 
  // TODO Auto-generated catch block 
  e.printStackTrace(); 
 } finally { 
  /*if (conn != null) 
  { 
  try { 
   conn.close(); 
  } catch (SQLException e) { 
   // TODO Auto-generated catch block 
   e.printStackTrace(); 
  } 
  }*/ 
 } 
 
 } 
 
 private String getOraclURL(String sHostName, String sPortNumber, String sSid) { 
 String url = "jdbc:oracle:thin:@" + sHostName + ":" + sPortNumber + ":" + sSid; 
 return url; 
 } 
 
}

針對以上程式碼，說明如下：

##以上程式碼有幾點說明的部分:

1.

conn.setAutoCommit(false) 執行後不提交交易。

對於Select沒有影響， 但對於Insert和Update的話， 沒有提交資料就不會被修改

#

2.  conn.close(); 关闭Connection的代码有被Mark掉， 是想呈现conn.setAutoCommit(false)的效果。

原因是在 Connection Close的时候会执行一次Commit.

而如果Connection是在应用服务器中使用连接池的话， Connection就不会被Close, 也就不会执行Commit.

3. setAutoCommit(false) 用法大多数是在要执行多条语句才提交。

所以针对以上第三点， 更接近实际的状况的代码如示例代码2

示例代码2

/** 
 * @Title: JDBCTrans.java 
 * @Package com.oscar999.trans 
 * @Description: 
 * @author XM 
 * @date Feb 14, 2017 4:38:27 PM 
 * @version V1.0 
 */ 
package com.oscar999.trans; 
 
import java.sql.Connection; 
import java.sql.DriverManager; 
import java.sql.SQLException; 
import java.sql.Statement; 
 
/** 
 * @author 
 * 
 */ 
public class JDBCTrans { 
 
 public JDBCTrans() { 
 
 } 
 
 /** 
 * 
 * @param sHostName 
 * @param sPortNumber 
 * @param sSid 
 * @param userName 
 * @param password 
 * @return 
 * @throws SQLException 
 */ 
 public Connection getConnection(String sHostName, String sPortNumber, String sSid, String userName, String password) throws SQLException { 
 Connection conn = null; 
 String url = getOraclURL(sHostName, sPortNumber, sSid); 
 conn = DriverManager.getConnection(url, userName, password); 
 return conn; 
 } 
 
 /** 
 * 
 * @param conn 
 * @param sql 
 * @throws SQLException 
 */ 
 public void add(Connection conn, String sql) throws SQLException { 
 Statement stmt = null; 
 try { 
  stmt = conn.createStatement(); 
  stmt.execute(sql); 
 } catch (SQLException e) { 
  // TODO Auto-generated catch block 
  e.printStackTrace(); 
 } finally { 
  if (stmt != null) 
  stmt.close(); 
 } 
 } 
 
 /** 
 * @param args 
 */ 
 public static void main(String[] args) { 
 // TODO Auto-generated method stub 
 String sHostName = ""; 
 String sPortNumber = ""; 
 String sSid = ""; 
 String userName = ""; 
 String password = ""; 
 
 sHostName = ""; 
 sPortNumber = ""; 
 sSid = ""; 
 userName = ""; 
 password = ""; 
 
 try { 
  Class.forName("oracle.jdbc.driver.OracleDriver"); 
 } catch (ClassNotFoundException e1) { 
  // TODO Auto-generated catch block 
  e1.printStackTrace(); 
 } 
 
 JDBCTrans jdbcTrans = new JDBCTrans(); 
 Connection conn = null; 
 try { 
  conn = jdbcTrans.getConnection(sHostName, sPortNumber, sSid, userName, password); 
  conn.setAutoCommit(false);// can't insert, update 
 
  // 1. add SQL 1 
  String addSQL = "insert into TEST_TABLE values('name1','value1')"; 
  jdbcTrans.add(conn, addSQL); 
 
  //2. add SQL 2 
  addSQL = "insert into TEST_TABLE values('name2','value2')"; 
  jdbcTrans.add(conn, addSQL); 
  
  conn.commit(); 
 } catch (SQLException e) { 
  // TODO Auto-generated catch block 
  if(conn!=null){ 
   try { 
   conn.rollback(); 
   } catch (SQLException e1) { 
   e1.printStackTrace(); 
   } 
  }  
  e.printStackTrace(); 
 } finally { 
  if (conn != null) { 
  try { 
   conn.close(); 
  } catch (SQLException e) { 
   // TODO Auto-generated catch block 
   e.printStackTrace(); 
  } 
  } 
 } 
 
 } 
 
 private String getOraclURL(String sHostName, String sPortNumber, String sSid) { 
 String url = "jdbc:oracle:thin:@" + sHostName + ":" + sPortNumber + ":" + sSid; 
 return url; 
 } 
 
}

这里需要说明的是： conn.rollback(); 

只要执行有异常，就要rollback , 这一步必不可少

如果没有在执行出现异常的时候进行回滚。如果在执行第一条语句之后出现异常，con既没有提交也没有回滚，表就会被锁住(如果oracle数据库就是行锁)，而这个锁却没有机会释放。

可能在执行con.close()的时候会释放锁，但还是如果应用服务器使用了数据库连接池，连接不会被断开。

总结

以上是Java事務管理學習之詳解JDBC的範例程式碼的詳細內容。更多資訊請關注PHP中文網其他相關文章！