上篇文章aop源码运行总结：
AOP总结目录--- Spring源码从入门到精通(二十四)
这篇文章主要介绍事务的作用 ：
事务可以在运行的业务发生异常时，保证这里面对数据库的操作都进行回滚，保证原子性，要么全部成功，要么全部失败，不会出现张三扣款5元成功，李四未收到5元转账。
先贴上项目目录：
一、事务环境搭建
先导入我们需要的数据源，数据库，springjdbc，数据源c3p0和 数据库 mysql我们之前已经导入过maven包，接下来导入springjdbc的maven：
<!--jdbc-->
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-jdbc</artifactId>
<version>4.3.12.RELEASE</version>
</dependency>
接下来创建新的配置类，里面加DataSource连接数据库，在创建JdbcTemplate对象加载入ioc容器。写一个dao和service，dao里面@Autowired注入jdbcTemplate连接数据库，sql操作数据。
/**
* 事务配置类
* 环境搭建：数据源，数据库、spring-jdbc
* 配置数据源：JdbcTemplate操作数据(spring提供的操作数据工具)
*
* @author keying
*/
@Configuration
@ComponentScan("com.alibaba.tx")
public class TxConfig {
@Bean
public DataSource dataSource() throws Exception {
ComboPooledDataSource dataSource = new ComboPooledDataSource();
dataSource.setDriverClass("com.mysql.jdbc.Driver");
dataSource.setJdbcUrl("jdbc:mysql://127.0.0.1:3306/testmac");
dataSource.setUser("root");
dataSource.setPassword("root");
return dataSource;
}
/**
* spring对@Configuration有特殊处理，给容器中加组件的方法，多次调用也只是在容器中找组件
*/
@Bean
public JdbcTemplate jdbcTemplate() throws Exception {
JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource());
return jdbcTemplate;
}
}
/**
* @author keying
*/
@Repository
public class UserDao {
@Autowired
private JdbcTemplate jdbcTemplate;
public void insert() {
String sql = "insert into user (uid,name,age) values (?,?,?)";
String name = UUID.randomUUID().toString().substring(0, 3);
jdbcTemplate.update(sql, "111", name, 12);
System.out.println("插入完成");
//当有异常时，事务让整个方法回滚
int i = 10/0;
}
}
/**
* @author keying
*/
@Service
public class UserService {
@Autowired
private UserDao userDao;
public void inert(){
userDao.insert();
}
}
junitTest加载我们的数据库配置类，并且从容器中获取到userService，调用autowired注入的dao，访问操作数据。
/**
* @author keying
*/
public class TestTx {
@Test
public void test() {
AnnotationConfigApplicationContext applicationContext = new AnnotationConfigApplicationContext(TxConfig.class);
UserService userService = applicationContext.getBean(UserService.class);
userService.inert();
applicationContext.close();
}
}
从结果打印可以看到，即使后面的运算抛出异常，但数据库依然插入成功，方法不会回滚。
二、事务开启
事务开启分位三步，缺一不可：
1、@EnableTransactionManagement开启事务。
2、给方法加上@Transactional注解。
3、配置事务管理控制事务。(注意事务管理要交给ioc容器管理)
/**
* 事务配置类
* 环境搭建：数据源，数据库、spring-jdbc
* 配置数据源：JdbcTemplate操作数据(spring提供的操作数据工具)
*
* 1、给方法上加上@Transactional
* 2、给配置文件加上@EnableTransactionManagement开启事务管理
* 3、配置事务管理器控制事务
*
* @author keying
*/
@EnableTransactionManagement
@Configuration
@ComponentScan("com.alibaba.tx")
public class TxConfig {
@Bean
public DataSource dataSource() throws Exception {
ComboPooledDataSource dataSource = new ComboPooledDataSource();
dataSource.setDriverClass("com.mysql.jdbc.Driver");
dataSource.setJdbcUrl("jdbc:mysql://127.0.0.1:3306/testmac");
dataSource.setUser("root");
dataSource.setPassword("root");
return dataSource;
}
/**
* spring对@Configuration有特殊处理，给容器中加组件的方法，多次调用也只是在容器中找组件
*/
@Bean
public JdbcTemplate jdbcTemplate() throws Exception {
JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource());
return jdbcTemplate;
}
/**
* 事务管理器
*/
@Bean
public PlatformTransactionManager transactionManager() throws Exception {
return new DataSourceTransactionManager(dataSource());
}
}
dao层加个@Transactional注解：
/**
* @author keying
*/
@Repository
public class UserDao {
@Autowired
private JdbcTemplate jdbcTemplate;
@Transactional
public void insert() {
String sql = "insert into user (uid,name,age) values (?,?,?)";
String name = UUID.randomUUID().toString().substring(0, 3);
jdbcTemplate.update(sql, "111", name, 12);
System.out.println("插入完成");
//当有异常时，事务让整个方法回滚
int i = 10 / 0;
try {
} catch (Exception e) {
}
}
}
开启之后可以看到，当运算异常时，数据库并不会插入数据成功。
