亚洲av无码一区二区三区观看,亚洲色大成WWW亚洲女子,mm1313亚洲精品国产

Hibernate大數據量操作解決方案（轉）

閱讀了Hibernate的Reference之后，可以采用批量處理的方法，當插入的數據超過10000時，就flush session并且clear。

下面是一個測試method。

/**?*//**
?2

?????*?測試成批插入數據的事務處理，返回是否成功
?3

?????*?
?4

?????*?@param?objPO?Object
?5

?????*?@return?boolean
?6

?????*/
?7

????public?boolean?insertBatch(final?Object?objPO)?

{
?8

????????boolean?isSuccess?=?false;
?9

????????Transaction?transaction?=?null;
10

????????Session?session?=?openSession();
11

????????try?

{
12

????????????transaction?=?session.beginTransaction();
13

????????????for?(int?i?=?0;?i?<?100000;?i++)?

{
14

????????????????session.save(objPO);
15

????????????????if?(i?%?50?==?0)?

{
16

????????????????????//?flush?a?batch?of?inserts?and?release?memory
17

????????????????????session.flush();
18

????????????????????session.clear();
19

????????????????}
20

????????????}
21

????????????transaction.commit();
22

????????????logger.info("transaction.wasCommitted:"
23

????????????????????+?transaction.wasCommitted());
24

????????????isSuccess?=?true;
25

????????}?catch?(HibernateException?ex)?

{
26

????????????if?(transaction?!=?null)?

{
27

????????????????try?

{
28

????????????????????transaction.rollback();
29

????????????????????logger.error("transaction.wasRolledBack:"
30

????????????????????????????+?transaction.wasRolledBack());
31

????????????????}?catch?(HibernateException?ex1)?

{
32

????????????????????logger.error(ex1.getMessage());
33

????????????????????ex1.printStackTrace();
34

????????????????}
35

????????????}
36

????????????logger.error("Insert?Batch?PO?Error:"?+?ex.getMessage());
37

????????????ex.printStackTrace();
38

????????}?finally?

{
39

????????????if?(transaction?!=?null)?

{
40

????????????????transaction?=?null;
41

????????????}
42

????????????session.close();
43

????????}
44

????????return?isSuccess;
45

????}
46

這只是簡單的測試，實際項目中遇到的問題，要比這個復雜得多。
這時候，我們可以讓Spring來控制Transaction，自己來控制Hibernate的Session，隨時更新數據。
首先，利用HibernateDaoSupport類來自定義個方法打開Session；

public ?Session?openSession()

{
2

????????
3

????????return?getHibernateTemplate().getSessionFactory().openSession();
4

????????
5

????}

然后，用打開的Session處理你的數據；

protected?void?doBusiness(Session?session)?

{
?2

????????while?(true)?

{
?4

????????????//do?your?business?with?the?opening?session????????
?5

????????????someMethod(session);
?6

????????????session.flush();
?7

????????????session.clear();
?8

????????????logger.info("good?job!");????????????
?9

????????}???????
10

}

每做一次數據操作，就更新一次Session，這樣可以保證每次數據操作都成功，否則就讓Spring去控制它roll back吧。

最后，記得關閉Session。

Session?session? = ?openSession();
2

doBusiness(session);
3

session.close();? // 關閉session

至于處理速度呢，不會慢到哪兒去的，已經試驗過了。; - )

還等什么，趕快試試吧！

posted on 2007-01-12 15:30 liaojiyong 閱讀(738) 評論(0) 編輯收藏所屬分類: Hibernate

新用戶注冊刷新評論列表


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




網站導航: 博客園 IT新聞 Chat2DB C++博客博問管理
相關文章: Hibernate O/R映射三大基本定則(轉) Hibernate程序性能優化的考慮要點(轉) Hibernate大數據量操作解決方案（轉） Hibernate 深入研究之Criteria(轉) Hibernate 深入研究之 Criteria （轉）以2/8原則指導我們的底層框架設計（轉）

love fish大鵬一曰同風起，扶搖直上九萬里

導航

公告

留言簿(15)

隨筆分類(493)

隨筆檔案(498)

相冊

閱讀排行榜

常用鏈接

統計

積分與排名

friends

link

最新評論

Hibernate大數據量操作解決方案（轉）