Let's go inside

Transaction Annotation

在EJB 3.0 的應(yīng)用中，transaction properties最常聲明在session bean定義的方法中。如果一個(gè)方法requires transaction， 所有這個(gè)方法中的操作(包括database updates)僅在方法正常退出時(shí)才被提交。如果在這個(gè)方法或調(diào)用這個(gè)方法的方法中拋出了application exception，transaction manager會(huì)回滾所有的變化(i.e., database updates). 聲明transaction所用的標(biāo)注是@TransactionAttribute，可以帶如下參數(shù)：

REQUIRED: 有則用之，沒有就創(chuàng)建一個(gè)新的用。
MANDATORY: the caller method必須自帶事務(wù). 否則，將拋出一個(gè)錯(cuò)誤。
REQUIRESNEW: 被標(biāo)注的方法必須在新的事務(wù)中執(zhí)行. 如果the caller method自帶事務(wù)， 則之前的那個(gè)事務(wù)將被掛起.
SUPPORTS: 有則用之，沒有就算了。
NOT_SUPPORTED: 有則出錯(cuò)。

如果一個(gè)方法沒有事務(wù)標(biāo)注, 則它使用EJB 3.0 container指定的默認(rèn)值：REQUIRED

在EJB 3.0中，EntityManager必須運(yùn)行在一個(gè)事務(wù)性的context中以保證數(shù)據(jù)庫完整性(database integrity). transaction manager總是在事務(wù)被提交的時(shí)候同步數(shù)據(jù)庫(在current thread之后或在next database query之前)。你也可以在一個(gè)事務(wù)中調(diào)用EntityManager.flush()隨時(shí)同步數(shù)據(jù)庫。
?
Transaction Rollback
??? 當(dāng)應(yīng)用拋出一個(gè)RuntimeException的時(shí)候transation將失敗，這通常與數(shù)據(jù)庫有關(guān)或者也有可能是一個(gè)ApplicationException.這里是一個(gè)自定義ApplicationException的例子。你可以在任何地方拋出它以引發(fā)事務(wù)失敗---即使并不是數(shù)據(jù)庫錯(cuò)誤。

當(dāng)一個(gè)事務(wù)失敗的時(shí)候，database會(huì)回滾到事務(wù)開始前的狀態(tài)，即使你在事務(wù)中調(diào)用了flush()。所有被管理的entity beans均處在detached的狀態(tài)。如果你想在事務(wù)失敗后繼續(xù)使用這些entity beans, 你不得不手工設(shè)置它們的ID為零。
?
A Transactional Method Example
??? 在下面的例子中，我們?cè)趗pdateExchangeRate()的for循環(huán)中產(chǎn)生隨機(jī)的application exceptions，因?yàn)榉椒ū宦暶鳛槭聞?wù)性的，這些exceptions將導(dǎo)致所有的更新失敗。

@Stateless
public ? class ?TransCalculator? implements ?Calculator?{
??@PersistenceContext
?? protected ?EntityManager?em;
?? // ??
??@TransactionAttribute(TransactionAttributeType.REQUIRED)
?? public ? void ?updateExchangeRate?( double ?newrate)? throws ?Exception?{
????Collection? < TimedRecord > ?rc? = ?
??????em.createQuery( " from?TimedRecord?r " ).getResultList();
???? int ?size? = ?rc.size?();
????
???? for ?(Iterator?iter? = ?rc.iterator();?iter.hasNext();)?{
??????TimedRecord?r? = ?(TimedRecord)?iter.next();
??????r.setSaving(r.getSaving()? * ?newrate);
??????r.setResult(r.getResult()? * ?newrate);

?????? // ?Emulate?a?failure
??????
?????? // ?Calculate?failure?probability?for?each?loop
?????? // ?in?order?for?the?overall?failure?probability
?????? // ?to?be?50%
?????? double ?prob? = ?Math.pow?( 0.5 ,? 1 . / size);
?????? if ?(Math.random()? > ?prob)?{
???????? // ?Emulated?failure?causes?rollback
???????? throw ? new ?TransException?();
????????
???????? // ?Or?throw?a?RuntimeException?to?trigger?rollback
??????}
????}
??}

點(diǎn)擊下面的按鈕以載入新的匯率更新程序。試著多次更新匯率的值你將看到要么所有的記錄被更新，要么所有的記錄都沒有被更新。永遠(yuǎn)不會(huì)出現(xiàn)只有部分記錄被更新的情況，即使異常是在循環(huán)的中期進(jìn)行的。出現(xiàn)異常的概率為50%

**************************************************************************************

第二小節(jié)：Application Transactions

介紹?
?標(biāo)準(zhǔn)的JTA事務(wù)是基于線程的。事務(wù)在線程結(jié)束時(shí)要么commit要么rollback.在線程結(jié)束時(shí)，事務(wù)被提交;數(shù)據(jù)的變更將flush到database;并且persistence context被銷毀。對(duì)于有些web應(yīng)用來說，這種"one thread"的限制令人感到不快。比如，我們考慮一個(gè)購物車程序。用戶需要瀏覽一系列的頁面：選擇商品，輸入信用卡的資料，輸入貨運(yùn)地址，預(yù)覽最終的結(jié)算，最后結(jié)束整個(gè)事務(wù)。每一次頁面提交在服務(wù)器端都會(huì)被一個(gè)獨(dú)立的線程處理。但是事務(wù)必須在最后一個(gè)頁面提交時(shí)才能被commit.

在 EJB 3.0中， 你可以把多線程的database updates緩存到EntityManager中，只在應(yīng)用結(jié)束一次邏輯會(huì)話時(shí)commit the changes in a batch(比如在購物車checkout的時(shí)候)。在這個(gè)例子中，我們將模擬一次多頁面aplication transaction.

The sample application
? 這次的示例應(yīng)用程序是對(duì)前面“currency exchange rate update”例子一次小小的改動(dòng)，當(dāng)你提交更改一次新的currency exchange rate后，應(yīng)用更新所有entity beans對(duì)象中的計(jì)算記錄但是不會(huì)把變化flush到database，然后應(yīng)用轉(zhuǎn)到另外一個(gè)頁面詢問是否更新這些記錄的timestamp，如果你選擇“yes”,這些bean對(duì)象的timestamp屬性將被更新同時(shí)在a single batch中flush到database.

The extended EntityManager
?為了使上面的事務(wù)工作，你首先要指定 @PersistenceContext的type屬性為PersistenceContextType.EXTENDED.這告訴container EntityManager在跨線程區(qū)域內(nèi)維護(hù)它的persistence context (也就是它所管理的entity beans對(duì)象)

@Stateful
public ? class ?ApptransCalculator? implements ?Calculator,?Serializable?{
??@PersistenceContext(
??????type = PersistenceContextType.EXTENDED
??)
?? protected ?EntityManager?em;
?? // ????
}

Commit the transaction
?然后，我們通過使用參數(shù)NOT_SUPPORTED告訴JTA事務(wù)處理器不要在線程結(jié)束時(shí)提交更新.EntityManager應(yīng)該僅在stateful session bean銷毀時(shí)更新數(shù)據(jù)庫. 你應(yīng)該還記得我們可以通過調(diào)用用@Remove標(biāo)記的方法來銷毀一個(gè)statuful session bean.我們?cè)谟?#64;Remove標(biāo)記的方法中顯示的調(diào)用EntityManager.flush()來send in all updates to the database。

@Stateful
public ? class ?ApptransCalculator? implements ?Calculator,?Serializable?{
?? // ??
??@TransactionAttribute(TransactionAttributeType.NOT_SUPPORTED)
?? public ? void ?updateExchangeRate?( double ?newrate)?{
???? // ??
??}
??@TransactionAttribute(TransactionAttributeType.NOT_SUPPORTED)
?? public ? void ?updateTimestamp?()?{
???? // ??
??}
??@Remove
?? public ? void ?checkout()? throws ?Exception?{
????em.flush?()
??}
}