淺談SpringBoot之事務處理機制

一、Spring的事務機制

所有的數據訪問技術都有事務處理機制，這些技術提供了API用來開啟事務、提交事務來完成數據操作，或者在發生錯誤的時候回滾數據。

而Spring的事務機制是用統一的機制來處理不同數據訪問技術的事務處理。 Spring的事務機制提供了一個PlatformTransactionManager接口，不同的數據訪問技術的事務使用不同的接口實現：

在程序中定義事務管理器的代碼如下：

 @Bean public PlatformTransactionManager transactionManager() { JpaTransactionManager transactionManager = new JpaTransactionManager(); transactionManager.setDataSource(dataSource()); return transactionManager; }

二、聲明式事務

Spring支持聲明式事務，即使用註解來選擇需要使用事務的方法，它使用@Transactional註解在方法上表明該方法需要事務支持。

 @Transactional public void saveSomething(Long id, String name) { //數據庫操作}

在此處需要特別注意的是，此@Transactional註解來自org.springframework.transaction.annotation包，而不是javax.transaction。

Spring提供了一個@EnableTransactionManagement註解在配置類上來開啟聲明式事務的支持。使用了@EnableTransactionManagement後，Spring容器會自動掃描註解@Transactional的方法和類。 @EnableTransactionManagement的使用方式如下：

 @Configuration @EnableTransactionManagement public class AppConfig { }

三、類級別使用@Transactional

@Transactional不僅可以註解在方法上，也可以註解在類上。當註解在類上的時候意味著此類的所有public方法都是開啟事務的。如果類級別和方法級別同時使用了@Transactional註解，則使用在類級別的註解會重載方法級別的註解。

四、Spring Data JPA的事務支持

Spring Data JPA對所有的默認方法都開啟了事務支持，且查詢類事務默認啟用readOnly=true屬性。

這個從源碼SimpleJpaRepository中可以看出，SimpleJpaRepository在類級別定義了@Transactional（readOnly=true），而在和save、delete相關的操作重寫了@Transactional屬性，此時readOnly屬性是false，其餘查詢操作readOnly仍然為false。

五、Spring Boot的事務支持

1.自動配置的事務管理器

在使用JDBC作為數據訪問技術的時候，SpringBoot為我們定義了PlatformTransactionManager的實現DataSourceTransactionManager的Bean；配置見org.springframework.boot.autoconfigure.jdbc.DataSourceTransactionManagerAutoConfiguration類中的定義：

 @Bean @ConditionalOnMissingBean @ConditionalOnBean(DataSource.class) public PlatformTransactionManager transactionManager() { return new DataSourceTransactionManager(this.dataSource); }

在使用JPA作為數據訪問技術的時候，Spring Boot為我們了定義一個PlatformTransactionManager的實現JpaTransactionManager的Bean；配置見org.springframework.boot.autoconfigure.orm.jpa.JpaBaseConfiguration.class類中的定義：

 @Bean @ConditionalOnMissingBean(PlatformTransactionManager.class) public PlatformTransactionManager transactionManager() { return new JpaTransactionManager(); }

2.自動開啟註解事務的支持

Spring Boot專門用於配置事務的類為：org.springframework.boot.autoconfigure.transaction.TransactionAutoConfiguration，此配置類依賴於JpaBaseConfiguration和DataSourceTransactionManagerAutoConfiguration。

而在DataSourceTransactionManagerAutoConfiguration配置裡還開啟了對聲明式事務的支持，代碼如下：

 @ConditionalOnMissingBean(AbstractTransactionManagementConfiguration.class) @Configuration @EnableTransactionManagement protected static class TransactionManagementConfiguration { }

所以在Spring Boot中，無須顯示開啟使用@EnableTransactionManagement註解。

六、實例（Springboot）

1.pom.xml：

 <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data-jpa</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data-rest</artifactId> </dependency> <dependency> <groupId>mysql</groupId> <artifactId>mysql-connector-java</artifactId> <scope>runtime</scope> </dependency>

2.application.yml：

 server: port: 5000 spring: datasource: driver-class-name: com.mysql.jdbc.Driver url: jdbc:mysql://localhost:3306/test?useUnicode=true&characterEncoding=utf8&characterSetResults=utf8 username: root password: password jpa: hibernate: ddl-auto: update # 第一次簡表create 後面用update show-sql: true

3.實體類Staff：

 @Entity public class Staff { @Id @GeneratedValue private Long id; private String name; private Integer age; private String address; public Staff() { super(); } public Staff(Long id, String name, Integer age, String address) { super(); this.id = id; this.name = name; this.age = age; this.address = address; } //省略get、set方法}

4.Staff的Repository：

 public interface StaffRepository extends JpaRepository<Staff, Long> { }

5.服務接口：

 public interface StaffService { public Staff saveStaffWithRollBack(Staff staff);//回滾public Staff saveStaffWithoutRollBack(Staff staff);//不回滾}

6.服務實現：

 @Service public class StaffServiceImpl implements StaffService { @Autowired StaffRepository staffRepository; //可以直接注入我們的RersonRepository的Bean。 @Override //使用@Transactional註解的rollbackFor屬性，指定特定異常時，數據回滾。 @Transactional(rollbackFor = {IllegalArgumentException.class}) public Staff saveStaffWithRollBack(Staff staff) { Staff s = staffRepository.save(staff); if (staff.getName().equals("張三")) { throw new IllegalArgumentException("張三已經存在了，rollback"); } return s; } @Override public Staff saveStaffWithoutRollBack(Staff staff) { Staff s = staffRepository.save(staff); if (staff.getName().equals("張三")) { throw new IllegalArgumentException("張三已經存在了，數據不回滾"); } return s; } }

7.Controller：

 @RestController @RequestMapping("/staff") public class StaffController { @Autowired StaffService staffService; //測試回滾情況@RequestMapping("/rollback") public Staff rollback(Staff staff) { return staffService.saveStaffWithRollBack(staff); } //測試不回滾情況@RequestMapping("/notrollback") public Staff noRollBack(Staff staff) { return staffService.saveStaffWithoutRollBack(staff); } }

8.運行測試：

（1）回滾：http://localhost:5000/staff/rollback?name=張三&age=18

控制台：

資料庫:

（2）不回滾：http://localhost:5000/staff/notrollback?name=張三&age=18

控制台：

資料庫:

以上就是本文的全部內容，希望對大家的學習有所幫助，也希望大家多多支持武林網。