国产探花免费观看_亚洲丰满少妇自慰呻吟_97日韩有码在线_资源在线日韩欧美_一区二区精品毛片,辰东完美世界有声小说,欢乐颂第一季,yy玄幻小说排行榜完本

首頁(yè) > 學(xué)院 > 開發(fā)設(shè)計(jì) > 正文

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

2019-11-18 11:34:42
字體:
來(lái)源:轉(zhuǎn)載
供稿:網(wǎng)友

很多人都對(duì)java在批量數(shù)據(jù)的處理方面是否是其合適的場(chǎng)所持有懷疑的念頭,由此延伸,那么就會(huì)認(rèn)為ORM可能也不是非凡適合數(shù)據(jù)的批量處理。 其實(shí),我想假如我們應(yīng)用得當(dāng)?shù)脑挘耆梢韵齇RM批量處理性能問題這方面的顧慮。下面以Hibernate為例來(lái)做為說明,假如我們真的不得不在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并沒有限制first-level cache 的緩存大小:

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

  # Session實(shí)現(xiàn)了異步write-behind,它答應(yīng)Hibernate顯式地寫操作的批處理。 這里,我給出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)存治理的問題。原因就是對(duì)于用戶的每一次插入和更新,Hibernate在事務(wù)處理結(jié)束后不得不通告second-level cache 。因此,我們?cè)谂幚砬闆r下將要禁用用戶使用緩存。



發(fā)表評(píng)論 共有條評(píng)論
用戶名: 密碼:
驗(yàn)證碼: 匿名發(fā)表
主站蜘蛛池模板: 南部县| 泽库县| 武隆县| 扎鲁特旗| 寿光市| 含山县| 漳州市| 齐齐哈尔市| 依安县| 皋兰县| 体育| 博爱县| 合作市| 清水县| 喀喇| 永泰县| 台安县| 安福县| 辽阳市| SHOW| 佛冈县| 海兴县| 沙湾县| 营山县| 平阴县| 苏尼特左旗| 凌源市| 虎林市| 江都市| 潮州市| 平江县| 喀什市| 南京市| 旌德县| 桐乡市| 镇原县| 玛沁县| 乌拉特中旗| 吴江市| 石棉县| 衡水市|