<rt id="bn8ez"></rt>
<label id="bn8ez"></label>

  • <span id="bn8ez"></span>

    <label id="bn8ez"><meter id="bn8ez"></meter></label>

    posts - 165, comments - 198, trackbacks - 0, articles - 1
      BlogJava :: 首頁 :: 新隨筆 :: 聯系 :: 聚合  :: 管理

    hbn 攔截器

    Posted on 2007-11-29 10:13 G_G 閱讀(1029) 評論(0)  編輯  收藏 所屬分類: hibernate
    攔截器
    package ?hbn.test.supper.Interceptor;

    import ?java.io.Serializable;
    import ?java.util.HashSet;
    import ?java.util.Iterator;
    import ?java.util.Set;

    import ?org.hibernate.CallbackException;
    import ?org.hibernate.EntityMode;
    import ?org.hibernate.Interceptor;
    import ?org.hibernate.Transaction;
    import ?org.hibernate.type.Type;

    public ? class ?TestInterceptor? implements ?Interceptor,Serializable{

    ????
    private ?Set?inserts? = ? new ?HashSet();
    ????
    private ?Set?updates? = ? new ?HashSet();
    ????
    ?? ?
    // Session初化一個持久對象 如果這方法中改變了對象屬性就返回true 否則null
    ???? public ? boolean ?onLoad(Object?entity,?Serializable?id,?Object[]?state,?String[]?propertyNames,?Type[]?types)? throws ?CallbackException?{
    ????
    ??? return ? false ;
    ????}
    ??? // Session flush()中檢查到臟數據是調用 如:tr.commit() ....
    ???? public ? boolean ?onFlushDirty(Object?entity,?Serializable?id,?Object[]?currentState,?Object[]?previousState,?String[]?propertyNames,?Type[]?types)? throws ?CallbackException?{
    ????????updates.add(entity);
    ????????
    return ? false ;
    ????}
    ???
    // Session Save() 當修改了對象屬性返回true
    ???? public ? boolean ?onSave(Object?entity,?Serializable?id,?Object[]?state,?String[]?propertyNames,?Type[]?types)? throws ?CallbackException?{
    ????????
    ????????inserts.add(entity);
    ????????
    return ? false ;
    ????}
    ????
    // delete
    ???? public ? void ?onDelete(Object?entity,?Serializable?id,?Object[]?state,?String[]?propertyNames,?Type[]?types)? throws ?CallbackException?{
    ????}
    ? ?? //flush() 之前調用
    ???? public ? void ?preFlush(Iterator?entities)? throws ?CallbackException?{
    ????}
    ????
    // flush() 執行SQL語句之后調用
    ???? public ? void ?postFlush(Iterator?entities)? throws ?CallbackException?{
    ????????
    ????????
    try ?{
    ????????????
    for (Iterator?it? = ?updates.iterator();it.hasNext();){
    ????????????????System.out.println(
    " update= " + ?it.next()?);????
    ????????????}
    ????????????
    for (Iterator?it? = ?inserts.iterator();it.hasNext();){
    ????????????????System.out.println(
    " insert " + ?it.next()?);????
    ????????????}
    ????????????
    ????????}?
    catch ?(Exception?e)?{
    ????????????e.printStackTrace();
    ????????}
    ????????
    ????}

    ????
    public ?Boolean?isTransient(Object?entity)?{
    ????????
    // ?TODO?Auto-generated?method?stub
    ???????? return ? null ;
    ????}
    ? ? //決定Session中那些對象是臟數據 如果null Session使用默認處理臟數據
    ???? public ? int []?findDirty(Object?entity,?Serializable?id,?Object[]?currentState,?Object[]?previousState,?String[]?propertyNames,?Type[]?types)?{
    ???????? return ? null ;
    ????}

    ????
    // 當Session構造實體類對象前調用
    ???? public ?Object?instantiate(String?entityName,?EntityMode?entityMode,?Serializable?id)? throws ?CallbackException?{
    ???????? return ? null ;
    ????}

    ????
    public ?String?getEntityName(Object?object)? throws ?CallbackException?{
    ????????
    // ?TODO?Auto-generated?method?stub
    ???????? return ? null ;
    ????}

    ????
    public ?Object?getEntity(String?entityName,?Serializable?id)? throws ?CallbackException?{
    ????????
    // ?TODO?Auto-generated?method?stub
    ???????? return ? null ;
    ????}

    ????
    public ? void ?afterTransactionBegin(Transaction?tx)?{
    ????????
    // ?TODO?Auto-generated?method?stub
    ????????
    ????}

    ????
    public ? void ?beforeTransactionCompletion(Transaction?tx)?{
    ????????
    // ?TODO?Auto-generated?method?stub
    ????????
    ????}

    ????
    public ? void ?afterTransactionCompletion(Transaction?tx)?{
    ????????
    // ?TODO?Auto-generated?method?stub
    ????????
    ????}

    }

    測試

    package ?hbn.test.supper.Interceptor;

    import ?java.lang.reflect.Field;

    import ?org.hibernate.Session;
    import ?org.hibernate.SessionFactory;
    import ?org.hibernate.Transaction;

    import ?hbn.HibernateSessionFactory;
    import ?hbn.bean.T2oo;
    import ?junit.framework.TestCase;

    public ? class ?TestIC? extends ?TestCase?{
    ????
    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 );
    ????}
    ????
    ????
    public ? void ?testInc()? throws ?Exception?{
    ????????TestInterceptor?intx?
    = ? new ?TestInterceptor();
    ????????
    // 加載攔截器
    ????????Session?session? = ?sessionFactory.openSession(intx);
    ????????
    ????????Transaction?tr?
    = ?session.beginTransaction();
    ????????T2oo?t2?
    = ? new ?T2oo( 23 );
    ????????session.save(t2);
    ????????t2.setAvg(
    new ?Integer( 99 ));
    ????????tr.commit();
    ????}
    }
    結果
    Hibernate: insert into t2oo (version, avg, aid, id) values (?, ?, ?, ?)
    Hibernate: update t2oo set version=?, avg=?, aid=? where id=? and version=?
    //攔截到的
    update=hbn.bean.T2oo@277
    inserthbn.bean.T2oo@277



    主站蜘蛛池模板: 亚洲一级特黄无码片| 国产色爽女小说免费看| 久久国产精品免费专区| 精品国产污污免费网站aⅴ| 1000部拍拍拍18勿入免费视频软件 | 国产a视频精品免费观看| 亚洲韩国在线一卡二卡| 亚洲国产日韩精品| 亚洲免费日韩无码系列| 日韩免费在线视频| 亚洲免费精彩视频在线观看| 国产成+人+综合+亚洲专| 一区二区三区免费电影| 亚洲视频在线免费播放| 亚洲片国产一区一级在线观看| 亚洲天堂一区在线| 中文字幕av免费专区| 成年轻人网站色免费看| 亚洲中文字幕无码一区二区三区| 亚洲人成网站在线观看播放青青| 性生大片视频免费观看一级| 欧洲一级毛片免费| 亚洲AV无码一区二区大桥未久| 男人j进入女人j内部免费网站| 亚洲视频网站在线观看| 日本成人免费在线| 亚洲专区一路线二| 久久国产免费观看精品3| 亚洲中文字幕不卡无码| 亚洲美女视频免费| 亚洲AV无码专区亚洲AV桃| 伊人久久精品亚洲午夜| 在线观看成人免费视频不卡| 亚洲韩国精品无码一区二区三区| 亚洲狠狠婷婷综合久久| 丁香花免费高清视频完整版| 亚洲视频在线观看视频| 免费99热在线观看| 男女交性无遮挡免费视频| 亚洲精品在线视频观看| 一级特黄录像视频免费|