Spring註解驅動——事務
阿新 • • 發佈:2020-12-24
宣告式事務
寫個配置類
/** * 宣告式事務: * * 環境搭建: * 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(); } }