PlatformTransactionManager

本文轉載自查看原文 2016-09-16 23:02 19089 Transactional

Spring Boot 使用事務非常簡單，首先使用注解 @EnableTransactionManagement 開啟事務支持后，然后在訪問數據庫的Service方法上添加注解 @Transactional 便可。

關於事務管理器，不管是JPA還是JDBC等都實現自接口 PlatformTransactionManager 如果你添加的是 spring-boot-starter-jdbc 依賴，框架會默認注入 DataSourceTransactionManager 實例。如果你添加的是 spring-boot-starter-data-jpa 依賴，框架會默認注入 JpaTransactionManager 實例。

你可以在啟動類中添加如下方法，Debug測試，就能知道自動注入的是 PlatformTransactionManager 接口的哪個實現類。

@EnableTransactionManagement // 啟注解事務管理，等同於xml配置方式的 <tx:annotation-driven />
@SpringBootApplication
public class ProfiledemoApplication {

    @Bean
    public Object testBean(PlatformTransactionManager platformTransactionManager){
        System.out.println(">>>>>>>>>>" + platformTransactionManager.getClass().getName());
        return new Object();
    }

    public static void main(String[] args) {
        SpringApplication.run(ProfiledemoApplication.class, args);
    }
}

這些SpringBoot為我們自動做了，這些對我們並不透明，如果你項目做的比較大，添加的持久化依賴比較多，我們還是會選擇人為的指定使用哪個事務管理器。
代碼如下：

@EnableTransactionManagement
@SpringBootApplication
public class ProfiledemoApplication {

    // 其中 dataSource 框架會自動為我們注入
    @Bean
    public PlatformTransactionManager txManager(DataSource dataSource) {
        return new DataSourceTransactionManager(dataSource);
    }

    @Bean
    public Object testBean(PlatformTransactionManager platformTransactionManager) {
        System.out.println(">>>>>>>>>>" + platformTransactionManager.getClass().getName());
        return new Object();
    }

    public static void main(String[] args) {
        SpringApplication.run(ProfiledemoApplication.class, args);
    }
}

在Spring容器中，我們手工注解@Bean 將被優先加載，框架不會重新實例化其他的 PlatformTransactionManager 實現類。

然后在Service中，被 @Transactional 注解的方法，將支持事務。如果注解在類上，則整個類的所有方法都默認支持事務。

對於同一個工程中存在多個事務管理器要怎么處理，請看下面的實例，具體說明請看代碼中的注釋。

@EnableTransactionManagement // 開啟注解事務管理，等同於xml配置文件中的 <tx:annotation-driven />
@SpringBootApplication
public class ProfiledemoApplication implements TransactionManagementConfigurer {

    @Resource(name="txManager2")
    private PlatformTransactionManager txManager2;

    // 創建事務管理器1
    @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();
    }

    // 在存在多個事務管理器的情況下，如果使用value具體指定
    // 則默認使用方法 annotationDrivenTransactionManager() 返回的事務管理器
    @Transactional
    public void send2() {
        System.out.println(">>>>>>>>Dev Send2()<<<<<<<<");
    }

}

注：
如果Spring容器中存在多個 PlatformTransactionManager 實例，並且沒有實現接口 TransactionManagementConfigurer 指定默認值，在我們在方法上使用注解 @Transactional 的時候，就必須要用value指定，如果不指定，則會拋出異常。

對於系統需要提供默認事務管理的情況下，實現接口 TransactionManagementConfigurer 指定。

對有的系統，為了避免不必要的問題，在業務中必須要明確指定 @Transactional 的 value 值的情況下。不建議實現接口 TransactionManagementConfigurer，這樣控制台會明確拋出異常，開發人員就不會忘記主動指定。

http://blog.csdn.net/catoop/article/details/50595702

注意的幾點:

1 @Transactional 只能被應用到public方法上, 對於其它非public的方法,如果標記了@Transactional也不會報錯,但方法沒有事務功能.

2 默認情況下,一個有事務方法, 遇到RuntiomeException 時會回滾 . 遇到 受檢查的異常 是不會回滾 的. 要想所有異常都回滾,要加上 @Transactional( rollbackFor={Exception.class,其它異常}) .

@Transactional 的所有可選屬性如下:

屬性	類型	默認值	說明
propagation	Propagation枚舉	REQUIRED	事務傳播屬性 (下有說明)
isolation	isolation枚舉	DEFAULT	事務隔離級別 (另有說明)
readOnly	boolean	false	是否只讀
timeout	int	-1	超時(秒)
rollbackFor	Class[]	{}	需要回滾的異常類
rollbackForClassName	String[]	{}	需要回滾的異常類名
noRollbackFor	Class[]	{}	不需要回滾的異常類
noRollbackForClassName	String[]	{}	不需要回滾的異常類名

事務的隔離級別有如下可選:

可以去看spring源碼 : org.springframework.transaction.annotation.Isolation

(用時，導入org.springframework.transaction.annotation.Isolation，再在Transactional括號里用如isolation = Isolation.DEFAULT)

我的"隔離級別"相關文章有不明白的,可以去看看.

DEFAULT	采用數據庫默認隔離級別
READ_UNCOMMITTED	請看"隔離級別"相關文章
READ_COMMITTED	請看"隔離級別"相關文章
REPEATABLE_READ	請看"隔離級別"相關文章
SERIALIZABLE	請看 "隔離級別"相關文章

事務的傳播屬性 ,有如下可選

可以去看spring源碼 : org.springframework.transaction.annotation.Propagation

(用時，導入org.springframework.transaction.annotation.Propagation，再在Transactional括號里用如propagation = Propagation.REQUIRED)

REQUIRED	業務方法需要在一個事務中運行,如果方法運行時,已處在一個事務中,那么就加入該事務,否則自己創建一個新的事務.這是spring默認的傳播行為.
SUPPORTS	如果業務方法在某個事務范圍內被調用,則方法成為該事務的一部分,如果業務方法在事務范圍外被調用,則方法在沒有事務的環境下執行.
MANDATORY	只能在一個已存在事務中執行,業務方法不能發起自己的事務,如果業務方法在沒有事務的環境下調用,就拋異常
REQUIRES_NEW	業務方法總是會為自己發起一個新的事務,如果方法已運行在一個事務中,則原有事務被掛起,新的事務被創建,直到方法結束,新事務才結束,原先的事務才會恢復執行.
NOT_SUPPORTED	聲明方法需要事務,如果方法沒有關聯到一個事務,容器不會為它開啟事務.如果方法在一個事務中被調用,該事務會被掛起,在方法調用結束后,原先的事務便會恢復執行.
NEVER	聲明方法絕對不能在事務范圍內執行,如果方法在某個事務范圍內執行,容器就拋異常.只有沒關聯到事務,才正常執行.
NESTED	如果一個活動的事務存在,則運行在一個嵌套的事務中.如果沒有活動的事務,則按REQUIRED屬性執行.它使用了一個單獨的事務, 這個事務擁有多個可以回滾的保證點.內部事務回滾不會對外部事務造成影響, 它只對DataSourceTransactionManager 事務管理器起效.

//事務傳播屬性  
    @Transactional(propagation=Propagation.REQUIRED) //如果有事務,那么加入事務,沒有的話新建一個(不寫的情況下)  
    @Transactional(propagation=Propagation.NOT_SUPPORTED) //容器不為這個方法開啟事務  
    @Transactional(propagation=Propagation.REQUIRES_NEW) //不管是否存在事務,都創建一個新的事務,原來的掛起,新的執行完畢,繼續執行老的事務  
    @Transactional(propagation=Propagation.MANDATORY) //必須在一個已有的事務中執行,否則拋出異常  
    @Transactional(propagation=Propagation.NEVER) //必須在一個沒有的事務中執行,否則拋出異常(與Propagation.MANDATORY相反)  
    @Transactional(propagation=Propagation.SUPPORTS) //如果其他bean調用這個方法,在其他bean中聲明事務,那就用事務.如果其他bean沒有聲明事務,那就不用事務.  
      
   
    @Transactional(propagation=Propagation.NESTED)   
    @Transactional (propagation = Propagation.REQUIRED,readOnly=true) //readOnly=true只讀,不能更新,刪除   
    @Transactional (propagation = Propagation.REQUIRED,timeout=30)//設置超時時間   
    @Transactional (propagation = Propagation.REQUIRED,isolation=Isolation.DEFAULT)//設置數據庫隔離級別

用 spring 事務管理器,由spring來負責數據庫的打開,提交,回滾.
默認遇到運行期例外(throw new RuntimeException("注釋");)會回滾，即遇到不受檢查（unchecked）的例外時回滾；
而遇到需要捕獲的例外(throw new Exception("注釋");)不會回滾,即遇到受檢查的例外（就是非運行時拋出的異常，編譯器會檢查到的異常叫受檢查例外或說受檢查異常）時，需我們指定方式來讓事務回滾 ,如下:

@Transactional(rollbackFor=Exception.class) //指定回滾,遇到異常Exception時回滾
    public void methodName() {
       throw new Exception("注釋");
        
    } 
@Transactional(noRollbackFor=Exception.class)//指定不回滾,遇到運行期例外(throw new RuntimeException("注釋");)會回滾
    public ItimDaoImpl getItemDaoImpl() {
        throw new RuntimeException("注釋");
    }

http://blog.csdn.net/hz_chenwenbiaotmb/article/details/5793538

原文 http://blog.didispace.com/springboottransactional/

什么是事務？

我們在開發企業應用時，對於業務人員的一個操作實際是對數據讀寫的多步操作的結合。由於數據操作在順序執行的過程中，任何一步操作都有可能發生異常，異常會導致后續操作無法完成，此時由於業務邏輯並未正確的完成，之前成功操作數據的並不可靠，需要在這種情況下進行回退。

事務的作用就是為了保證用戶的每一個操作都是可靠的，事務中的每一步操作都必須成功執行，只要有發生異常就回退到事務開始未進行操作的狀態。

事務管理是Spring框架中最為常用的功能之一，我們在使用Spring Boot開發應用時，大部分情況下也都需要使用事務。

快速入門

在Spring Boot中，當我們使用了spring-boot-starter-jdbc或spring-boot-starter-data-jpa依賴的時候，框架會自動默認分別注入DataSourceTransactionManager或JpaTransactionManager。所以我們不需要任何額外配置就可以用@Transactional注解進行事務的使用。

在該樣例工程中（若對該數據訪問方式不了解，可先閱讀該文章），我們引入了spring-data-jpa，並創建了User實體以及對User的數據訪問對象UserRepository，在ApplicationTest類中實現了使用UserRepository進行數據讀寫的單元測試用例，如下：

@RunWith(SpringJUnit4ClassRunner.class)
@SpringApplicationConfiguration(Application.class)
public class ApplicationTests {

    @Autowired
    private UserRepository userRepository;

    @Test
    public void test() throws Exception {

        // 創建10條記錄
        userRepository.save(new User("AAA", 10));
        userRepository.save(new User("BBB", 20));
        userRepository.save(new User("CCC", 30));
        userRepository.save(new User("DDD", 40));
        userRepository.save(new User("EEE", 50));
        userRepository.save(new User("FFF", 60));
        userRepository.save(new User("GGG", 70));
        userRepository.save(new User("HHH", 80));
        userRepository.save(new User("III", 90));
        userRepository.save(new User("JJJ", 100));

        // 省略后續的一些驗證操作
    }


}

可以看到，在這個單元測試用例中，使用UserRepository對象連續創建了10個User實體到數據庫中，下面我們人為的來制造一些異常，看看會發生什么情況。

通過定義User的name屬性長度為5，這樣通過創建時User實體的name屬性超長就可以觸發異常產生。

@Entity
public class User {

    @Id
    @GeneratedValue
    private Long id;

    @Column(nullable = false, length = 5)
    private String name;

    @Column(nullable = false)
    private Integer age;

    // 省略構造函數、getter和setter

}

修改測試用例中創建記錄的語句，將一條記錄的name長度超過5，如下：name為HHHHHHHHH的User對象將會拋出異常。

// 創建10條記錄
userRepository.save(new User("AAA", 10));  
userRepository.save(new User("BBB", 20));  
userRepository.save(new User("CCC", 30));  
userRepository.save(new User("DDD", 40));  
userRepository.save(new User("EEE", 50));  
userRepository.save(new User("FFF", 60));  
userRepository.save(new User("GGG", 70));  
userRepository.save(new User("HHHHHHHHHH", 80));  
userRepository.save(new User("III", 90));  
userRepository.save(new User("JJJ", 100));

執行測試用例，可以看到控制台中拋出了如下異常，name字段超長：

2016-05-27 10:30:35.948 WARN 2660 --- [ main] o.h.engine.jdbc.spi.SqlExceptionHelper : SQL Error: 1406, SQLState: 22001 2016-05-27 10:30:35.948 ERROR 2660 --- [ main] o.h.engine.jdbc.spi.SqlExceptionHelper : Data truncation: Data too long for column 'name' at row 1 2016-05-27 10:30:35.951 WARN 2660 --- [ main] o.h.engine.jdbc.spi.SqlExceptionHelper : SQL Warning Code: 1406, SQLState: HY000 2016-05-27 10:30:35.951 WARN 2660 --- [ main] o.h.engine.jdbc.spi.SqlExceptionHelper : Data too long for column 'name' at row 1 org.springframework.dao.DataIntegrityViolationException: could not execute statement; SQL [n/a]; nested exception is org.hibernate.exception.DataException: could not execute statement

此時查數據庫中，創建了name從AAA到GGG的記錄，沒有HHHHHHHHHH、III、JJJ的記錄。而若這是一個希望保證完整性操作的情況下，AAA到GGG的記錄希望能在發生異常的時候被回退，這時候就可以使用事務讓它實現回退，做法非常簡單，我們只需要在test函數上添加 @Transactional 注解即可。

@Test
@Transactional
public void test() throws Exception {

    // 省略測試內容

}

這里主要通過單元測試演示了如何使用 @Transactional 注解來聲明一個函數需要被事務管理，通常我們單元測試為了保證每個測試之間的數據獨立，會使用 @Rollback 注解讓每個單元測試都能在結束時回滾。而真正在開發業務邏輯時，我們通常在service層接口中使用 @Transactional 來對各個業務邏輯進行事務管理的配置，例如：

public interface UserService {

    @Transactional
    User login(String name, String password);

}

事務詳解

上面的例子中我們使用了默認的事務配置，可以滿足一些基本的事務需求，但是當我們項目較大較復雜時（比如，有多個數據源等），這時候需要在聲明事務時，指定不同的事務管理器。對於不同數據源的事務管理配置可以見《Spring Boot多數據源配置與使用》中的設置。在聲明事務時，只需要通過value屬性指定配置的事務管理器名即可，例如： @Transactional(value="transactionManagerPrimary") 。

除了指定不同的事務管理器之后，還能對事務進行隔離級別和傳播行為的控制，下面分別詳細解釋：

隔離級別

隔離級別是指若干個並發的事務之間的隔離程度，與我們開發時候主要相關的場景包括：臟讀取、重復讀、幻讀。

我們可以看 org.springframework.transaction.annotation.Isolation 枚舉類中定義了五個表示隔離級別的值：

public enum Isolation {  
    DEFAULT(-1),
    READ_UNCOMMITTED(1),
    READ_COMMITTED(2),
    REPEATABLE_READ(4),
    SERIALIZABLE(8);
}

DEFAULT ：這是默認值，表示使用底層數據庫的默認隔離級別。對大部分數據庫而言，通常這值就是： READ_COMMITTED 。
READ_UNCOMMITTED ：該隔離級別表示一個事務可以讀取另一個事務修改但還沒有提交的數據。該級別不能防止臟讀和不可重復讀，因此很少使用該隔離級別。
READ_COMMITTED ：該隔離級別表示一個事務只能讀取另一個事務已經提交的數據。該級別可以防止臟讀，這也是大多數情況下的推薦值。
REPEATABLE_READ ：該隔離級別表示一個事務在整個過程中可以多次重復執行某個查詢，並且每次返回的記錄都相同。即使在多次查詢之間有新增的數據滿足該查詢，這些新增的記錄也會被忽略。該級別可以防止臟讀和不可重復讀。
SERIALIZABLE ：所有的事務依次逐個執行，這樣事務之間就完全不可能產生干擾，也就是說，該級別可以防止臟讀、不可重復讀以及幻讀。但是這將嚴重影響程序的性能。通常情況下也不會用到該級別。

指定方法：通過使用 isolation 屬性設置，例如：

@Transactional(isolation = Isolation.DEFAULT)

傳播行為

所謂事務的傳播行為是指，如果在開始當前事務之前，一個事務上下文已經存在，此時有若干選項可以指定一個事務性方法的執行行為。

我們可以看 org.springframework.transaction.annotation.Propagation 枚舉類中定義了6個表示傳播行為的枚舉值：

public enum Propagation {  
    REQUIRED(0),
    SUPPORTS(1),
    MANDATORY(2),
    REQUIRES_NEW(3),
    NOT_SUPPORTED(4),
    NEVER(5),
    NESTED(6);
}

REQUIRED ：如果當前存在事務，則加入該事務；如果當前沒有事務，則創建一個新的事務。
SUPPORTS ：如果當前存在事務，則加入該事務；如果當前沒有事務，則以非事務的方式繼續運行。
MANDATORY ：如果當前存在事務，則加入該事務；如果當前沒有事務，則拋出異常。
REQUIRES_NEW ：創建一個新的事務，如果當前存在事務，則把當前事務掛起。
NOT_SUPPORTED ：以非事務方式運行，如果當前存在事務，則把當前事務掛起。
NEVER ：以非事務方式運行，如果當前存在事務，則拋出異常。
NESTED ：如果當前存在事務，則創建一個事務作為當前事務的嵌套事務來運行；如果當前沒有事務，則該取值等價於 REQUIRED 。

指定方法：通過使用 propagation 屬性設置，例如：

@Transactional(propagation = Propagation.REQUIRED)

http://www.cnblogs.com/sllina/p/5694805.html

免責聲明！

本站轉載的文章為個人學習借鑒使用，本站對版權不負任何法律責任。如果侵犯了您的隱私權益，請聯系本站郵箱yoyou2525@163.com刪除。

猜您在找 PlatformTransactionManager Springboot使用PlatformTransactionManager接口的事務處理 Spring事務管理接口：PlatformTransactionManager、TransactionDefinition和TransactionStatus Spring事務管理接口PlatformTransactionManager的實現類DataSourceTransactionManager Spring4.14 事務異常 NoUniqueBeanDefinitionException: No qualifying bean of type [....PlatformTransactionManager] No matching PlatformTransactionManager bean found for qualifier 'transactionManager' - neither qualifier match nor bean name match!