主講人：石云延遲符編程式事務Spring的數據庫開發與事務Spring事務簡介

事務管理對于企業應用而言至關重要。它保證了用戶的每一次操作都是可靠的，即便出現了異常的訪問情況，也不至于破壞后臺數據的完整性。Spring事務簡介

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

Spring事務簡介傳播行為傳播行為定義了事務應用于方法上之邊界（Boundaries），它告知何時該開始一個新的事務，或何時事務該被暫停，或方法是否要在事務中進行。Spring事務簡介傳播行為Spring定義了幾個傳播行為，常用的傳播行為如下所示。PROPAGATION_REQUIRED：支持當前事務，如果當前沒有事務，就新建一個事務；PROPAGATION_SUPPORTS：支持當前事務，如果當前沒有事務，就以非事務方式執行；PROPAGATION_MANDATORY：支持當前事務，如果當前沒有事務，就拋出異常；PROPAGATION_REQUIRES_NEW：新建事務，如果當前存在事務，把當前事務掛起。

Spring事務簡介隔離級別在一個應用程序中，可能有多個事務同時進行，由于事務彼此獨立，若讀取的是同一個數據，容易發生問題。根據需求的不同，

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

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

TABLE

USER

(user_id

integer,

name

varchar(100)");

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

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

可以使用

org.springframework.transaction.PlatformTransactionManager直接管理事務。簡單地通過一個bean引用給你的bean傳遞一個PlatformTransactionManager實現。然后，使用TransactionDefinition和TransactionStatus對象就可以發起事務，回滾和提交。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);編程式事務【例6-1】編程式事務實例分析。主要步驟:創建用戶類;創建數據庫訪問業務類;創建測試類;創建配置文件。編程式事務【例6-1】編程式事務實例分析。步驟1：創建用戶類@DatapublicclassUser{privateStringname;privateStringpassword;privateIntegerage;}編程式事務【例6-1】編程式事務實例分析。步驟2：創建數據庫訪問業務類publicclassUserDao{privateDataSourcedataSource;privateJdbcTemplatetemplate;publicDataSourcegetDataSource(){returndataSource;}publicvoidsetDataSource(DataSourcedataSource){this.dataSource=dataSource;template=newJdbcTemplate(dataSource);transactionManager=newDataSourceTransactionManager(dataSource);def=newDefaultTransactionDefinition();//異常處理機制def.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRED);}

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

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

編程式事務【例6-1】編程式事務實例分析。步驟4：創建配置文件<context:property-placeholderlocation="classpath:perties"/> <!--配置數據源--><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>編程式事務【例6-1】編程式事務實例分析。步驟4：創