Enjoying Life ...... !
          If u can look into my eyes, u will see how beautiful the life is.
          posts - 4,comments - 12,trackbacks - 0

          本文中的功能僅存在于hibernate3中。參考文件hibernate3源代碼中的org.hibernate.test.hql包下的BulkManipulationTest.java。

          hibernate2中對于批量操作的處理方法是,查詢得到所有符合條件的數據庫數據的主鍵,然后對根據主鍵對每條數據進行操作。這樣感覺既費時又費力。最新Hibernate3中提供批量更新操作功能。例如:

          String hqlUpdate = “ UPDATE user u “+
          “ SET u.username
          =:newUsername, u.password=:newPassword ”+
          “ WHERE u.username
          =:username and u.password=:password “;
          Query query 
          = session.createQuery(hqlUpdate);
          query.setString(
          "username",”hfm”);
          query.setString(
          "password",”1”);
          query.setString(
          "newUsername",”ps”);
          query.setString(
          "newPassword",”123”);
          int num = query.executeUpate();
          ts.commit();

          String hqlDelete = “ DELETE FROM user u “+
          “ WHERE u.username
          =:username and u.password=:password “;
          query.setString(
          "username",”ps”);
          query.setString(
          "password",”123”);
          int num = query.executeUpate();
          ts.commit();

          變量session的類型為org.hibernate.Session;ts的類行為為org.hibernate.Transaction;返回值num表示有幾條數據被操作了。以上兩段代碼執(zhí)行后在控制臺中打出來的SQL分別是:

          Hibernate: update CUSTOMER user0_ set user0_.USERNAME=?, user0_.PASSWORD=? where (user0_.USERNAME=? and user0_.PASSWORD=?)

          Hibernate: delete from CUSTOMER user0_ where (user0_.USERNAME=? and user0_.PASSWORD=?)

          以上是我認為比較好的方法。但是注意,產生的第二條語句不能在MySql中執(zhí)行,但是hql仍然可以被編譯成sql,不知道是我語法寫錯了還是bug?有誰了解可以給我maillippea@sohu.com。另外在參考文件BulkManipulationTest.java中有一個方法:

          public QueryTranslatorImpl assertTranslation(String hql) throws QueryException, MappingException;

          這個方法我不知道是干嘛的,但是我嘗試了按照這種形式進行批量操作:

          String hqlDelete = “ DELETE FROM user u “+
          “ WHERE u.username
          =:username and u.password=:password “;
           Object[] objects 
          = new Object[]{“hfm”,”1”}
           Type[] types
          =new Type[]{(Type)Hibernate.STRING,(Type)Hibernate.STRING};
          QueryParameters queryParas 
          = new QueryParameters(types,objects);
          QueryTranslatorFactory ast 
          = new ASTQueryTranslatorFactory();
          QueryTranslator newQueryTranslator 
          = 
               ast.createQueryTranslator(hqlDelete, Collections.EMPTY_MAP,
               (SessionFactoryImplementor)sf );
          newQueryTranslator.compile( Collections.EMPTY_MAP, 
          false );
          int num = newQueryTranslator.executeUpdate(queryParas,
                         (SessionImplementor)session);

          sf的類型為org.hibernate.SessionFactorysession的類型為org.hibernate.Session。使用這種方法的結果與上面那種方法的結果相同,但是在對hql中變量進行賦值很不方便,我也沒發(fā)現這種方法有什么更廣泛的用處。或許有別的方法賦值,或者其它用處?

          posted on 2005-05-27 17:36 lippea'blog 閱讀(1453) 評論(1)  編輯  收藏 所屬分類: Hibernate

          FeedBack:
          # re: 使用hibernate進行批量更新和刪除操作
          2006-03-05 02:06 | zhaoce
          我也使用了SessionImplementor接口去強制轉換Session session
          以便我更方便地使用Dialect對象去包裝我的sql語句
          但是我總擔心,這樣操作會不會哪一天出什么問題
          萬一哪天SessionImpl extends AbstractSession implements SessionImplementor不再有效
          那就完蛋了  回復  更多評論
            

          只有注冊用戶登錄后才能發(fā)表評論。


          網站導航:
           
          主站蜘蛛池模板: 五河县| 肥城市| 通州市| 榆中县| 宁陕县| 常熟市| 淳化县| 巴东县| 霍州市| 安乡县| 海伦市| 淅川县| 突泉县| 炉霍县| 晋江市| 茶陵县| 保定市| 富锦市| 荥经县| 墨竹工卡县| 台南市| 中宁县| 巴南区| 安西县| 汉中市| 紫阳县| 晋江市| 岳普湖县| 浙江省| 襄垣县| 稷山县| 佛山市| 黄山市| 长垣县| 平舆县| 海丰县| 哈巴河县| 玉溪市| 通州市| 岢岚县| 娱乐|