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

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

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

    爪哇一角

    共同探討STRUTS#HIBERNATE#SPRING#EJB等技術(shù)
    posts - 3, comments - 6, trackbacks - 0, articles - 99
      BlogJava :: 首頁(yè) :: 新隨筆 :: 聯(lián)系 :: 聚合  :: 管理

    Hibernate下數(shù)據(jù)批量處理解決方案

    很多人都對(duì)Java在批量數(shù)據(jù)的處理方面是否是其合適的場(chǎng)所持有懷疑的念頭,由此延伸,那么就會(huì)認(rèn)為ORM可能也不是特別適合數(shù)據(jù)的批量處理。 其實(shí),我想如果我們應(yīng)用得當(dāng)?shù)脑挘耆梢韵齇RM批量處理性能問(wèn)題這方面的顧慮。下面以Hibernate為例來(lái)做為說(shuō)明,假如我們真的不得不在Java中使用Hibernate來(lái)對(duì)數(shù)據(jù)進(jìn)行批量處理的話。 向數(shù)據(jù)庫(kù)插入100 000條數(shù)據(jù),用Hibernate可能像這樣:

    Session session = sessionFactory.openSession();
    Transaction tx = session.beginTransaction();
    for ( int i=0; i<100000; i++ ) {
    Customer customer = new Customer(.....);
    session.save(customer); }
    tx.commit();
    session.close();

      大概在運(yùn)行到第50 000條的時(shí)候,就會(huì)出現(xiàn)內(nèi)存溢出而失敗。這是Hibernate把最近插入的Customer都以session-level cache在內(nèi)存做緩存,我們不要忘記Hiberante并沒(méi)有限制first-level cache 的緩存大小:

      # 持久對(duì)象實(shí)例被管理在事務(wù)結(jié)束時(shí),此時(shí)Hibernate與數(shù)據(jù)庫(kù)同步任何已經(jīng)發(fā)生變 化的被管理的的對(duì)象。

      # Session實(shí)現(xiàn)了異步write-behind,它允許Hibernate顯式地寫(xiě)操作的批處理。 這里,我給出Hibernate如何實(shí)現(xiàn)批量插入的方法:
    首先,我們?cè)O(shè)置一個(gè)合理的JDBC批處理大小,hibernate.jdbc.batch_size 20。 然后在一定間隔對(duì)Session進(jìn)行flush()和clear()。

    Session session = sessionFactory.openSession();
    Transaction tx = session.beginTransaction();
    for ( int i=0; i<100000; i++ ) {
    Customer customer = new Customer(.....);
    session.save(customer);
    if ( i % 20 == 0 ) {
    //flush 插入數(shù)據(jù)和釋放內(nèi)存:
    session.flush(); session.clear(); }
    }
    tx.commit();
    session.close();

      那么,關(guān)于怎樣刪除和更新數(shù)據(jù)呢?那好,在Hibernate2.1.6或者更后版本,scroll() 這個(gè)方法將是最好的途徑:

    Session session = sessionFactory.openSession();
    Transaction tx = session.beginTransaction();
    ScrollableResults customers = session.getNamedQuery("GetCustomers")
    .scroll(ScrollMode.FORWARD_ONLY);
    int count=0;
    while ( customers.next() ) {
    Customer customer = (Customer) customers.get(0);
    customer.updateStuff(...);
    if ( ++count % 20 == 0 ) {
    //flush 更新數(shù)據(jù)和釋放內(nèi)存:
    session.flush(); session.clear(); } }
    tx.commit(); session.close();

      這種做法并不困難,也不算不優(yōu)雅。請(qǐng)注意,如果Customer啟用了second-level caching ,我們?nèi)匀粫?huì)有一些內(nèi)存管理的問(wèn)題。原因就是對(duì)于用戶的每一次插入和更新,Hibernate在事務(wù)處理結(jié)束后不得不通告second-level cache 。因此,我們?cè)谂幚砬闆r下將要禁用用戶使用緩存。

    主站蜘蛛池模板: 亚洲视频一区调教| 亚洲天天做日日做天天看 | 东北美女野外bbwbbw免费| 永久免费不卡在线观看黄网站| 免费在线看v网址| jlzzjlzz亚洲乱熟在线播放| 亚洲精品线在线观看| 久久免费视频精品| 亚洲欧洲中文日韩av乱码| 亚洲三级视频在线| 中国国产高清免费av片| 国产亚洲精品久久久久秋霞| 亚洲人成网站色7799| 一级毛片不卡片免费观看| 亚洲国产一成久久精品国产成人综合| 免费精品视频在线| 野花高清在线电影观看免费视频 | 国产亚洲精品高清在线| 亚洲精华国产精华精华液网站| 99在线热视频只有精品免费| 久99精品视频在线观看婷亚洲片国产一区一级在线| 日日摸日日碰夜夜爽亚洲| 中文字幕免费在线看线人| 亚洲精品成人无限看| 牛牛在线精品观看免费正| a级亚洲片精品久久久久久久| 黄色网址在线免费| 国内精品99亚洲免费高清| 无人在线观看免费高清| 亚洲午夜无码久久久久软件 | 九九美女网站免费| 亚洲不卡视频在线观看| 国产大片51精品免费观看| 亚洲va久久久久| 免费国产作爱视频网站| 国产亚洲精品美女久久久久久下载| 啦啦啦高清视频在线观看免费| 亚洲国产成人精品青青草原| 最近2019免费中文字幕6| 91亚洲va在线天线va天堂va国产| 鲁丝片一区二区三区免费|