JDBC處理事務 & 事務的隔離級別
一、數據庫事務
在數據庫中,所謂事務是指一組邏輯操作單元,使數據從一種狀態變換到另一種狀態。
為確保數據庫中數據的一致性,數據的操縱應當是離散的成組的邏輯單元:當它全部完成時,數據的一致性可以保持,而當這個單元中的一部分操作失敗,整個事務應全部視為錯誤,所有從起始點以后的操作應全部回退到開始狀態。
事務的操作:先定義開始一個事務,然后對數據作修改操作,這時如果提交(COMMIT),這些修改就永久地保存下來,如果回退(ROLLBACK),數據庫管理系統將放棄所作的所有修改而回到開始事務時的狀態。
二、事務的ACID(acid)屬性</strong>
- 原子性（Atomicity） 原子性是指事務是一個不可分割的工作單位，事務中的操作要么都發生，要么都不發生。
- 一致性（Consistency） 事務必須使數據庫從一個一致性狀態變換到另外一個一致性狀態。
- 隔離性（Isolation） 事務的隔離性是指一個事務的執行不能被其他事務干擾，即一個事務內部的操作及使用的數據對并發的其他事務是隔離的，并發執行的各個事務之間不能互相干擾。（前幾天就犯了這個錯誤）
持久性（Durability） 持久性是指一個事務一旦被提交，它對數據庫中數據的改變就是永久性的，接下來的其他操作和數據庫故障不應該對其有任何影響
</span> </p>三、JDBC 事物處理
事務：指構成單個邏輯工作單元的操作集合
事務處理：保證所有事務都作為一個工作單元來執行，即使出現了故障，都不能改變這種執行方式。當在一個事務中執行多個操作時，要么所有的事務都被提交(commit)，要么整個事務回滾(rollback)到最初狀態
當一個連接對象被創建時，默認情況下是自動提交事務：每次執行一個 SQL 語句時，如果執行成功，就會向數據庫自動提交，而不能回滾為了讓多個 SQL 語句作為一個事務執行：
調用 Connection 對象的 setAutoCommit(false); 以取消自動提交事務
在所有的 SQL 語句都成功執行后，調用 commit(); 方法提交事務
在出現異常時，調用 rollback(); 方法回滾事務
若此時 Connection 沒有被關閉, 則需要恢復其自動提交狀態
public class TranscationTest {/**
- ID1 給 ID2 500錢
- 關于事務:
- 1.如果多個操作，每個使用自己單獨的連接,則無法保證事務 例 test1演示
- 2.具體步驟:
- 1) 事務開始前,取消Connection 的默認的自動提交 setAutoCommit(false);
- 2) 如果事務的操作都成功,那么就提交事務
- 3)否則在 try-catch塊中回滾
- try {
- conn.setAutoCommit(false);
- ...
- conn.commit();
- }catch{
- ...
- conn.rollback();
} */ @Test public void test2(){
Connection conn = null; try {
conn = JDBC_Tools.getConnection(); //System.out.println(conn.getAutoCommit()); // 1) 取消自動提交 conn.setAutoCommit(false); String sql = "UPDATE rent set money = " + "money - 500 where id = ?"; // 2) 如果事務的操作都成功,那么就提交事務 update(conn,sql, 1); //int i = 1 / 0; sql = "UPDATE rent set money = " + "money + 500 where id = ?"; update(conn,sql, 2); conn.commit();} catch (Exception e) {
e.printStackTrace(); // 3)否則在 try-catch塊中回滾 try { conn.rollback(); } catch (SQLException e1) { e1.printStackTrace(); }}finally{
JDBC_Tools.relaseSource(conn, null);} } public static void update(Connection conn,String sql,Object...objs){
PreparedStatement ps =null; try {
ps = conn.prepareStatement(sql); for(int i = 0;i<objs.length;i++){ ps.setObject(i+1, objs[i]); } ps.executeUpdate();} catch (Exception e) {
e.printStackTrace();}finally{
JDBC_Tools.relaseSource(null, ps);} }
@Test public void test1() {
String sql = "UPDATE rent set money = "
+ "money - 500 where id = ?";DAO.update(sql, 1);
int i = 1 / 0; //一旦出現異常, ID1 減了500,但是 ID2 的錢并沒有增加
sql = "UPDATE rent set money = "
+ "money + 500 where id = ?";DAO.update(sql, 2); }
}</pre>
三、數據庫的隔離級別
對于同時運行的多個事務, 當這些事務訪問數據庫中相同的數據時, 如果沒有采取必要的隔離機制, 就會導致各種并發問題:
臟讀: 對于兩個事物 T1, T2, T1 讀取了已經被 T2 更新但還沒有被提交的字段. 之后, 若 T2 回滾, T1讀取的內容就是臨時且無效的.
不可重復讀: 對于兩個事物 T1, T2, T1 讀取了一個字段, 然后 T2 更新了該字段. 之后, T1再次讀取同一個字段, 值就不同了.
幻讀: 對于兩個事物 T1, T2, T1 從一個表中讀取了一個字段, 然后 T2 在該表中插入了一些新的行. 之后, 如果 T1 再次讀取同一個表, 就會多出幾行.
數據庫事務的隔離性: 數據庫系統必須具有隔離并發運行各個事務的能力, 使它們不會相互影響, 避免各種并發問題.
一個事務與其他事務隔離的程度稱為隔離級別. 數據庫規定了多種事務隔離級別, 不同隔離級別對應不同的干擾程度, 隔離級別越高, 數據一致性就越好, 但并發性越弱
數據庫提供的 4 種事務隔離級別:
Oracle 支持的 2 種事務隔離級別：READ COMMITED, SERIALIZABLE. Oracle 默認的事務隔離級別為: READ COMMITED
Mysql 支持 4 中事務隔離級別. Mysql 默認的事務隔離級別為: REPEATABLE READ
演示
/*** ID1 給 ID2 500錢 * 關于事務: * 1.如果多個操作，每個使用自己單獨的連接,則無法保證事務 例 test1演示 * 2.具體步驟: * 1) 事務開始前,取消Connection 的默認的自動提交 setAutoCommit(false); * 2) 如果事務的操作都成功,那么就提交事務 * 3)否則在 try-catch塊中回滾 * try { * * conn.setAutoCommit(false); * ... * conn.commit(); * }catch{ * ... * conn.rollback(); * } */ @Test public void test2(){ Connection conn = null; try { conn = JDBC_Tools.getConnection(); //System.out.println(conn.getAutoCommit()); // 1) 取消自動提交 conn.setAutoCommit(false); String sql = "UPDATE rent set money = " + "money - 500 where id = ?"; // 2) 如果事務的操作都成功,那么就提交事務 update(conn,sql, 1); //int i = 1 / 0; sql = "UPDATE rent set money = " + "money + 500 where id = ?"; update(conn,sql, 2); conn.commit(); } catch (Exception e) { e.printStackTrace(); // 3)否則在 try-catch塊中回滾 try { conn.rollback(); } catch (SQLException e1) { e1.printStackTrace(); } }finally{ JDBC_Tools.relaseSource(conn, null); } }public static void update(Connection conn,String sql,Object...objs){
PreparedStatement ps =null; try { ps = conn.prepareStatement(sql); for(int i = 0;i<objs.length;i++){ ps.setObject(i+1, objs[i]); } ps.executeUpdate(); } catch (Exception e) { e.printStackTrace(); }finally{ JDBC_Tools.relaseSource(null, ps); } } @Test public void test1() { String sql = "UPDATE rent set money = " + "money - 500 where id = ?"; DAO.update(sql, 1); int i = 1 / 0; //一旦出現異常, ID1 減了500,但是 ID2 的錢并沒有增加 sql = "UPDATE rent set money = " + "money + 500 where id = ?"; DAO.update(sql, 2); }</pre> 設置隔離級別<p> </p>
public static <E> E getForValue(String sql){//1. 得到結果集，該結果只有一行一列 Connection conn = null; PreparedStatement ps = null; ResultSet rs = null; try { //1. 獲取數據庫連接 conn = JDBC_Tools.getConnection();//System.out.println(conn.getTransactionIsolation()); conn.setTransactionIsolation(Connection.TRANSACTION_READ_COMMITTED); //2. 獲取 PreparedStatement 對象 ps = conn.prepareStatement(sql); //2. 取得結果 rs = ps.executeQuery(); if(rs.next()){ return (E)rs.getObject(1); } }catch(Exception e){ e.printStackTrace(); }finally{ JDBC_Tools.relaseSource(rs,conn, ps); } return null; }</pre> <br />在 MySql 中設置隔離級別
每啟動一個 mysql 程序, 就會獲得一個單獨的數據庫連接. 每個數據庫連接都有一個全局變量 @@tx_isolation, 表示當前的事務隔離級別. MySQL 默認的隔離級別為 Repeatable Read
來自：http://blog.csdn.net/wjw0130/article/details/43796173
查看當前的隔離級別: SELECT @@tx_isolation;
設置當前 mySQL 連接的隔離級別:
set transaction isolation level read committed;
設置數據庫系統的全局的隔離級別:
set global transaction isolation level read committed;