- 事務(wù)具有ACID原則屋厘，各個(gè)數(shù)據(jù)庫實(shí)現(xiàn)了這些原則(用日志實(shí)現(xiàn)原子性坏逢，一致性高诺，持久性踱讨，用鎖實(shí)現(xiàn)隔離性)
- 隔離級別有四種(Read UnCommitted,Read Committed,Repeated Read, Serializable)惹谐，在不同的隔離級別下持偏，有可能會出現(xiàn)臟讀驼卖，不可重復(fù)讀，幻讀等現(xiàn)象
| 隔離級別 | 是否存在臟讀 | 是否存在不可重復(fù)讀 | 是否存在幻讀 |
|---|---|---|---|
| Read UnCommitted | Y | Y | Y |
| Read Committed | N | Y | Y |
| Repeated Read | N | N | Y |
| Serializable | N | N | N |
臟讀舉例：
- Mary的原工資為1000, 財(cái)務(wù)人員將Mary的工資改為了8000(但未提交事務(wù))
- Mary讀取自己的工資 ,發(fā)現(xiàn)自己的工資變?yōu)榱?000鸿秆，歡天喜地酌畜！
- 而財(cái)務(wù)發(fā)現(xiàn)操作有誤，回滾了事務(wù),Mary的工資又變?yōu)榱?000像這樣,Mary記取的工資數(shù)8000是一個(gè)臟數(shù)據(jù)卿叽。
不可重復(fù)讀：
- 在事務(wù)1中桥胞，Mary 讀取了自己的工資為1000,操作并沒有完成
- 在事務(wù)2中，這時(shí)財(cái)務(wù)人員修改了Mary的工資為2000,并提交了事務(wù).
- 在事務(wù)1中考婴，Mary 再次讀取自己的工資時(shí)贩虾，工資變?yōu)榱?000
幻讀
目前工資為1000的員工有10人。
- 事務(wù)1,讀取所有工資為1000的員工沥阱。
- 這時(shí)事務(wù)2向employee表插入了一條員工記錄缎罢，工資也為1000
- 事務(wù)1再次讀取所有工資為1000的員工 共讀取到了11條記錄，
本文就是用hibernate考杉，然后修改mysql數(shù)據(jù)庫中的隔離級別來重現(xiàn)上述現(xiàn)象策精，以此來深刻體會事務(wù)的隔離性
實(shí)體類：
package entity;
import java.util.Date;
public class User {
private int id;
private String userName;
private Date addtime;
public Date getAddtime() {
return addtime;
}
public void setAddtime(Date addtime) {
this.addtime = addtime;
}
public User(){}
public int getId() {
return id;
}
public void setId(int id) {
this.id = id;
}
public String getUserName() {
return userName;
}
public void setUserName(String userName) {
this.userName = userName;
}
}
映射文件：
<?xml version="1.0"?>
<!DOCTYPE hibernate-mapping PUBLIC
"-//Hibernate/Hibernate Mapping DTD 3.0//EN"
"http://hibernate.sourceforge.net/hibernate-mapping-3.0.dtd">
<hibernate-mapping>
<class name="entity.User" table="_user" >
<id name="id">
<generator class="native" />
</id>
<property name="userName" />
<property name="addtime" type="time" />
</class>
</hibernate-mapping>
單元測試：
package entity;
import java.util.Date;
import java.util.List;
import org.hibernate.classic.Session;
import org.hibernate.criterion.Projection;
import org.hibernate.criterion.Projections;
import junit.framework.TestCase;
import util.hibernateUtil;
/**
* 測試目的： 1. 不同的數(shù)據(jù)庫實(shí)現(xiàn)鎖(隔離)的機(jī)制不同，在不同機(jī)制下崇棠，重現(xiàn)臟讀咽袜，不可重復(fù)讀，幻讀等現(xiàn)象 2. 利用phpunit實(shí)現(xiàn)多事務(wù)爭搶同一數(shù)據(jù)現(xiàn)象
* 3. 修改mysql數(shù)據(jù)庫隔離級別
*
* @author arkulo
*
*/
public class TestTransaction extends TestCase {
// 1. 改變數(shù)據(jù)庫隔離級別枕稀，至Read UnCommitted
// 查詢mysql數(shù)據(jù)庫的隔離級別：select @@global.tx_isolation,@@tx_isolation;
// 修改mysql數(shù)據(jù)庫當(dāng)前會話隔離級別：set session transaction isolation level read
// uncommitted;
//
// 問題：在數(shù)據(jù)庫中修改的時(shí)候询刹，該session會話級別的隔離是不行的，只能改global級別的隔離
// 這個(gè)函數(shù)是查詢當(dāng)前數(shù)據(jù)庫的隔離級別
// 給user表中初始化一條數(shù)據(jù)
public void getACID() {
Session session = null;
try {
session = hibernateUtil.getSession();
session.beginTransaction();
List res = session.createSQLQuery("select @@tx_isolation").list();
for (Object i : res) {
System.out.println("隔離級別：" + i.toString());
}
User user = new User();
user.setUserName("王蕊");
user.setAddtime(new Date());
// id策略是native抽莱，在save之后就立刻發(fā)出sql語句范抓，這里設(shè)斷點(diǎn)停住骄恶，不提交commit
session.save(user);
session.getTransaction().commit();
} catch (Exception e) {
e.printStackTrace();
session.getTransaction().rollback();
} finally {
hibernateUtil.closeSession(session);
}
}
// 重現(xiàn)臟讀：在一個(gè)事務(wù)未提交的時(shí)候食铐，另外一個(gè)事務(wù)就可以讀取到該事務(wù)中的新增數(shù)據(jù)
// 2. 啟動第一個(gè)進(jìn)程做斷點(diǎn)，到save后停止僧鲁，啟動另外一個(gè)進(jìn)程虐呻，直接執(zhí)行，看看能不能讀到數(shù)據(jù)庫中的數(shù)據(jù)
public void test1() {
// getACID();
System.out.println("-------------------------------------");
Session session = null;
try {
session = hibernateUtil.getSession();
session.beginTransaction();
User user = (User) session.load(User.class, 1);
System.out.println("用戶名：" + user.getUserName());
user.setUserName("李四");
session.update(user);
session.flush();
// 單步斷點(diǎn)寞秃，停在這里不提交斟叼，但是需要flush
session.getTransaction().commit();
} catch (Exception e) {
e.printStackTrace();
session.getTransaction().rollback();
} finally {
hibernateUtil.closeSession(session);
}
}
// 再啟動一個(gè)進(jìn)程，運(yùn)行這個(gè)函數(shù)去讀取user表中的第一條數(shù)據(jù)春寿，這時(shí)候就會發(fā)現(xiàn)
// 1. 隔離級別是READ UNCOMMITED朗涩，讀取事務(wù)并沒有被阻塞
// 2. 這里讀出的用戶名是李四，屬于臟讀
public void test1_1() {
Session session = null;
try {
session = hibernateUtil.getSession();
session.beginTransaction();
User user = (User) session.get(User.class, 1);
System.out.println("用戶名：" + user.getUserName());
session.getTransaction().commit();
} catch (Exception e) {
e.printStackTrace();
session.getTransaction().rollback();
} finally {
hibernateUtil.closeSession(session);
}
}
// －－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－
// 這里展示不可重復(fù)讀問題
public void test2() {
Session session = null;
try {
session = hibernateUtil.getSession();
session.beginTransaction();
User user = (User) session.get(User.class, 1);
System.out.println("用戶名：" + user.getUserName());
// 因?yàn)間et函數(shù)會緩存對象到一級緩存绑改，這里需要把緩存清理掉
// 如果不清理谢床，系統(tǒng)會采用緩存中的數(shù)據(jù)兄一，而下面的get函數(shù)就不會發(fā)出sql語句查詢
session.evict(user);
// 在這里斷點(diǎn)停住，當(dāng)另外一個(gè)用戶的事務(wù)結(jié)束之后识腿，這里再繼續(xù)
User user1 = (User) session.get(User.class, 1);
// 這里讀出的用戶名是李四３龈铩！
System.out.println("用戶名：" + user1.getUserName());
session.getTransaction().commit();
} catch (Exception e) {
e.printStackTrace();
session.getTransaction().rollback();
} finally {
hibernateUtil.closeSession(session);
}
}
// 當(dāng)test2第一個(gè)查詢執(zhí)行完畢之后,test2_1修改用戶名渡讼，然后再執(zhí)行test2中的第二個(gè)查詢
public void test2_1() {
Session session = null;
try {
session = hibernateUtil.getSession();
session.beginTransaction();
User user = (User) session.get(User.class, 1);
user.setUserName("李四");
session.getTransaction().commit();
} catch (Exception e) {
e.printStackTrace();
session.getTransaction().rollback();
} finally {
hibernateUtil.closeSession(session);
}
}
// －－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－
// 以下部分是幻讀的重現(xiàn)
public void test3() {
Session session = null;
try {
session = hibernateUtil.getSession();
session.beginTransaction();
// 以下是兩種查詢總數(shù)的方式，都會用到uniqueResult()
// int acount = ((Long)session.createQuery("select count(*) from
// User").uniqueResult()).intValue();
int acount = ((Number) session.createCriteria("entity.User").setProjection(Projections.rowCount())
.uniqueResult()).intValue();
System.out.println("數(shù)量：" + acount);
// 因?yàn)椴樵兊牟皇菍ο蟪审铮虼瞬粫灰患壘彺嬲瓜洌@里斷點(diǎn)停住
// 這里打印的數(shù)據(jù)庫記錄比上面多了1條，好像是幻覺一樣
int acount1 = ((Number) session.createCriteria("entity.User").setProjection(Projections.rowCount())
.uniqueResult()).intValue();
System.out.println("數(shù)量：" + acount1);
session.getTransaction().commit();
} catch (Exception e) {
e.printStackTrace();
session.getTransaction().rollback();
} finally {
hibernateUtil.closeSession(session);
}
}
// 新起一個(gè)事務(wù)做插入
public void test3_1() {
Session session = null;
try {
session = hibernateUtil.getSession();
session.beginTransaction();
User user = new User();
user.setUserName("李四");
user.setAddtime(new Date());
session.save(user);
session.getTransaction().commit();
} catch (Exception e) {
e.printStackTrace();
session.getTransaction().rollback();
} finally {
hibernateUtil.closeSession(session);
}
}
}