Spring使用注解和配置文件配置事務(wù)
更新時間:2022年08月26日 11:51:08 作者:x297910962
這篇文章主要為大家詳細介紹了Spring使用注解和配置文件配置事務(wù),文中示例代碼介紹的非常詳細,具有一定的參考價值,感興趣的小伙伴們可以參考一下
本文實例為大家分享了Spring使用注解和配置文件配置事務(wù)的具體代碼,供大家參考,具體內(nèi)容如下
需求圖:
使用注解配置事務(wù):
package com.atguigu.spring.tx; ? public interface BookShopDao { ? ?? ?//根據(jù)書號獲取書的單價 ?? ?public int findBookPriceByIsbn(String isbn); ?? ? ?? ?//更新數(shù)的庫存. 使書號對應(yīng)的庫存 - 1 ?? ?public void updateBookStock(String isbn); ?? ? ?? ?//更新用戶的賬戶余額: 使 username 的 balance - price ?? ?public void updateUserAccount(String username, int price); }
package com.atguigu.spring.tx; ? import org.springframework.beans.factory.annotation.Autowired; import org.springframework.jdbc.core.JdbcTemplate; import org.springframework.stereotype.Repository; ? @Repository("bookShopDao") public class BookShopDaoImpl implements BookShopDao { ? ?? ?@Autowired ?? ?private JdbcTemplate jdbcTemplate; ?? ? ?? ?@Override ?? ?public int findBookPriceByIsbn(String isbn) { ?? ??? ?String sql = "SELECT price FROM book WHERE isbn = ?"; ?? ??? ?return jdbcTemplate.queryForObject(sql, Integer.class, isbn); ?? ?} ? ?? ?@Override ?? ?public void updateBookStock(String isbn) { ?? ??? ?//檢查書的庫存是否足夠, 若不夠, 則拋出異常 ?? ??? ?String sql2 = "SELECT stock FROM book_stock WHERE isbn = ?"; ?? ??? ?int stock = jdbcTemplate.queryForObject(sql2, Integer.class, isbn); ?? ??? ?if(stock == 0){ ?? ??? ??? ?throw new BookStockException("庫存不足!"); ?? ??? ?} ?? ??? ? ?? ??? ?String sql = "UPDATE book_stock SET stock = stock -1 WHERE isbn = ?"; ?? ??? ?jdbcTemplate.update(sql, isbn); ?? ?} ? ?? ?@Override ?? ?public void updateUserAccount(String username, int price) { ?? ??? ?//驗證余額是否足夠, 若不足, 則拋出異常 ?? ??? ?String sql2 = "SELECT balance FROM account WHERE username = ?"; ?? ??? ?int balance = jdbcTemplate.queryForObject(sql2, Integer.class, username); ?? ??? ?if(balance < price){ ?? ??? ??? ?throw new UserAccountException("余額不足!"); ?? ??? ?} ?? ??? ? ?? ??? ?String sql = "UPDATE account SET balance = balance - ? WHERE username = ?"; ?? ??? ?jdbcTemplate.update(sql, price, username); ?? ?} ? }
package com.atguigu.spring.tx; ? public interface BookShopService { ?? ? ?? ?public void purchase(String username, String isbn); ?? ? }
事務(wù)配置的核心部分:
package com.atguigu.spring.tx; ? import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Isolation; import org.springframework.transaction.annotation.Propagation; import org.springframework.transaction.annotation.Transactional; ? @Service("bookShopService") public class BookShopServiceImpl implements BookShopService { ? ?? ?@Autowired ?? ?private BookShopDao bookShopDao; ?? ? ?? ?//添加事務(wù)注解 ?? ?//1.使用 propagation 指定事務(wù)的傳播行為, 即當前的事務(wù)方法被另外一個事務(wù)方法調(diào)用時 ?? ?//REQUIRED:為默認取值, 被調(diào)用的事務(wù)一個執(zhí)行失敗整個大事務(wù)就回滾 ?? ?//REQUIRES_NEW:調(diào)用的事務(wù)如果執(zhí)行成功就保存結(jié)果不會被回滾,其他事務(wù)執(zhí)行失敗不會影響到它 ?? ?//2.使用 isolation 指定事務(wù)的隔離級別, 最常用的取值為 READ_COMMITTED ?? ?//3.默認情況下 Spring 的聲明式事務(wù)對所有的運行時異常進行回滾. 也可以通過對應(yīng)的 ?? ?//屬性進行設(shè)置. 通常情況下取默認值即可.? ?? ?//4.使用 readOnly 指定事務(wù)是否為只讀. 表示這個事務(wù)只讀取數(shù)據(jù)但不更新數(shù)據(jù),? ?? ?//這樣可以幫助數(shù)據(jù)庫引擎優(yōu)化事務(wù). 若方法只讀取數(shù)據(jù)庫值, 應(yīng)設(shè)置 readOnly=true ?? ?//5.使用 timeout 指定事務(wù)最多可以占用的時間,若超過時間則強制回滾? //?? ?@Transactional(propagation=Propagation.REQUIRES_NEW, //?? ??? ??? ?isolation=Isolation.READ_COMMITTED, //?? ??? ??? ?noRollbackFor={UserAccountException.class}) ?? ?@Transactional(propagation=Propagation.REQUIRES_NEW, ?? ??? ??? ?isolation=Isolation.READ_COMMITTED, ?? ??? ??? ?readOnly=false, ?? ??? ??? ?timeout=3) ?? ?@Override ?? ?public void purchase(String username, String isbn) { ?? ??? ? ?? ??? ?try { ?? ??? ??? ?Thread.sleep(5000); ?? ??? ?} catch (InterruptedException e) {} ?? ??? ? ?? ??? ?//1. 獲取書的單價 ?? ??? ?int price = bookShopDao.findBookPriceByIsbn(isbn); ?? ??? ? ?? ??? ?//2. 更新數(shù)的庫存 ?? ??? ?bookShopDao.updateBookStock(isbn); ?? ??? ? ?? ??? ?//3. 更新用戶余額 ?? ??? ?bookShopDao.updateUserAccount(username, price); ?? ?} ? }
package com.atguigu.spring.tx; ? import java.util.List; ? public interface Cashier { ? ?? ?public void checkout(String username, List<String> isbns); ?? ? }
package com.atguigu.spring.tx; ? import java.util.List; ? import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; ? @Service("cashier") public class CashierImpl implements Cashier { ? ?? ?@Autowired ?? ?private BookShopService bookShopService; ?? ? ?? ?@Transactional ?? ?@Override ?? ?public void checkout(String username, List<String> isbns) { ?? ??? ?for(String isbn: isbns){ ?? ??? ??? ?bookShopService.purchase(username, isbn); ?? ??? ?} ?? ?} ? }
package com.atguigu.spring.tx; ? import static org.junit.Assert.*; ? import java.util.Arrays; ? import org.junit.Test; import org.springframework.context.ApplicationContext; import org.springframework.context.support.ClassPathXmlApplicationContext; ? public class SpringTransactionTest { ? ?? ?private ApplicationContext ctx = null; ?? ?private BookShopDao bookShopDao = null; ?? ?private BookShopService bookShopService = null; ?? ?private Cashier cashier = null; ?? ? ?? ?{ ?? ??? ?ctx = new ClassPathXmlApplicationContext("applicationContext.xml"); ?? ??? ?bookShopDao = ctx.getBean(BookShopDao.class); ?? ??? ?bookShopService = ctx.getBean(BookShopService.class); ?? ??? ?cashier = ctx.getBean(Cashier.class); ?? ?} ?? ? ?? ?@Test ?? ?public void testTransactionlPropagation(){ ?? ??? ?cashier.checkout("AA", Arrays.asList("1001", "1002")); ?? ?} ?? ? ?? ?@Test ?? ?public void testBookShopService(){ ?? ??? ?bookShopService.purchase("AA", "1001"); ?? ?} ?? ? ?? ?@Test ?? ?public void testBookShopDaoUpdateUserAccount(){ ?? ??? ?bookShopDao.updateUserAccount("AA", 200); ?? ?} ?? ? ?? ?@Test ?? ?public void testBookShopDaoUpdateBookStock(){ ?? ??? ?bookShopDao.updateBookStock("1001"); ?? ?} ?? ? ?? ?@Test ?? ?public void testBookShopDaoFindPriceByIsbn() { ?? ??? ?System.out.println(bookShopDao.findBookPriceByIsbn("1001")); ?? ?} ? }
BookStockException、UserAccountException為自定義異常類!
配置文件:
<?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans" ?? ?xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" ?? ?xmlns:context="http://www.springframework.org/schema/context" ?? ?xmlns:tx="http://www.springframework.org/schema/tx" ?? ?xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd ?? ??? ?http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-4.0.xsd ?? ??? ?http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-4.0.xsd"> ?? ? ?? ?<context:component-scan base-package="com.atguigu.spring"></context:component-scan> ?? ? ?? ?<!-- 導入資源文件 --> ?? ?<context:property-placeholder location="classpath:db.properties"/> ?? ? ?? ?<!-- 配置 C3P0 數(shù)據(jù)源 --> ?? ?<bean id="dataSource" ?? ??? ?class="com.mchange.v2.c3p0.ComboPooledDataSource"> ?? ??? ?<property name="user" value="${jdbc.user}"></property> ?? ??? ?<property name="password" value="${jdbc.password}"></property> ?? ??? ?<property name="jdbcUrl" value="${jdbc.jdbcUrl}"></property> ?? ??? ?<property name="driverClass" value="${jdbc.driverClass}"></property> ? ?? ??? ?<property name="initialPoolSize" value="${jdbc.initPoolSize}"></property> ?? ??? ?<property name="maxPoolSize" value="${jdbc.maxPoolSize}"></property> ?? ?</bean> ?? ? ?? ?<!-- 配置 Spirng 的 JdbcTemplate --> ?? ?<bean id="jdbcTemplate"? ?? ??? ?class="org.springframework.jdbc.core.JdbcTemplate"> ?? ??? ?<property name="dataSource" ref="dataSource"></property> ?? ?</bean> ?? ? ?? ?<!-- 配置 NamedParameterJdbcTemplate, 該對象可以使用具名參數(shù), 其沒有無參數(shù)的構(gòu)造器, 所以必須為其構(gòu)造器指定參數(shù) --> ?? ?<bean id="namedParameterJdbcTemplate" ?? ??? ?class="org.springframework.jdbc.core.namedparam.NamedParameterJdbcTemplate"> ?? ??? ?<constructor-arg ref="dataSource"></constructor-arg>?? ? ?? ?</bean> ?? ? ?? ?<!-- 配置事務(wù)管理器 --> ?? ?<bean id="transactionManager"? ?? ??? ?class="org.springframework.jdbc.datasource.DataSourceTransactionManager"> ?? ??? ?<property name="dataSource" ref="dataSource"></property> ?? ?</bean> ?? ? ?? ?<!-- 啟用事務(wù)注解 --> ?? ?<tx:annotation-driven transaction-manager="transactionManager"/> ?? ? </beans>
配置文件(使用配置文件配置事務(wù),以上類的注解需要全部刪除):
<?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans" ?? ?xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" ?? ?xmlns:context="http://www.springframework.org/schema/context" ?? ?xmlns:tx="http://www.springframework.org/schema/tx" ?? ?xmlns:aop="http://www.springframework.org/schema/aop" ?? ?xsi:schemaLocation="http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-4.0.xsd ?? ??? ?http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd ?? ??? ?http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-4.0.xsd ?? ??? ?http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-4.0.xsd"> ?? ? ?? ?<context:component-scan base-package="com.atguigu.spring"></context:component-scan> ?? ? ?? ?<!-- 導入資源文件 --> ?? ?<context:property-placeholder location="classpath:db.properties"/> ?? ? ?? ?<!-- 配置 C3P0 數(shù)據(jù)源 --> ?? ?<bean id="dataSource" ?? ??? ?class="com.mchange.v2.c3p0.ComboPooledDataSource"> ?? ??? ?<property name="user" value="${jdbc.user}"></property> ?? ??? ?<property name="password" value="${jdbc.password}"></property> ?? ??? ?<property name="jdbcUrl" value="${jdbc.jdbcUrl}"></property> ?? ??? ?<property name="driverClass" value="${jdbc.driverClass}"></property> ? ?? ??? ?<property name="initialPoolSize" value="${jdbc.initPoolSize}"></property> ?? ??? ?<property name="maxPoolSize" value="${jdbc.maxPoolSize}"></property> ?? ?</bean> ?? ? ?? ?<!-- 配置 Spirng 的 JdbcTemplate --> ?? ?<bean id="jdbcTemplate"? ?? ??? ?class="org.springframework.jdbc.core.JdbcTemplate"> ?? ??? ?<property name="dataSource" ref="dataSource"></property> ?? ?</bean> ?? ? ?? ?<!-- 配置 bean --> ?? ?<bean id="bookShopDao" class="com.atguigu.spring.tx.xml.BookShopDaoImpl"> ?? ??? ?<property name="jdbcTemplate" ref="jdbcTemplate"></property> ?? ?</bean> ?? ? ?? ?<bean id="bookShopService" class="com.atguigu.spring.tx.xml.service.impl.BookShopServiceImpl"> ?? ??? ?<property name="bookShopDao" ref="bookShopDao"></property> ?? ?</bean> ?? ? ?? ?<bean id="cashier" class="com.atguigu.spring.tx.xml.service.impl.CashierImpl"> ?? ??? ?<property name="bookShopService" ref="bookShopService"></property> ?? ?</bean> ?? ? ?? ?<!-- 1. 配置事務(wù)管理器 --> ?? ?<bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager"> ?? ??? ?<property name="dataSource" ref="dataSource"></property> ?? ?</bean> ?? ? ?? ?<!-- 2. 配置事務(wù)屬性 --> ?? ?<tx:advice id="txAdvice" transaction-manager="transactionManager"> ?? ??? ?<tx:attributes> ?? ??? ??? ?<!-- 根據(jù)方法名指定事務(wù)的屬性 --> ?? ??? ??? ?<tx:method name="purchase" propagation="REQUIRES_NEW"/> ?? ??? ??? ?<tx:method name="get*" read-only="true"/> ?? ??? ??? ?<tx:method name="find*" read-only="true"/> ?? ??? ??? ?<tx:method name="*"/> ?? ??? ?</tx:attributes> ?? ?</tx:advice> ?? ? ?? ?<!-- 3. 配置事務(wù)切入點, 以及把事務(wù)切入點和事務(wù)屬性關(guān)聯(lián)起來 --> ?? ?<aop:config> ?? ??? ?<aop:pointcut expression="execution(* com.atguigu.spring.tx.xml.service.*.*(..))"? ?? ??? ??? ?id="txPointCut"/> ?? ??? ?<aop:advisor advice-ref="txAdvice" pointcut-ref="txPointCut"/>?? ? ?? ?</aop:config> ?? ? </beans>
以上就是本文的全部內(nèi)容,希望對大家的學習有所幫助,也希望大家多多支持腳本之家。
相關(guān)文章
Spring實戰(zhàn)之XML與JavaConfig的混合配置詳解
大家都知道Spring的顯示配置方式有兩種,一種是基于XML配置,一種是基于JavaConfig的方式配置。那么下這篇文章主要給大家分別介紹如何在JavaConfig中引用XML配置的bean以及如何在XML配置中引用JavaConfig,需要的朋友可以參考下。2017-07-07Springboot整合Flowable6.x導出bpmn20的步驟詳解
這篇文章主要介紹了Springboot整合Flowable6.x導出bpmn20,Flowable流程引擎可用于部署B(yǎng)PMN 2.0流程定義,可以十分靈活地加入你的應(yīng)用/服務(wù)/構(gòu)架,本文給出兩種從flowable導出流程定義bpmn20.xml的方式,需要的朋友可以參考下2023-04-04