JavaEE企業(yè)級(jí)項(xiàng)目開(kāi)發(fā)（第3版）課件 微課6-3：編程式事務(wù)

主講人：石云延遲符編程式事務(wù)Spring的數(shù)據(jù)庫(kù)開(kāi)發(fā)與事務(wù)Spring事務(wù)簡(jiǎn)介

事務(wù)管理對(duì)于企業(yè)應(yīng)用而言至關(guān)重要。它保證了用戶的每一次操作都是可靠的，即便出現(xiàn)了異常的訪問(wèn)情況，也不至于破壞后臺(tái)數(shù)據(jù)的完整性。Spring事務(wù)簡(jiǎn)介

Spring中提供了豐富的事務(wù)管理功能，它們超過(guò)了EJB并且和EJB一樣支持聲明式事務(wù)，重要的是Spring提供了一致的事務(wù)管理，它有如下優(yōu)點(diǎn)。為不同的事務(wù)的API提供一致的編程模式；提供更簡(jiǎn)單，更易使用的編程式事務(wù)管理；支持Spring聲明事務(wù)；整合Spring對(duì)數(shù)據(jù)訪問(wèn)的抽象。Spring事務(wù)簡(jiǎn)介在Spring中，事務(wù)是通過(guò)TransactionDefinition接口來(lái)定義的。該接口包含與事務(wù)屬性有關(guān)的方法。TransactionDefinition接口中定義的主要方法如下所示。publicinterfaceTransactionDefinition{intgetPropagationBehavior();intgetIsolationLevel();intgetTimeout();booleanisReadOnly();}

Spring事務(wù)簡(jiǎn)介傳播行為傳播行為定義了事務(wù)應(yīng)用于方法上之邊界（Boundaries），它告知何時(shí)該開(kāi)始一個(gè)新的事務(wù)，或何時(shí)事務(wù)該被暫停，或方法是否要在事務(wù)中進(jìn)行。Spring事務(wù)簡(jiǎn)介傳播行為Spring定義了幾個(gè)傳播行為，常用的傳播行為如下所示。PROPAGATION_REQUIRED：支持當(dāng)前事務(wù)，如果當(dāng)前沒(méi)有事務(wù)，就新建一個(gè)事務(wù)；PROPAGATION_SUPPORTS：支持當(dāng)前事務(wù)，如果當(dāng)前沒(méi)有事務(wù)，就以非事務(wù)方式執(zhí)行；PROPAGATION_MANDATORY：支持當(dāng)前事務(wù)，如果當(dāng)前沒(méi)有事務(wù)，就拋出異常；PROPAGATION_REQUIRES_NEW：新建事務(wù)，如果當(dāng)前存在事務(wù)，把當(dāng)前事務(wù)掛起。

Spring事務(wù)簡(jiǎn)介隔離級(jí)別在一個(gè)應(yīng)用程序中，可能有多個(gè)事務(wù)同時(shí)進(jìn)行，由于事務(wù)彼此獨(dú)立，若讀取的是同一個(gè)數(shù)據(jù)，容易發(fā)生問(wèn)題。根據(jù)需求的不同，

隔離級(jí)別可以根據(jù)實(shí)際需求，對(duì)數(shù)據(jù)的鎖定進(jìn)行設(shè)置。Spring事務(wù)簡(jiǎn)介隔離級(jí)別Spring提供了幾種隔離級(jí)別設(shè)置，如下所示。ISOLATION_DEFAULT：這是一個(gè)PlatfromTransactionManager默認(rèn)的隔離級(jí)別，使用數(shù)據(jù)庫(kù)默認(rèn)的事務(wù)隔離級(jí)別。ISOLATION_READ_UNCOMMITTED：這是事務(wù)最低的隔離級(jí)別，它允許另外一個(gè)事務(wù)可以看到這個(gè)事務(wù)未提交的數(shù)據(jù)。這種隔離級(jí)別會(huì)產(chǎn)生臟讀，不可重復(fù)讀和幻讀。ISOLATION_READ_COMMITTED：保證一個(gè)事務(wù)修改的數(shù)據(jù)提交后才能被另外一個(gè)事務(wù)讀取。另外一個(gè)事務(wù)不能讀取該事務(wù)未提交的數(shù)據(jù)。

Spring事務(wù)簡(jiǎn)介事務(wù)超時(shí)所謂事務(wù)超時(shí)，就是指一個(gè)事務(wù)所允許執(zhí)行的最長(zhǎng)時(shí)間，如果超過(guò)該時(shí)間限制但事務(wù)還沒(méi)有完成，則自動(dòng)回滾事務(wù)。在TransactionDefinition中以int的值來(lái)表示超時(shí)時(shí)間，其單位是秒。Spring事務(wù)簡(jiǎn)介事務(wù)的只讀屬性事務(wù)的只讀屬性是指，對(duì)事務(wù)性資源進(jìn)行只讀操作或者是讀寫(xiě)操作。所謂事務(wù)性資源就是指那些被事務(wù)管理的資源，比如數(shù)據(jù)源、JMS資源，以及自定義的事務(wù)性資源等等。編程式事務(wù)Spring提供的事務(wù)管理API，可以在代碼中靈活控制事務(wù)的執(zhí)行。在底層，Spring仍然將事務(wù)操作委托給底層的持久化框架來(lái)執(zhí)行。Spring提供兩種方式的編程式事務(wù)管理：使用TransactionTemplate和PlatformTransactionManager。編程式事務(wù)TransactionTempale采用和其他Spring模板，如JdbcTempalte和HibernateTemplate一樣的方法。它使用回調(diào)方法，把應(yīng)用程序從處理取得和釋放資源中解脫出來(lái)。必須在事務(wù)上下文中執(zhí)行的應(yīng)用代碼看起來(lái)像這樣，注意使用TransactionCallback可以返回一個(gè)值，代碼如下：jdbcTemplate.execute("CREATE

TABLE

USER

(user_id

integer,

name

varchar(100)");

Objectresult=tt.execute(newTransactionCallback(){publicObjectdoInTransaction(TransactionStatusstatus){updateOperation1();returnresultOfUpdateOperation2();}});編程式事務(wù)TransactionTempale如果沒(méi)有返回值，使用TransactionCallbackWithoutResult，

代碼如下：tt.execute(newTransactionCallbackWithoutResult(){protectedvoiddoInTransactionWithoutResult(TransactionStatusstatus){updateOperation1();updateOperation2();}});編程式事務(wù)使用PlatformTransactionManager

可以使用

org.springframework.transaction.PlatformTransactionManager直接管理事務(wù)。簡(jiǎn)單地通過(guò)一個(gè)bean引用給你的bean傳遞一個(gè)PlatformTransactionManager實(shí)現(xiàn)。然后，使用TransactionDefinition和TransactionStatus對(duì)象就可以發(fā)起事務(wù)，回滾和提交。jdbcTemplate.execute("CREATE

TABLE

USER

(user_id

integer,

name

varchar(100)");

DefaultTransactionDefinitiondef=newDefaultTransactionDefinition()def.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRED);TransactionStatusstatus=transactionManager.getTransactionDefinition(def);try{//executeyourbusinesslogichere}catch(MyExceptionex){transactionManager.rollback(status);throwex;}transactionMmit(status);編程式事務(wù)【例6-1】編程式事務(wù)實(shí)例分析。主要步驟:創(chuàng)建用戶類;創(chuàng)建數(shù)據(jù)庫(kù)訪問(wèn)業(yè)務(wù)類;創(chuàng)建測(cè)試類;創(chuàng)建配置文件。編程式事務(wù)【例6-1】編程式事務(wù)實(shí)例分析。步驟1：創(chuàng)建用戶類@DatapublicclassUser{privateStringname;privateStringpassword;privateIntegerage;}編程式事務(wù)【例6-1】編程式事務(wù)實(shí)例分析。步驟2：創(chuàng)建數(shù)據(jù)庫(kù)訪問(wèn)業(yè)務(wù)類publicclassUserDao{privateDataSourcedataSource;privateJdbcTemplatetemplate;publicDataSourcegetDataSource(){returndataSource;}publicvoidsetDataSource(DataSourcedataSource){this.dataSource=dataSource;template=newJdbcTemplate(dataSource);transactionManager=newDataSourceTransactionManager(dataSource);def=newDefaultTransactionDefinition();//異常處理機(jī)制def.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRED);}

編程式事務(wù)【例6-1】編程式事務(wù)實(shí)例分析。步驟2：創(chuàng)建數(shù)據(jù)庫(kù)訪問(wèn)業(yè)務(wù)類publicvoidinsert(Useruser){//添加用戶Stringname=user.getName();intage=user.getAge().intValue();TransactionStatusstatus=transactionManager.getTransaction(def);try{//下面的SQL有錯(cuò)誤，用于測(cè)試事務(wù)template.update("INSERINTOtb_user2(name,age)"+"VALUES('"+name+"',"+age+")");}catch(DataAccessExceptione){transactionManager.rollback(status);//回滾到status這個(gè)狀態(tài)System.out.println("執(zhí)行回滾操作了！");throwe;}transactionMmit(status);System.out.println("成功提交了！");}}

編程式事務(wù)【例6-1】編程式事務(wù)實(shí)例分析。步驟3：創(chuàng)建測(cè)試類publicclassTestTransaction{publicstaticvoidmain(String[]args){//加載配置文件ApplicationContextapplicationContext=newClassPathXmlApplicationContext("applicationContext.xml");//獲取UserDao實(shí)例UserDaodao=(UserDao)applicationContext.getBean("userDao");Useruser=newUser();user.setName("cf");user.setPassword("123");user.setAge(1);dao.insert(user);}}

編程式事務(wù)【例6-1】編程式事務(wù)實(shí)例分析。步驟4：創(chuàng)建配置文件<context:property-placeholderlocation="classpath:perties"/> <!--配置數(shù)據(jù)源--><beanid="dataSource"class="mons.dbcp2.BasicDataSource"> <propertyname="driverClassName"value="${db.driver}"/> <propertyname="url"value="${db.url}"/> <propertyname="username"value="${db.username}"/> <propertyname="password"value="${db.password}"/> <propertyname="maxIdle"value="5"/> </bean>編程式事務(wù)【例6-1】編程式事務(wù)實(shí)例分析。步驟4：創(chuàng)