1. 程式人生 > 實用技巧 >Spring註解驅動——事務

Spring註解驅動——事務

宣告式事務

寫個配置類

/**
 * 宣告式事務:
 * 
 * 環境搭建:
 * 1、匯入相關依賴
 *         資料來源、資料庫驅動、Spring-jdbc模組
 * 2、配置資料來源、JdbcTemplate(Spring提供的簡化資料庫操作的工具)操作資料
 * 3、給方法上標註 @Transactional 表示當前方法是一個事務方法;
 * 4、 @EnableTransactionManagement 開啟基於註解的事務管理功能;
 *         @EnableXXX  這種註解就等於開啟某一個功能
 * 5、配置事務管理器來控制事務;  必須有
 *         @Bean
 *         public PlatformTransactionManager transactionManager()
 * 
 * 原理:
 * 1)、@EnableTransactionManagement
 *             利用TransactionManagementConfigurationSelector給容器中會匯入元件
 *             匯入兩個元件
 *             AutoProxyRegistrar
 *             ProxyTransactionManagementConfiguration
 * 2)、AutoProxyRegistrar:
 *             給容器中註冊一個 InfrastructureAdvisorAutoProxyCreator 元件;
 *             InfrastructureAdvisorAutoProxyCreator:?
 *             利用後置處理器機制在物件建立以後,包裝物件,返回一個代理物件(增強器),代理物件執行方法利用攔截器鏈進行呼叫;
 * 
 * 3)、ProxyTransactionManagementConfiguration 做了什麼?
 *             1、給容器中註冊事務增強器;
 *                 1)、事務增強器要用事務註解的資訊,AnnotationTransactionAttributeSource解析事務註解
 *                 2)、事務攔截器:
 *                     TransactionInterceptor;儲存了事務屬性資訊,事務管理器;
 *                     他是一個 MethodInterceptor;
 *                     在目標方法執行的時候;
 *                         執行攔截器鏈;
 *                         事務攔截器:
 *                             1)、先獲取事務相關的屬性
 *                             2)、再獲取PlatformTransactionManager,如果事先沒有新增指定任何transactionmanger
 *                                 最終會從容器中按照型別獲取一個PlatformTransactionManager;
 *                             3)、執行目標方法
 *                                 如果異常,獲取到事務管理器,利用事務管理回滾操作;
 *                                 如果正常,利用事務管理器,提交事務           
 
*/ @EnableTransactionManagement @ComponentScan("com.atguigu.tx") @Configuration public class TxConfig { //資料來源 @Bean public DataSource dataSource() throws Exception{ ComboPooledDataSource dataSource = new ComboPooledDataSource(); dataSource.setUser("root"); dataSource.setPassword(
"123456"); dataSource.setDriverClass("com.mysql.jdbc.Driver"); dataSource.setJdbcUrl("jdbc:mysql://localhost:3306/test"); return dataSource; } // @Bean public JdbcTemplate jdbcTemplate() throws Exception{ //Spring對@Configuration類會特殊處理;給容器中加元件的方法,多次呼叫都只是從容器中找元件
JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource()); return jdbcTemplate; } //註冊事務管理器在容器中 @Bean public PlatformTransactionManager transactionManager() throws Exception{ return new DataSourceTransactionManager(dataSource()); } }

dao:

@Repository
public class UserDao {    
    @Autowired
    private JdbcTemplate jdbcTemplate;
    public void insert(){
        String sql = "INSERT INTO `tbl_user`(username,age) VALUES(?,?)";
        String username = UUID.randomUUID().toString().substring(0, 5);
        jdbcTemplate.update(sql, username,19);
        
    }
}

service

@Service
public class UserService {
    
    @Autowired
    private UserDao userDao;
    
    @Transactional
    public void insertUser(){
        userDao.insert();
        //otherDao.other();xxx
        System.out.println("插入完成...");
        int i = 10/0;
    }
}

測試呼叫下

public class IOCTest_Tx {
    
    @Test
    public void test01(){
        AnnotationConfigApplicationContext applicationContext = new AnnotationConfigApplicationContext(TxConfig.class);
    
        UserService userService = applicationContext.getBean(UserService.class);
        
        userService.insertUser();
        applicationContext.close();
    }
}