溫馨提示×
您好，登錄后才能下訂單哦！
點擊 登錄注冊 即表示同意《億速云用戶服務條款》
您好，登錄后才能下訂單哦！
在Spring Boot事務管理中，實現自接口PlatformTransactionManager。
public interface PlatformTransactionManager {
org.springframework.transaction.TransactionStatus getTransaction(org.springframework.transaction.TransactionDefinition transactionDefinition) throws org.springframework.transaction.TransactionException;
void commit(org.springframework.transaction.TransactionStatus transactionStatus) throws org.springframework.transaction.TransactionException;
void rollback(org.springframework.transaction.TransactionStatus transactionStatus) throws org.springframework.transaction.TransactionException;
}
當我們使用了spring-boot-starter-jdbc依賴的時候，框 架會自動默認注入DataSourceTransactionManager。所以我們不需要任何額外 配置就可以用@Transactional注解進行事務的使用。
jdbc事務管理器
在Service中，被 @Transactional 注解的方法，將支持事務。如果注解在類上，則整個類的所有方法都默認支持事務。
多事務管理器情況
一：可以通過實現TransactionManagementConfigurer接口，里面方法返回值是默認的事務管理器。
二：可以在具體執行方法上設置value
如果Spring容器中存在多個 PlatformTransactionManager 實例，并且沒有實現接口TransactionManagementConfigurer 指定默認值，在我們在方法上使用注解 @Transactional 的時候，就必須要用value指定，如果不指定，則會拋出異常。
//@EnableTransactionManagement // 開啟注解事務管理，等同于xml配置文件中的 <tx:annotation-driven />
@SpringBootApplication
public class ProfiledemoApplication implements TransactionManagementConfigurer {
@Resource(name="txManager2")
private PlatformTransactionManager txManager2;
// 手動創建事務管理器1 datasource框架會自動注入
//在Spring容器中，我們手工注解@Bean 將被優先加載，框架不會重新實例化其他的 PlatformTransactionManager 實現類。
@Bean(name = "txManager1")
public PlatformTransactionManager txManager(DataSource dataSource) {
return new DataSourceTransactionManager(dataSource);
}
// 創建事務管理器2
@Bean(name = "txManager2")
public PlatformTransactionManager txManager2(EntityManagerFactory factory) {
return new JpaTransactionManager(factory);
}
// 實現接口 TransactionManagementConfigurer 方法，其返回值代表在擁有多個事務管理器的情況下默認使用的事務管理器
@Override
public PlatformTransactionManager annotationDrivenTransactionManager() {
return txManager2;
}
public static void main(String[] args) {
SpringApplication.run(ProfiledemoApplication.class, args);
}
}
具體實現
@Component
public class DevSendMessage implements SendMessage {
// 使用value具體指定使用哪個事務管理器
@Transactional(value="txManager1")
@Override
public void send() {
System.out.println(">>>>>>>>Dev Send()<<<<<<<<");
send2();
}
@Transactional
public void send2() {
System.out.println(">>>>>>>>Dev Send2()<<<<<<<<");
}
}
隔離級別
public enum Isolation {
DEFAULT(TransactionDefinition.ISOLATION_DEFAULT),
READ_UNCOMMITTED(TransactionDefinition.ISOLATION_READ_UNCOMMITTED),
READ_COMMITTED(TransactionDefinition.ISOLATION_READ_COMMITTED),
REPEATABLE_READ(TransactionDefinition.ISOLATION_REPEATABLE_READ),
SERIALIZABLE(TransactionDefinition.ISOLATION_SERIALIZABLE);
private final int value;
Isolation(int value) { this.value = value; }
public int value() { return this.value; }
}
指定方法：通過使用 isolation 屬性設置，例如：
@Transactional(isolation = Isolation.DEFAULT)
傳播行為
所謂事務的傳播行為是指，如果在開始當前事務之前，一個事務上下文已經存在，此時有若干選項可以指定一個事務性方法的執行行為。
我們可以看 org.springframework.transaction.annotation.Propagation 枚舉類中定義了6個表示傳播行為的枚舉值：
public enum Propagation {
REQUIRED(TransactionDefinition.PROPAGATION_REQUIRED),
SUPPORTS(TransactionDefinition.PROPAGATION_SUPPORTS),
MANDATORY(TransactionDefinition.PROPAGATION_MANDATORY),
REQUIRES_NEW(TransactionDefinition.PROPAGATION_REQUIRES_NEW),
NOT_SUPPORTED(TransactionDefinition.PROPAGATION_NOT_SUPPORTED),
NEVER(TransactionDefinition.PROPAGATION_NEVER),
NESTED(TransactionDefinition.PROPAGATION_NESTED);
private final int value;
Propagation(int value) { this.value = value; }
public int value() { return this.value; }
}
REQUIRED ：如果當前存在事務，則加入該事務；如果當前沒有事務，則創建一個新的事務。默認值。
SUPPORTS ：如果當前存在事務，則加入該事務；如果當前沒有事務，則以非事務的方式繼續運行。
MANDATORY ：如果當前存在事務，則加入該事務；如果當前沒有事務，則拋出異常。（強制放入事務中）
REQUIRES_NEW ：創建一個新的事務，如果當前存在事務，則把當前事務掛起。（打印日志常用，即使前面回滾，該事務也會執行，記錄報錯信息）
NOT_SUPPORTED ：以非事務方式運行，如果當前存在事務，則把當前事務掛起。
NEVER ：以非事務方式運行，如果當前存在事務，則拋出異常。
NESTED ：如果當前存在事務，則創建一個事務作為當前事務的嵌套事務來運行；如果當前沒有事務，則該取值等價于 REQUIRED 。
指定方法：通過使用 propagation 屬性設置，例如：
@Transactional(propagation = Propagation.REQUIRED)
事務不回滾情況
只在發生未被捕獲的 RuntimeException 時才回滾
catch拋出的異常，兩次插入都會成功
@Override
@Transactional
public void insertandinsert(Staff staff) {
staffDao.insert(staff);
try {
int i = 1 / 0;
}catch (Exception e){
e.printStackTrace();
}
staffDao.insert(staff);
}
在service層方法的catch語句中增加：TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();語句，手動回滾不會插入數據
@Override
@Transactional
public void insertandinsert(Staff staff) throws Exception {
try {
staffDao.insert(staff);
int i=1/0;
staffDao.insert(staff);
}catch (Exception e){
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
}
}
以上就是本文的全部內容，希望對大家的學習有所幫助，也希望大家多多支持億速云。
免責聲明：本站發布的內容（圖片、視頻和文字）以原創、轉載和分享為主，文章觀點不代表本網站立場，如果涉及侵權請聯系站長郵箱：is@yisu.com進行舉報，并提供相關證據，一經查實，將立刻刪除涉嫌侵權內容。
