緩存問題：
/** 使用 Query.executeUpdate() 緩存中數據不同步 解決辦法
* Table -> T1oo(id,name)
* Table -> T2oo(id,avg,aid)
* 外鍵 T1oo.id->T2oo.aid
* Session.createQuery("delete T1oo") -> Query.executeUpdate()
*/
public void testExecuteUpdate(){
System.out.println( " \r\n\r\n********************ExecuteUpdate************************ " );
T1oo t1oo = new T1oo();
t1oo.setName( " liukaiyi " );
HibernateSessionFactory.closeSession();
Session session = HibernateSessionFactory.currentSession();
Transaction tr1 = session.beginTransaction();
// t1 成為 持久狀態 一級緩存中 加載
session.saveOrUpdate(t1oo);
// 直接一條語句刪除T1oo，緩存無法同步
// 一級緩存中還有 t1
Query qu = session.createQuery( " delete T1oo " );
try {
qu.executeUpdate();
} catch (Exception e) {
System.out.println( " //err: 有級聯 單使用 delete T1oo 還要delete T2oo.aid = T1oo.id// " );
List list = session.createQuery( " from T1oo " ).list();
for (Iterator it = list.iterator();it.hasNext();){
Query t2qu = session.createQuery( " delete T2oo where aid=:id " );
t2qu.setInteger( " id " , ((T1oo)it.next()).getId().intValue());
t2qu.executeUpdate();
}
qu.executeUpdate();
}
tr1.commit();
Transaction tr2 = session.beginTransaction();
// 這直接通過一級緩存中加載t2，但DB中以沒有此條數據
t1oo = (T1oo)session.load(T1oo. class ,t1oo.getId());
t1oo.setName( " google " );
try {
tr2.commit();
} catch (Exception e) {
System.out.println( " //err: update(t1oo)->DB 中數據庫中沒有 t1oo // " );
}
System.out.println( " 一級緩存清空前 " + session.get(T1oo. class ,t1oo.getId()) );
session.evict(t1oo);
System.out.println( " 一級緩存清空后 " + session.get(T1oo. class ,t1oo.getId()) );
// 不把t1oo id 為空，否則當在saveOrUpdate時候就會以為是游離態 update了
t1oo.setId( null );
// id=null insert 調用
session.saveOrUpdate(t1oo);
tr2.commit();
Transaction tr3 = session.beginTransaction();
session.delete(t1oo);
tr3.commit();
session.close();
HibernateSessionFactory.closeSession();
}
結果是：
********************ExecuteUpdate************************
log4j:WARN No appenders could be found for logger (org.hibernate.cfg.Environment).
log4j:WARN Please initialize the log4j system properly.
Hibernate: insert into t1oo (name, id) values (?, ?)
Hibernate: delete from t1oo
//err: 有級聯 單使用 delete T1oo 還要delete T2oo.aid = T1oo.id//
Hibernate: select t1oo0_.id as id, t1oo0_.name as name0_ from t1oo t1oo0_
Hibernate: delete from t2oo where aid=?
Hibernate: delete from t2oo where aid=?
Hibernate: delete from t2oo where aid=?
Hibernate: delete from t1oo
Hibernate: update t1oo set name=? where id=?
//err: update(t1oo)->DB 中數據庫中沒有 t1oo //
一級緩存清空前 hbn.bean.T1oo@287
Hibernate: select t1oo0_.id as id0_, t1oo0_.name as name0_0_ from t1oo t1oo0_ where t1oo0_.id=?
一級緩存清空后 null
Hibernate: insert into t1oo (name, id) values (?, ?)
Hibernate: delete from t1oo where id=?
Get Load 區別 ：
/** Get Load 區別 (在commit前要 session.flush())
* Table -> T1oo(id,name)
* 1.如果未能發現符合條件的記錄，get方法返回null，而load方法會拋出異常
* 2.Load方法可返回實體的代理類實例，而get方法永遠直接返回實體類。
* 3.load方法可以充分利用內部緩存和二級緩存中的現有數據，而get方法則僅僅在內部緩存中進行數據查找，
* 如沒有發現對應數據，將越過二級緩存，直接調用SQL完成數據讀取。
*/
public void testGetLoad() throws Exception {
System.out.println("\r\n\r\n********************Get<>Load************************");
Session session = HibernateSessionFactory.currentSession();
// 數據準備
T1oo t1oo = new T1oo();
t1oo.setName("liu");
Transaction t1 = session.beginTransaction();
session.saveOrUpdate(t1oo);
// 為什么這會錯？
//session.evict(t1oo);
//session.flush();
t1.commit();
session.evict(t1oo);
Transaction t2 = session.beginTransaction();
System.out.println("一級緩存是否有t1oo(load)->"+session.contains(t1oo));
//這時候t1oo為 CGlib生成的代理類
t1oo = (T1oo)session.load(T1oo.class,t1oo.getId());
System.out.println(" 延遲加載出現：select.. t1oo0_.id=? 表的其他屬性加載 ");
t1oo.setName("load list");
//后在 update
t2.commit();
session.evict(t1oo);
Transaction t3 = session.beginTransaction();
System.out.println("一級緩存是否有t1oo(get)->"+session.contains(t1oo));
//這時候t1oo為 CGlib生成的代理類
t1oo = (T1oo)session.get(T1oo.class,t1oo.getId());
System.out.println(" 沒有延遲加載出現");
t1oo.setName("get list");
//后在 update
t3.commit();
session.evict(t1oo);
Transaction tr3 = session.beginTransaction();
session.delete(t1oo);
tr3.commit();
session.close();
HibernateSessionFactory.closeSession();
}
結果
********************Get<>Load************************
Hibernate: insert into t1oo (name, id) values (?, ?)
一級緩存是否有t1oo(load)->false
延遲加載出現：select.. t1oo0_.id=? 表的其他屬性加載
Hibernate: select t1oo0_.id as id0_, t1oo0_.name as name0_0_ from t1oo t1oo0_ where t1oo0_.id=?
Hibernate: update t1oo set name=? where id=?
一級緩存是否有t1oo(get)->false
Hibernate: select t1oo0_.id as id0_, t1oo0_.name as name0_0_ from t1oo t1oo0_ where t1oo0_.id=?
沒有延遲加載出現
Hibernate: update t1oo set name=? where id=?
Hibernate: select t2ooset0_.aid as aid1_, t2ooset0_.id as id1_, t2ooset0_.id as id0_, t2ooset0_.avg as avg1_0_, t2ooset0_.aid as aid1_0_ from t2oo t2ooset0_ where t2ooset0_.aid=?
Hibernate: delete from t1oo where id=?
Set 集合的識別：
/** Set 集合的識別
* Table -> T1oo(id,name)
* Table -> T2oo(id,avg,aid)
* 外鍵 T1oo.id->T2oo.aid
* T1oo <set name="t2ooSet" inverse="false" cascade = "all" >
* T2oo <many-to-one name="t1oo" column="aid" class="T1oo" />
* cascade='insert' 是一定要的
* 當 T1oo沒有 inverse="true" 主動權的時候，要雙項關聯
* t1oo.getT2ooSet().add(t2oo1);
* t1oo.getT2ooSet().add(t2oo2);
* t2oo1.setT1oo(t1oo);
* t2oo2.setT1oo(t1oo);
* 要不后sql為：
* Hibernate: insert into t2oo (avg, aid, id) values (?, ?, ?)
* Hibernate: insert into t2oo (avg, aid, id) values (?, ?, ?)
* +----+-----+------+
* | id | avg | aid |
* +----+-----+------+
* | 1 | 24 | NULL |
* | 2 | 23 | NULL |
* +----+-----+------+
* 當 T1oo有 inverse="false"主動權的時候
* t1oo.getT2ooSet().add(t2oo1);
* t1oo.getT2ooSet().add(t2oo2);
* Sql語句為：
* Hibernate: insert into t1oo (name, id) values (?, ?)
* Hibernate: insert into t2oo (avg, aid, id) values (?, ?, ?)
* Hibernate: insert into t2oo (avg, aid, id) values (?, ?, ?)
* Hibernate: update t2oo set aid=? where id=?
* Hibernate: update t2oo set aid=? where id=?
* | 3 | 24 | 12 |
* | 4 | 23 | 12 |
* +----+-----+------+
*/
public void testSet(){
System.out.println("\r\n\r\n********************Set************************");
T1oo t1oo = new T1oo();
t1oo.setName("list");
T2oo t2oo1 = new T2oo(); t2oo1.setAvg(new Integer(23));
T2oo t2oo2 = new T2oo(); t2oo2.setAvg(new Integer(24));
Session session = HibernateSessionFactory.currentSession();
Transaction tr1 = session.beginTransaction();
session.save(t1oo);
t1oo = (T1oo) session.load(T1oo.class,t1oo.getId());
t1oo.setT2ooSet(new HashSet()) ;
t1oo.getT2ooSet().add(t2oo1);
t1oo.getT2ooSet().add(t2oo2);
System.out.println( t1oo.getT2ooSet().size()+"" );
tr1.commit();
System.out.println();
T2oo t2oo3 = new T2oo(); t2oo3.setAvg(new Integer(25));
T1oo t1oo2 = new T1oo(); t1oo2.setName("mz");
t2oo3.setT1oo(t1oo2);
Transaction tr2 = session.beginTransaction();
session.save(t2oo3);
try {
tr2.commit();
} catch (Exception e) {
System.out.println("//err: 沒有主動權 cascade = 'all' 不可以級聯save t1oo //");
}
session.close();
HibernateSessionFactory.closeSession();
}
結果是：
********************Set************************
2
Hibernate: insert into t1oo (name, id) values (?, ?)
Hibernate: insert into t2oo (avg, aid, id) values (?, ?, ?)
Hibernate: insert into t2oo (avg, aid, id) values (?, ?, ?)
Hibernate: update t2oo set aid=? where id=?
Hibernate: update t2oo set aid=? where id=?
//err: 沒有主動權 cascade = 'all' 不可以級聯save t1oo //
inverse 使用
說明約定-如：
1.表屬性 :T1oo->id,name
T2oo->id,avg,aid( 外鍵 ),version
2.代碼過程是：Save->t1oo對象(T1oo 外鍵 T2oo)
T1oo t1oo = new T1oo();
t1oo.setName("xx");
t1oo.setT2ooSet(new HashSet());
T2oo t2oo2 = new T2oo(24);
//t2oo2.setT1oo(t1oo); (在下面的本用例表中的第3屬性 )
t1oo.getT2ooSet().add(t2oo2); (在下面的本用例表中的第2屬性 )
session.save(t1oo);
3.本例表使用：
T1oo.hbm.xml ->
<set name="t2ooSet" inverse="true" cascade = "all" > (在下面的本用例表中的第1，2屬性 )
<key column="aid"/>
<one-to-many class="T2oo"/>
</set>
T2oo.hbm.xml ->
<many-to-one name="t1oo" column="aid" class="T1oo" cascade="all" /> (在下面的本用例表中的第1，2屬性 )
結合上面說明得表為：
+-------+-------+-------+----------+----------+
|hbn.xml|inverse|cascade|t1oo->t2oo|t2oo->t1oo|
+-------+-------+-------+----------+----------+
| t1oo | true | all | | |
+-------+-------+-------+ true | false |
| t2oo | | all | | |
+-------+-------+-------+----------+----------+
4.執行 Hibernate語句 ：
Hibernate: insert into t1oo (name, id) values (?, ?)
Hibernate: insert into t2oo (version, avg, aid, id) values (?, ?, ?, ?)
5.結果為：
mysql> select * from t2oo;
+----+-----+------+---------+
| id | avg | aid | version |
+----+-----+------+---------+
| 2 | 24 | NULL | 0 | //主要就是看 aid屬性
+----+-----+------+---------+
1 row in set (0.00 sec)
mysql> select * from t1oo; // 因為 T1oo總是可以 Save 下面就不再提了
+----+------+
| id | name |
+----+------+
| 2 | xx |
+----+------+
1 row in set (0.00 sec)
可改項：
+-------+-------+-------+----------+----------+
|hbn.xml|inverse|cascade|t1oo->t2oo|t2oo->t1oo|
+-------+-------+-------+----------+----------+
| t1oo | 可改4 | 可改2 | | |
+-------+-------+-------+ | 可改1 |
| t2oo | | 可改3 | | |
+-------+-------+-------+----------+----------+
主本:
+-------+-------+-------+----------+----------+
|hbn.xml|inverse|cascade|t1oo->t2oo|t2oo->t1oo|
+-------+-------+-------+----------+----------+
| t1oo | true | all | | |
+-------+-------+-------+ true | true |
| t2oo | | all | | |
+-------+-------+-------+----------+----------+
Hibernate: insert into t1oo (name, id) values (?, ?)
Hibernate: insert into t2oo (version, avg, aid, id) values (?, ?, ?, ?)
mysql> select * from t2oo;
+----+-----+------+---------+
| id | avg | aid | version |
+----+-----+------+---------+
| 1 | 24 | 1 | 0 |
+----+-----+------+---------+
1 row in set (0.00 sec)
改1
+-------+-------+-------+----------+----------+
|hbn.xml|inverse|cascade|t1oo->t2oo|t2oo->t1oo|
+-------+-------+-------+----------+----------+
| t1oo | true | all | | |
+-------+-------+-------+ true | false |
| t2oo | | all | | |
+-------+-------+-------+----------+----------+
Hibernate: insert into t1oo (name, id) values (?, ?)
Hibernate: insert into t2oo (version, avg, aid, id) values (?, ?, ?, ?)
mysql> select * from t2oo;
+----+-----+------+---------+
| id | avg | aid | version |
+----+-----+------+---------+
| 1 | 24 | NULL| 0 |
+----+-----+------+---------+
1 row in set (0.00 sec)
改2
+-------+-------+-------+----------+----------+
|hbn.xml|inverse|cascade|t1oo->t2oo|t2oo->t1oo|
+-------+-------+-------+----------+----------+
| t1oo | true | | | |
+-------+-------+-------+ true | true |
| t2oo | | all | | |
+-------+-------+-------+----------+----------+
Hibernate: insert into t1oo (name, id) values (?, ?)
Empty set (0.00 sec)
改2 改1
+-------+-------+-------+----------+----------+
|hbn.xml|inverse|cascade|t1oo->t2oo|t2oo->t1oo|
+-------+-------+-------+----------+----------+
| t1oo | true | | | |
+-------+-------+-------+ true | false |
| t2oo | | all | | |
+-------+-------+-------+----------+----------+
Hibernate: insert into t1oo (name, id) values (?, ?)
Empty set (0.00 sec)
改3
+-------+-------+-------+----------+----------+
|hbn.xml|inverse|cascade|t1oo->t2oo|t2oo->t1oo|
+-------+-------+-------+----------+----------+
| t1oo | true | all | | |
+-------+-------+-------+ true | true |
| t2oo | | | | |
+-------+-------+-------+----------+----------+
Hibernate: insert into t1oo (name, id) values (?, ?)
Hibernate: insert into t2oo (version, avg, aid, id) values (?, ?, ?, ?)
mysql> select * from t2oo;
+----+-----+------+---------+
| id | avg | aid | version |
+----+-----+------+---------+
| 1 | 24 | 1 | 0 |
+----+-----+------+---------+
1 row in set (0.00 sec)
改3 改2
+-------+-------+-------+----------+----------+
|hbn.xml|inverse|cascade|t1oo->t2oo|t2oo->t1oo|
+-------+-------+-------+----------+----------+
| t1oo | true | | | |
+-------+-------+-------+ true | true |
| t2oo | | | | |
+-------+-------+-------+----------+----------+
Hibernate: insert into t1oo (name, id) values (?, ?)
Empty set (0.00 sec)
改3 改1
+-------+-------+-------+----------+----------+
|hbn.xml|inverse|cascade|t1oo->t2oo|t2oo->t1oo|
+-------+-------+-------+----------+----------+
| t1oo | true | all | | |
+-------+-------+-------+ true | false |
| t2oo | | | | |
+-------+-------+-------+----------+----------+
Hibernate: insert into t1oo (name, id) values (?, ?)
Hibernate: insert into t2oo (version, avg, aid, id) values (?, ?, ?, ?)
mysql> select * from t2oo;
+----+-----+------+---------+
| id | avg | aid | version |
+----+-----+------+---------+
| 1 | 24 | NULL | 0 |
+----+-----+------+---------+
1 row in set (0.00 sec)
改3 改2 改1
+-------+-------+-------+----------+----------+
|hbn.xml|inverse|cascade|t1oo->t2oo|t2oo->t1oo|
+-------+-------+-------+----------+----------+
| t1oo | true | | | |
+-------+-------+-------+ true | false |
| t2oo | | | | |
+-------+-------+-------+----------+----------+
Hibernate: insert into t1oo (name, id) values (?, ?)
Empty set (0.00 sec)
改4
+-------+-------+-------+----------+----------+
|hbn.xml|inverse|cascade|t1oo->t2oo|t2oo->t1oo|
+-------+-------+-------+----------+----------+
| t1oo | false | all | | |
+-------+-------+-------+ true | true |
| t2oo | | all | | |
+-------+-------+-------+----------+----------+
Hibernate: insert into t1oo (name, id) values (?, ?)
Hibernate: insert into t2oo (version, avg, aid, id) values (?, ?, ?, ?)
Hibernate: update t2oo set aid=? where id=?
mysql> select * from t2oo;
+----+-----+------+---------+
| id | avg | aid | version |
+----+-----+------+---------+
| 1 | 24 | 1 | 0 |
+----+-----+------+---------+
1 row in set (0.02 sec)
改4 改1
+-------+-------+-------+----------+----------+
|hbn.xml|inverse|cascade|t1oo->t2oo|t2oo->t1oo|
+-------+-------+-------+----------+----------+
| t1oo | false | all | | |
+-------+-------+-------+ true | false |
| t2oo | | all | | |
+-------+-------+-------+----------+----------+
Hibernate: insert into t1oo (name, id) values (?, ?)
Hibernate: insert into t2oo (version, avg, aid, id) values (?, ?, ?, ?)
Hibernate: update t2oo set aid=? where id=?
mysql> select * from t2oo;
+----+-----+------+---------+
| id | avg | aid | version |
+----+-----+------+---------+
| 1 | 24 | 1 | 0 |
+----+-----+------+---------+
1 row in set (0.00 sec)
改4 改2
+-------+-------+-------+----------+----------+
|hbn.xml|inverse|cascade|t1oo->t2oo|t2oo->t1oo|
+-------+-------+-------+----------+----------+
| t1oo | false | | | |
+-------+-------+-------+ true | true |
| t2oo | | all | | |
+-------+-------+-------+----------+----------+
Hibernate: insert into t1oo (name, id) values (?, ?)
Hibernate: update t2oo set aid=? where id=?
Empty set (0.00 sec)
改4 改3
+-------+-------+-------+----------+----------+
|hbn.xml|inverse|cascade|t1oo->t2oo|t2oo->t1oo|
+-------+-------+-------+----------+----------+
| t1oo | false | all | | |
+-------+-------+-------+ true | true |
| t2oo | | | | |
+-------+-------+-------+----------+----------+
Hibernate: insert into t1oo (name, id) values (?, ?)
Hibernate: insert into t2oo (version, avg, aid, id) values (?, ?, ?, ?)
Hibernate: update t2oo set aid=? where id=?
mysql> select * from t2oo;
+----+-----+------+---------+
| id | avg | aid | version |
+----+-----+------+---------+
| 1 | 24 | 1 | 0 |
+----+-----+------+---------+
1 row in set (0.00 sec)
改4 改3 改2
+-------+-------+-------+----------+----------+
|hbn.xml|inverse|cascade|t1oo->t2oo|t2oo->t1oo|
+-------+-------+-------+----------+----------+
| t1oo | false | | | |
+-------+-------+-------+ true | true |
| t2oo | | | | |
+-------+-------+-------+----------+----------+
Hibernate: insert into t1oo (name, id) values (?, ?)
Hibernate: update t2oo set aid=? where id=?
Empty set (0.00 sec)
改4 改1 改2
+-------+-------+-------+----------+----------+
|hbn.xml|inverse|cascade|t1oo->t2oo|t2oo->t1oo|
+-------+-------+-------+----------+----------+
| t1oo | false | | | |
+-------+-------+-------+ true | false |
| t2oo | | all | | |
+-------+-------+-------+----------+----------+
Hibernate: insert into t1oo (name, id) values (?, ?)
Hibernate: update t2oo set aid=? where id=?
Empty set (0.00 sec)
改4 改1 改3
+-------+-------+-------+----------+----------+
|hbn.xml|inverse|cascade|t1oo->t2oo|t2oo->t1oo|
+-------+-------+-------+----------+----------+
| t1oo | false | all | | |
+-------+-------+-------+ true | false |
| t2oo | | | | |
+-------+-------+-------+----------+----------+
Hibernate: insert into t1oo (name, id) values (?, ?)
Hibernate: insert into t2oo (version, avg, aid, id) values (?, ?, ?, ?)
Hibernate: update t2oo set aid=? where id=?
mysql> select * from t2oo;
+----+-----+------+---------+
| id | avg | aid | version |
+----+-----+------+---------+
| 1 | 24 | 1 | 0 |
+----+-----+------+---------+
1 row in set (0.02 sec)
改4 改3 改2 改1
+-------+-------+-------+----------+----------+
|hbn.xml|inverse|cascade|t1oo->t2oo|t2oo->t1oo|
+-------+-------+-------+----------+----------+
| t1oo | false | | | |
+-------+-------+-------+ true | false |
| t2oo | | | | |
+-------+-------+-------+----------+----------+
Hibernate: insert into t1oo (name, id) values (?, ?)
Hibernate: update t2oo set aid=? where id=?
Empty set (0.00 sec)
環境:
private SessionFactory sessionFactory;
protected void setUp() throws Exception {
super .setUp();
// 利用java反射得到 HibernateSessionFactory ->
// private static org.hibernate.SessionFactory sessionFactory;
// 要模擬 并發 要 HibernateSessionFactory 得出的 有 threadLocal 不行
// 要
HibernateSessionFactory.currentSession();
HibernateSessionFactory.closeSession();
Field field = HibernateSessionFactory. class .getDeclaredField( " sessionFactory " );
field.setAccessible( true );
sessionFactory = (SessionFactory) field.get(HibernateSessionFactory. class );
}
protected void tearDown() throws Exception {
super .tearDown();
}
悲觀鎖:
/** 悲觀鎖問題 線程模擬 并發
* Table -> T1oo(id,name)
* +----+------+
* | id | name |
* +----+------+
* | 4 | xx1 |
* +----+------+
*/
public void ctestLock() throws Exception {
// insert test Data 測試數據
Session seInsert = sessionFactory.openSession();
Transaction tr = seInsert.beginTransaction();
T1oo testUse = testUse = new T1oo();
testUse.setName( " liukaiyi_test " );
seInsert.save(testUse);
tr.commit();
System.out.println( " **************Test Use Bean : insert******************* " );
seInsert.close();
Integer testId = testUse.getId();
//并發模擬
Session session1 = sessionFactory.openSession();
Session session2 = sessionFactory.openSession();
final Transaction tr1 = session1.beginTransaction();
Transaction tr2 = session2.beginTransaction();
Query qu1 = session1.createQuery( " from T1oo t1oo where t1oo.name='liukaiyi_test' " );
Query qu2 = session2.createQuery( " from T1oo t1oo where t1oo.name='liukaiyi_test' " );
//加悲觀鎖
qu1.setLockMode( " t1oo " ,LockMode.UPGRADE);
final Object bean1 = qu1.uniqueResult();
Object bean2 = qu2.uniqueResult();
T1oo t1oo2 = (T1oo)bean2;
t1oo2.setName( " run1 " );
new Thread(
new Runnable(){
public void run() {
try {
System.out.println( " ********解鎖準備********* " );
Thread.sleep( 10 * 1000 );
T1oo t1oo1 = (T1oo)bean1;
t1oo1.setName( " run2 " );
tr1.commit();
System.out.println( " ********解鎖成功t********* " );
} catch (InterruptedException e) {e.printStackTrace();}
}
}
).start();
/ /這里會 等待十秒后 tr1解鎖 /
tr2.commit();
session1.close();
session2.close();
// delete Test Date 刪除測試數據
Session seDelete = sessionFactory.openSession();
Transaction trD = seDelete.beginTransaction();
Object obj = seDelete.createQuery( " from T1oo t where t.id=:id " ).
setInteger( " id " ,testId.intValue()).
uniqueResult();
seDelete.delete(obj);
trD.commit();
System.out.println( " **************Test Use Bean : delete************** " );
seDelete.close();
}
樂觀鎖:
/** 樂觀鎖問題
* Table -> T1oo(id,name)
* T2oo.hbn.xml <class> +> optimistic-lock="version"
* id下面 +> <version name="version" type="integer" column="version" />
* +---------+---------+------+
* | Field | Type | Null |
* +---------+---------+------+
* | id | int(11) | |
* | avg | int(11) | |
* | aid | int(11) | YES |
* | version | int(11) | YES |
* +---------+---------+------+
* 注意：要在數據庫中多加一列
* mysql> alter table T2OO add version int;
*/
public void testOpLock() throws Exception{
//添加測試數據
Session session = sessionFactory.openSession();
Transaction trI = session.beginTransaction();
Connection conn = session.connection();
T2oo t2oo = new T2oo();
T1oo t1oo = new T1oo( " t1ooOpLock " );
t1oo.setT2ooSet( new HashSet());
t2oo.setAvg( new Integer( 23 ));
t2oo.setT1oo(t1oo);
t1oo.getT2ooSet().add(t2oo);
session.save(t2oo);
trI.commit();
session.clear();
session.close();
//并發模擬
Session se1 = sessionFactory.openSession();
Session se2 = sessionFactory.openSession();
Transaction tr1 = se1.beginTransaction();
Transaction tr2 = se2.beginTransaction();
T1oo obj1 = (T1oo)se1.load(T1oo. class , new Integer( 1 ));
T1oo obj2 = (T1oo)se2.load(T1oo. class , new Integer( 1 ));
((T2oo)obj1.getT2ooSet().iterator().next()).setAvg( new Integer( 9 ));
((T2oo)obj2.getT2ooSet().iterator().next()).setAvg( new Integer( 10 ));
tr1.commit();
try {
tr2.commit();
} catch (Exception e) {
se2.clear();
tr2.commit();
// tr2報錯
} finally {
se1.close();
se2.close();
}
//測試數據刪除
Session dele = sessionFactory.openSession();
Transaction tr = dele.beginTransaction();
dele.delete(obj1);
tr.commit();
dele.close();
HibernateSessionFactory.closeSession();
}
|