JAVA程序對MYSQL數據庫加鎖實驗

什么是臟讀，不可重復讀，幻讀

1. 臟讀 ：臟讀就是指當一個事務正在訪問數據，並且對數據進行了修改，而這種修改還沒有提交到數據庫中，這時，另外一個事務也訪問這個數據，然后使用了這個數據。

2. 不可重復讀 ：是指在一個事務內，多次讀同一數據。在這個事務還沒有結束時，另外一個事務也訪問該同一數據。那么，在第一個事務中的兩次讀數據之間，由於第二個事務的修改，那么第一個事務兩次讀到的的數據可能是不一樣的。這樣就發生了在一個事務內兩次讀到的數據是不一樣的，因此稱為是不可重復讀。例如，一個編輯人員兩次讀取同一文檔，但在兩次讀取之間，作者重寫了該文檔。當編輯人員第二次讀取文檔時，文檔已更改。原始讀取不可重復。如果只有在作者全部完成編寫后編輯人員才可以讀取文檔，則可以避免該問題。

3. 幻讀 : 是指當事務不是獨立執行時發生的一種現象，例如第一個事務對一個表中的數據進行了修改，這種修改涉及到表中的全部數據行。同時，第二個事務也修改這個表中的數據，這種修改是向表中插入一行新數據。那么，以后就會發生操作第一個事務的用戶發現表中還有沒有修改的數據行，就好象發生了幻覺一樣。例如，一個編輯人員更改作者提交的文檔，但當生產部門將其更改內容合並到該文檔的主復本時，發現作者已將未編輯的新材料添加到該文檔中。如果在編輯人員和生產部門完成對原始文檔的處理之前，任何人都不能將新材料添加到文檔中，則可以避免該問題。

補充 : 基於元數據的 Spring 聲明性事務 :

Isolation 屬性一共支持五種事務設置，具體介紹如下：

l          DEFAULT 使用數據庫設置的隔離級別 ( 默認 ) ，由 DBA 默認的設置來決定隔離級別 .

l          READ_UNCOMMITTED 會出現臟讀、不可重復讀、幻讀 ( 隔離級別最低，並發性能高 )

l          READ_COMMITTED  會出現不可重復讀、幻讀問題（鎖定正在讀取的行）

l          REPEATABLE_READ 會出幻讀（鎖定所讀取的所有行）

l          SERIALIZABLE 保證所有的情況不會發生（鎖表）

不可重復讀的重點是修改 :
同樣的條件 ,   你讀取過的數據 ,   再次讀取出來發現值不一樣了
幻讀的重點在於新增或者刪除
同樣的條件 ,   第 1 次和第 2 次讀出來的記錄數不一樣

再想了想，其實你后面說的都沒錯，唯一的問題是“數據庫不會處理並發操作”這個理解所引發的，數據庫不是不會處理並發操作，如果它不會處理就沒有加鎖機制和事務隔離機制了，數據庫的問題是在於它並不知道你的並發依賴關系，因此需要你告知它。數據庫的並發處理控制並不依賴於Hibernate或其它數據訪問層的實現機制，唯一需要的只是你要“告知它”哪里需要重點關照。


數據庫默認情況下的事務管理是“已提交讀取”，也就是說已經可以保證Select不會拿到臟數據（不會發生臟讀----你理解錯的地方）；當然也可能你理解錯的臟讀，臟讀的意思是，事務B拿到了事務A中間狀態的數據，而A后來把這個整個事務回滾了，那么事務B就相當於拿到了一個實際上根本不存在的臟數據。


而不可重復讀（幻讀）和更新丟失的問題需要另外解決，這個你是說對了的；目前除了加鎖（排他鎖）和串行化隔離外，沒有更好招數。


雖然你只錯了一個地方，但我感覺可能你還沒有理解的比較透徹，建議去找找：臟讀（寫-讀依賴）、更新丟（寫-寫依賴）、幻讀（讀-寫依賴）這幾個東西的概念，最好能自己舉例說明。

 

 

 

JAVA程序對MYSQL數據庫加鎖實驗

分類：  mysql 2010-09-13 14:11  761人閱讀 評論(0) 收藏 舉報

以下實驗僅在MYSQL 5.0.45做的實驗.

方法1：用mysql命令鎖住表.
    

[java]  view plain copy print ?

1.   public void test() {  
2.   
3.     String sql = "lock tables aa1 write";  
4.     // 或String sql = "lock tables aa1 read";   
5.     // 如果想鎖多個表 lock tables aa1 read ,aa2 write , .....   
6.     String sql1 = "select * from aa1 ";  
7.   
8.     String sql2 = "unlock tables";  
9.     try {  
10.         this.pstmt = conn.prepareStatement(sql);  
11.         this.pstmt1 = conn.prepareStatement(sql1);  
12.         this.pstmt2 = conn.prepareStatement(sql2);  
13.         pstmt.executeQuery();  
14.         pstmt1.executeQuery();  
15.         pstmt2.executeQuery();  
16.   
17.     } catch (Exception e) {  
18.         System.out.println("異常" + e.getMessage());  
19.     }  
20.   
21. }  

一、對於read lock 和 write lock官方說明：
   1.如果一個線程獲得一個表的READ鎖定，該線程（和所有其它線程）只能從該表中讀取。
      如果一個線程獲得一個表的WRITE鎖定，只有保持鎖定的線程可以對表進行寫入。
      其它的線程被阻止，直到鎖定被釋放時為止。

   2.當您使用LOCK TABLES時，您必須鎖定您打算在查詢中使用的所有的表。
      雖然使用LOCKTABLES語句獲得的鎖定仍然有效，但是您不能訪問沒有被此語句鎖定的任何的表。
      同時，您不能在一次查詢中多次使用一個已鎖定的表——使用別名代替，
      在此情況下，您必須分別獲得對每個別名的鎖定。

二、對與read lock 和 write lock個人說明：
    1.read lock 和 write lock 是線程級(表級別).
    2.在同一個會話中加了read lock鎖. 只能對這個表進行讀操作.對這個表以外的任何表都無法進行增、刪、改、查的操作.
       但是在不同會話中，只能對加了read lock的表進行讀操作.但可以對read lock以外的表進行增、刪、改、查的操作.
    3.在同一個會話中加了write lock鎖.只能對這個表進行讀、寫操作.對這個表以外的任何表都無法進行增、刪、改、查的操作.
      但是在不同會話中,無法對加了write lock的表進行讀、寫操作.但可以對write lock以外的表進行增、刪、改、查的操作.
   4.如果表中使用了別名.(SELECT * FROM aa1 AS byname_table)
      在對aa1加鎖時，必須把別名加上去(lock tables aa1 as byname_table read)
      在同一個會話中.必須使用別名進行查詢.
      在不同的會話中.可以不需要使用別名進行查詢.
   5.在多個會話中可以對同一個表進行lock read操作.但不能在多個會話中對同一個表進行lock write操作（這些鎖將等待已鎖的表釋放自身的線程鎖）
     如果多個會話對同一個表進行lock read操作.那么在這些會話中,也只能對以鎖的表進行讀操作.
   6.如果要你鎖住了一個表，需要嵌套查詢.你必須使用別名，並且，要鎖定別名.
     例如.lock table aa1 read ,aa1 as byname_table read;
     select * from aa1 where id in (select * from aa1 as xx  where id=2);  
   7.解鎖必須用unlock tables;

   另:
      在JAVA程序中,要想解鎖,需要調用 unlock tables來解鎖.
      如果沒有調用unlock tables.
      關閉connection 、程序結束 、調用GC 都能解鎖.      

方法2：用記錄鎖鎖表. 

[java]  view plain copy print ?

1.   public void test() {  
2.   
3.     String sql = "select * from aa1 for update";   
4.                // select * from aa1 lock in share mode;   
5.   
6.     try {  
7.         conn.setAutoCommit(false);  
8.         this.pstmt = conn.prepareStatement(sql);  
9.         pstmt.executeQuery();  
10.   
11.     } catch (Exception e) {  
12.         System.out.println("異常" + e.getMessage());  
13.     }  
14.   
15. }  

 
 
1.for update 與 lock in share mode 屬於行級鎖和頁級鎖

2.for update 排它鎖,lock in share mode 共享鎖

3.對於記錄鎖.必須開啟事務.

4.行級鎖定事實上是索引記錄的鎖定.只要是用索引掃描的行（或沒索引全表掃描的行）,都將被鎖住.

5.在不同的隔離級別下還會使用next-key locking算法.即所掃描的行之間的“間隙”也會也鎖住(在Repeatable read和Serializable隔離級別下有間隙鎖).

6.在mysql中共享鎖的含義是:在被共享鎖鎖住的行,即使內容被修改且並沒有提交.在另一個會話中依然看到最新修改的信息.

   在同一會話中加上了共享鎖.可以對這個表以及這個表以外的所有表進行增、刪、改、查的操作.

   在不同的會話中.可以查到共享鎖鎖住行的最新消息.但是在Read Uncommitted隔離級別下不能對鎖住的表進行刪，

    改操作.（需要等待鎖釋放才能操作...）
                     在Read Committed隔離級別下不能對鎖住的表進行刪，改操作.（需要等待鎖釋放才能操作...）
                     在Repeatable read隔離級別下不能對鎖住行進行增、刪、改操作.（需要等待鎖釋放才能操作...）
                     在Serializable隔離級別下不能對鎖住行進行增、刪、改操作.  （需要等待鎖釋放才能操作...）

7.在mysql中排他鎖的含義是:在被排它鎖鎖住的行,內容修改並沒提交，在另一個會話中不會看到最新修改的信息。

   在不同的會話中.可以查到共享鎖鎖住行的最新消息.但是Read Uncommitted隔離級別下不能對鎖住的表進行刪，

    改操作.（需要等待鎖釋放才能操作...）
                     在Read Committed隔離級別下不能對鎖住的表進行刪，改操作.（需要等待鎖釋放才能操作...）
                     在Repeatable read隔離級別下不能對鎖住行進行增、刪、改操作.（需要等待鎖釋放才能操作...）
                     在Serializable隔離級別下不能對鎖住行進行增、刪、改操作. （需要等待鎖釋放才能操作...）   

8.在同一個會話中的可以疊加多個共享鎖和排他鎖.在多個會話中,需要等待鎖的釋放.

9.SQL中的update 與 for update是一樣的原理.

10.等待超時的參數設置:innodb_lock_wait_timeout=50 (單位秒).

11.任何可以觸發事務提交的命令,都可以關閉共享鎖和排它鎖.