天天看點

java多線程資料庫鎖表_Java程式對MySQL資料庫加鎖實驗

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

方法1:用mysql指令鎖住表.

publicvoidtest() {

String sql ="lock tables aa1 write";

// 或String sql = "lock tables aa1 read";

// 如果想鎖多個表 lock tables aa1 read ,aa2 write , .....

String sql1 ="select * from aa1 ";

String sql2 ="unlock tables";

try{

this.pstmt = conn.prepareStatement(sql);

this.pstmt1 = conn.prepareStatement(sql1);

this.pstmt2 = conn.prepareStatement(sql2);

pstmt.executeQuery();

pstmt1.executeQuery();

pstmt2.executeQuery();

}catch(Exception e) {

System.out.println("異常"+ e.getMessage());

}

}public void test() {

String sql = "lock tables aa1 write";

// 或String sql = "lock tables aa1 read";

// 如果想鎖多個表 lock tables aa1 read ,aa2 write , .....

String sql1 = "select * from aa1 ";

String sql2 = "unlock tables";

try {

this.pstmt = conn.prepareStatement(sql);

this.pstmt1 = conn.prepareStatement(sql1);

this.pstmt2 = conn.prepareStatement(sql2);

pstmt.executeQuery();

pstmt1.executeQuery();

pstmt2.executeQuery();

} catch (Exception e) {

System.out.println("異常" + e.getMessage());

}

}

一、對于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 都能解鎖.

java多線程資料庫鎖表_Java程式對MySQL資料庫加鎖實驗