(三)、声明式事务
1.声明式事务 - 环境搭建
(1).导入依赖
<!-- Spring包 ->IOC --> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-context</artifactId> <version>4.3.12.RELEASE</version> </dependency> <!-- C3P0数据包 ->数据源 --> <dependency> <groupId>com.mchange</groupId> <artifactId>c3p0</artifactId> <version>0.9.5.2</version> </dependency> <dependency> <groupId>mysql</groupId> <artifactId>mysql-connector-java</artifactId> <version>5.1.6</version> </dependency> <!-- Spring切面的包 ->aop --> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-aspects</artifactId> <version>4.3.12.RELEASE</version> </dependency> <!-- Spring-JDBC -> jdbcTemplate --> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-jdbc</artifactId> <version>4.3.12.RELEASE</version> </dependency>
(2).实体类和业务层
1.实体类
package com.jsxs.bean; /** * @Author Jsxs * @Date 2023/8/22 14:27 * @PackageName:com.jsxs.bean * @ClassName: Admin * @Description: TODO * @Version 1.0 */ public class Admin { private int id; private String name; private String password; public Admin() { } public Admin(int id, String name, String password) { this.id = id; this.name = name; this.password = password; } public int getId() { return id; } public void setId(int id) { this.id = id; } public String getName() { return name; } public void setName(String name) { this.name = name; } public String getPassword() { return password; } public void setPassword(String password) { this.password = password; } @Override public String toString() { return "Admin{" + "id=" + id + ", name='" + name + '\'' + ", password='" + password + '\'' + '}'; } }
2.Dao层:
package com.jsxs.mapper; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.jdbc.core.JdbcTemplate; import org.springframework.stereotype.Repository; import javax.annotation.Resource; /** * @Author Jsxs * @Date 2023/8/22 14:28 * @PackageName:com.jsxs.mapper * @ClassName: AdminMapper * @Description: TODO * @Version 1.0 */ @Repository public class AdminMapper { @Resource private JdbcTemplate jdbcTemplate; public void add(){ String sql="insert into admin(name,password) values(?,?)"; int i = jdbcTemplate.update(sql,222,222); // 后面的是参数也就是占位符,占位符有几个,参数也就有几个 if (i>0){ System.out.println("添加数据成功!!"); }else { System.out.println("添加数据失败!!"); } } }
3.业务层
package com.jsxs.service; import com.jsxs.mapper.AdminMapper; import org.springframework.stereotype.Service; import javax.annotation.Resource; /** * @Author Jsxs * @Date 2023/8/22 14:30 * @PackageName:com.jsxs.service * @ClassName: AdminServer * @Description: TODO * @Version 1.0 */ @Service public class AdminServer { @Resource AdminMapper adminMapper; public void insert(){ adminMapper.add(); } }
4.配置类
package com.jsxs.tx; import com.mchange.v2.c3p0.ComboPooledDataSource; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.ComponentScan; import org.springframework.context.annotation.Configuration; import org.springframework.context.annotation.PropertySource; import org.springframework.jdbc.core.JdbcTemplate; import javax.sql.DataSource; import java.beans.PropertyVetoException; /** * @Author Jsxs * @Date 2023/8/22 14:06 * @PackageName:com.jsxs.tx * @ClassName: TxConfig * @Description: TODO 声明式事务 * 1. 导入相关依赖 : 数据源、数据库驱动、Spring-JDBC->(提供了JDBCTemplate) * 2.配置数据源,JDBCTemplate(Spring提供的简化数据库操作的工具)操作数据库 * @Version 1.0 */ @Configuration @ComponentScan(value = "com.jsxs") @PropertySource(value = "classpath:db.properties") public class TxConfig { // 1.配置我们的数据源 @Bean public DataSource dataSource() throws PropertyVetoException { // 1.1.c3p0数据源 ComboPooledDataSource dataSource = new ComboPooledDataSource(); dataSource.setJdbcUrl("jdbc:mysql://127.0.0.1:3306/demo1"); dataSource.setUser("root"); dataSource.setPassword("121788"); dataSource.setDriverClass("com.mysql.jdbc.Driver"); return dataSource; } // 2.我们设置JDBC的模板,又因为这个模板需要数据源,所以我们要存放我们的数据源。又因为在配置类中的参数是先从IOC容器中拿取的,所以我们直接设置成参数即可。 @Bean public JdbcTemplate jdbcTemplate(DataSource dataSource){ return new JdbcTemplate(dataSource); } }
5.测试
package com.jsxs.Test; import com.jsxs.service.AdminServer; import com.jsxs.tx.TxConfig; import org.springframework.context.annotation.AnnotationConfigApplicationContext; /** * @Author Jsxs * @Date 2023/8/22 14:45 * @PackageName:com.jsxs.Test * @ClassName: AOP_TX * @Description: TODO * @Version 1.0 */ public class AOP_TX { public static void main(String[] args) { AnnotationConfigApplicationContext applicationContext = new AnnotationConfigApplicationContext(TxConfig.class); for (String beanDefinitionName : applicationContext.getBeanDefinitionNames()) { System.out.println(beanDefinitionName); } AdminServer server = applicationContext.getBean(AdminServer.class); server.insert(); } }
2.声明式事务 - 测试成功
(1).遇见问题
* 1. 导入相关依赖 : 数据源、数据库驱动、Spring-JDBC->(提供了JDBCTemplate) * 2.配置数据源,JDBCTemplate(Spring提供的简化数据库操作的工具)操作数据库 * ⭐ 3.给方法上标注@Transactional 表示当前方法是一个事务方法. * ⭐ 4.@EnableTransactionManagement 需要放在配置类进行开启注解的事务 * ⭐ 5.添加PlatformTransactionManager这个组件
我们在插入的方法中故意设置一个异常的操作,然后我们执行这个方法但是我们发现我们并不会发生事务回滚(即 失败都失败,成功都成功!);
(2).解决问题 -> 事务型(成功全成功_失败全失败)
package com.jsxs.service; import com.jsxs.mapper.AdminMapper; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import javax.annotation.Resource; /** * @Author Jsxs * @Date 2023/8/22 14:30 * @PackageName:com.jsxs.service * @ClassName: AdminServer * @Description: TODO * @Version 1.0 */ @Service public class AdminServer { @Resource AdminMapper adminMapper; @Transactional // 声明标注事务的注解⭐ public void insert(){ adminMapper.add(); // 2.故意制造异常 ⭐⭐ System.out.println(1/0); } }
- 基于XML文件的
- 基于注解
1.业务层添加上事务注解
package com.jsxs.service; import com.jsxs.mapper.AdminMapper; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import javax.annotation.Resource; /** * @Author Jsxs * @Date 2023/8/22 14:30 * @PackageName:com.jsxs.service * @ClassName: AdminServer * @Description: TODO * @Version 1.0 */ @Service public class AdminServer { @Resource AdminMapper adminMapper; @Transactional public void insert(){ adminMapper.add(); System.out.println(1/0); } }
2.需要在配置类上开启注解支持
package com.jsxs.tx; import com.mchange.v2.c3p0.ComboPooledDataSource; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.ComponentScan; import org.springframework.context.annotation.Configuration; import org.springframework.context.annotation.PropertySource; import org.springframework.jdbc.core.JdbcTemplate; import org.springframework.transaction.annotation.EnableTransactionManagement; import javax.sql.DataSource; import java.beans.PropertyVetoException; /** * @Author Jsxs * @Date 2023/8/22 14:06 * @PackageName:com.jsxs.tx * @ClassName: TxConfig * @Description: TODO 声明式事务 * 1. 导入相关依赖 : 数据源、数据库驱动、Spring-JDBC->(提供了JDBCTemplate) * 2.配置数据源,JDBCTemplate(Spring提供的简化数据库操作的工具)操作数据库 * 3.给方法上标注@Transactional 表示当前方法是一个事务方法. * 4.@EnableTransactionManagement 需要放在配置类进行开启注解的事务 * @Version 1.0 */ @Configuration @ComponentScan(value = "com.jsxs") @PropertySource(value = "classpath:db.properties") @EnableTransactionManagement ⭐ public class TxConfig { // 1.配置我们的数据源 @Bean public DataSource dataSource() throws PropertyVetoException { // 1.1.c3p0数据源 ComboPooledDataSource dataSource = new ComboPooledDataSource(); dataSource.setJdbcUrl("jdbc:mysql://127.0.0.1:3306/demo1"); dataSource.setUser("root"); dataSource.setPassword("121788"); dataSource.setDriverClass("com.mysql.jdbc.Driver"); return dataSource; } // 2.我们设置JDBC的模板,又因为这个模板需要数据源,所以我们要存放我们的数据源。又因为在配置类中的参数是先从IOC容器中拿取的,所以我们直接设置成参数即可。 @Bean public JdbcTemplate jdbcTemplate(DataSource dataSource){ return new JdbcTemplate(dataSource); } }
3.进行测试的操作
package com.jsxs.Test; import com.jsxs.service.AdminServer; import com.jsxs.tx.TxConfig; import org.springframework.context.annotation.AnnotationConfigApplicationContext; /** * @Author Jsxs * @Date 2023/8/22 14:45 * @PackageName:com.jsxs.Test * @ClassName: AOP_TX * @Description: TODO * @Version 1.0 */ public class AOP_TX { public static void main(String[] args) { AnnotationConfigApplicationContext applicationContext = new AnnotationConfigApplicationContext(TxConfig.class); for (String beanDefinitionName : applicationContext.getBeanDefinitionNames()) { System.out.println(beanDefinitionName); } AdminServer server = applicationContext.getBean(AdminServer.class); server.insert(); } }
4.结果我们发现缺少一个组件 PlatformTransactionManager
5. 给IOC容器中添加这个组件
package com.jsxs.tx; import com.mchange.v2.c3p0.ComboPooledDataSource; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.ComponentScan; import org.springframework.context.annotation.Configuration; import org.springframework.context.annotation.PropertySource; import org.springframework.jca.cci.connection.CciLocalTransactionManager; import org.springframework.jdbc.core.JdbcTemplate; import org.springframework.jdbc.datasource.DataSourceTransactionManager; import org.springframework.transaction.PlatformTransactionManager; import org.springframework.transaction.annotation.EnableTransactionManagement; import javax.sql.DataSource; import java.beans.PropertyVetoException; /** * @Author Jsxs * @Date 2023/8/22 14:06 * @PackageName:com.jsxs.tx * @ClassName: TxConfig * @Description: TODO 声明式事务 * 1. 导入相关依赖 : 数据源、数据库驱动、Spring-JDBC->(提供了JDBCTemplate) * 2.配置数据源,JDBCTemplate(Spring提供的简化数据库操作的工具)操作数据库 * 3.给方法上标注@Transactional 表示当前方法是一个事务方法. * 4.@EnableTransactionManagement 需要放在配置类进行开启注解的事务 * 5.添加PlatformTransactionManager这个组件 * @Version 1.0 */ @Configuration @ComponentScan(value = "com.jsxs") @PropertySource(value = "classpath:db.properties") @EnableTransactionManagement // ⭐ public class TxConfig { // 1.配置我们的数据源 @Bean public DataSource dataSource() throws PropertyVetoException { // 1.1.c3p0数据源 ComboPooledDataSource dataSource = new ComboPooledDataSource(); dataSource.setJdbcUrl("jdbc:mysql://127.0.0.1:3306/demo1"); dataSource.setUser("root"); dataSource.setPassword("121788"); dataSource.setDriverClass("com.mysql.jdbc.Driver"); return dataSource; } // 2.我们设置JDBC的模板,又因为这个模板需要数据源,所以我们要存放我们的数据源。又因为在配置类中的参数是先从IOC容器中拿取的,所以我们直接设置成参数即可。 @Bean public JdbcTemplate jdbcTemplate(DataSource dataSource){ return new JdbcTemplate(dataSource); } @Bean // 在配置类中的@Bean注解的方法参数,参数默认是从IOC容器中赋值的 ⭐⭐ public PlatformTransactionManager platformTransactionManager(DataSource dataSource){ return new DataSourceTransactionManager(dataSource); } }
3.声明式事务原理
* 2.事务原理 * (1).@EnableTransactionManagement * 利用 TransactionManagementConfigurationSelector 给容器中会导入批量组件 * 导入两个组件 * (1).AutoProxyRegistrar (2).ProxyTransactionManagementConfiguration * (2).细聊 AutoProxyRegistrar * 给容器中注入一个组件,利用后置处理器机制在对象创建以后,包装对象,返回一个代理对象(增强器),代理方法执行方法利用拦截器链进行调用 * * (3).细聊 ProxyTransactionManagementConfiguration * 1.给事务注册一个事务增强器->事务增强器要用事务注解的信息 * 2.事务拦截器 * (1).先获取事务相关的属性 * (2).在获取PlatformTransactionManager,如果事务先没有添加指定任何 * 最终会从容器中按照类型获取一个PlateFormTransactionManager; * (3).执行目标方法 * 如果异常,获取到事务管理器,利用事务管理回滚操作 * 如果正常,利用事务管理器,提交事务控制