Spring之声明式事务Transaction-环境搭建

╰+攻爆jí腚メ 2022-04-17 03:16 204阅读 0赞

**环境搭建步骤：**  
 \* 1、导入相关依赖  
 \*         数据源、数据库驱动、Spring-jdbc模块  
 \* 2、配置数据源、JdbcTemplate（Spring提供的简化数据库操作的工具）操作数据  
 \* 3、给方法上标注 @Transactional 表示当前方法是一个事务方法；  
 \* 4、 @EnableTransactionManagement 开启基于注解的事务管理功能；  
 \*         都是@EnableXXX模式  
 \* 5、配置事务管理器来控制事务;  
 \*         @Bean  
 \*         public PlatformTransactionManager transactionManager()

--------------------

### 1、导入数据源、数据库驱动、Spring-jdbc包 ###

<dependency>
    	<groupId>c3p0</groupId>
    	<artifactId>c3p0</artifactId>
    	<version>0.9.1.2</version>
    </dependency>
    
    
    <dependency>
    	<groupId>mysql</groupId>
    	<artifactId>mysql-connector-java</artifactId>
    	<version>5.1.44</version>
    </dependency>
    <dependency>
    	<groupId>org.springframework</groupId>
    	<artifactId>spring-jdbc</artifactId>
    	<version>4.3.12.RELEASE</version>
    </dependency>

### 2、 配置数据源、JdbcTemplate（Spring提供的简化数据库操作的工具）操作数据 ###

注：@EnableTransactionManagement 开启基于注解的事务管理功能；

方法 public PlatformTransactionManager transactionManager()用来配置事务管理器来控制事务；

package com.atguigu.tx;
    
    import java.beans.PropertyVetoException;
    
    import javax.sql.DataSource;
    
    import org.springframework.aop.aspectj.annotation.AnnotationAwareAspectJAutoProxyCreator;
    import org.springframework.aop.framework.autoproxy.InfrastructureAdvisorAutoProxyCreator;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.ComponentScan;
    import org.springframework.context.annotation.Configuration;
    import org.springframework.jdbc.core.JdbcTemplate;
    import org.springframework.jdbc.datasource.DataSourceTransactionManager;
    import org.springframework.transaction.PlatformTransactionManager;
    import org.springframework.transaction.annotation.AnnotationTransactionAttributeSource;
    import org.springframework.transaction.annotation.EnableTransactionManagement;
    import org.springframework.transaction.annotation.ProxyTransactionManagementConfiguration;
    import org.springframework.transaction.annotation.TransactionManagementConfigurationSelector;
    import org.springframework.transaction.annotation.Transactional;
    
    import com.mchange.v2.c3p0.ComboPooledDataSource;
    
    
    @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());
    	}
    	
    
    }

### 3、编写dao类 ###

package com.atguigu.tx;
    
    import java.util.UUID;
    
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.jdbc.core.JdbcTemplate;
    import org.springframework.stereotype.Repository;
    
    @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);
    		
    	}
    
    }

### 4、编写service类 ###

注：给方法上标注 @Transactional 表示当前方法是一个事务方法；如果方法中出现错误，则之前的执行内容进行回滚，以保证数据的一致性；

package com.atguigu.tx;
    
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.stereotype.Service;
    import org.springframework.transaction.annotation.Transactional;
    
    
    @Service
    public class UserService {
    	
    	@Autowired
    	private UserDao userDao;
    	
    	@Transactional
    	public void insertUser(){
    		userDao.insert();
    		//otherDao.other();xxx
    		System.out.println("插入完成...");
    	}
    
    }

### 5、 测试 ###

**情况一：事物正常执行**

package com.atguigu.test;
    
    import org.junit.Test;
    import org.springframework.context.annotation.AnnotationConfigApplicationContext;
    
    import com.atguigu.aop.MathCalculator;
    import com.atguigu.bean.Boss;
    import com.atguigu.bean.Car;
    import com.atguigu.bean.Color;
    import com.atguigu.bean.Red;
    import com.atguigu.config.MainConfigOfAOP;
    import com.atguigu.config.MainConifgOfAutowired;
    import com.atguigu.dao.BookDao;
    import com.atguigu.service.BookService;
    import com.atguigu.tx.TxConfig;
    import com.atguigu.tx.UserService;
    
    public class IOCTest_Tx {
    	
    	@Test
    	public void test01(){
    		AnnotationConfigApplicationContext applicationContext = 
    				new AnnotationConfigApplicationContext(TxConfig.class);
    	
    		UserService userService = applicationContext.getBean(UserService.class);
    		
    		userService.insertUser();
    		applicationContext.close();
    	}
    
    }

结果：

![2018111215381020.png][]

数据库插入之前：

![20181112153849935.png][]

插入之后：

![2018111215390282.png][]

**情况二：事物中出现错误**

如果方法中出现错误，则之前执行的内容需要回滚，以此来保证数据的安全

UserService.java添加int i = 10/0;则肯定汇报数据运算错误

![20181112154036911.png][]

再次执行测试方法：

发现方法已经报错，而且数据库中也没有插入行的数据，说明该方法事物添加成功；

![20181112154140907.png][]

[2018111215381020.png]: /images/20220417/1eff8a0bb18a435fac04e03e2e6ef812.png
[20181112153849935.png]: /images/20220417/6c627b6fe5ff4f66bef02b83ea7f934e.png
[2018111215390282.png]: /images/20220417/9ffa0d7087e94d23adc475522f7ef216.png
[20181112154036911.png]: /images/20220417/276fa594ddc34e82bf624da2aa4ff389.png
[20181112154140907.png]: /images/20220417/020313e625874351b58634df6a7e906f.png