上篇文章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) { } } }
开启之后可以看到，当运算异常时，数据库并不会插入数据成功。
