posts - 165, comments - 198, trackbacks - 0, articles - 1
  BlogJava :: 首页 :: 新随笔 :: 联系 :: 聚合  :: 管理

hibernate 问题_3(锁)

Posted on 2007-11-26 18:57 G_G 阅读(1085) 评论(0)  编辑  收藏 所属分类: hibernate
环境:
     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();
    }


只有注册用户登录后才能发表评论。


网站导航: