一、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> { }</staff>
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
控制台:
以上是SpringBoot事務處理機制是什麼的詳細內容。更多資訊請關注PHP中文網其他相關文章!