05.事务管理
- 事务是数据库操作最基本单位,要么都成功,要么都失败。
- 典型场景:转账
- 事务四个特性 ACID:原子性,一致性,隔离性,持久性。
- Spring 事务管理有两种方式:编程式事务管理 和 声明式事务管理,一般使用声明式事务管理,底层使用 AOP 原理。
- 声明式事务管理有两种方式:基于 xml 配置方式 和 基于注解方式,一般使用注解方式。
- Spring 事务管理提供了一个接口,叫做事务管理器,这个接口针对不同的框架提供不同的实现类。 对于使用 JdbcTemplate 进行数据库交互,则使用 DataSourceTransactionManager 实现类,如果整合 Hibernate 框架则使用 HibernateTransactionManager 实现类,具体情况具体使用。
1.注解实现声明式事务管理
xml
<!-- 数据库连接池 -->
<bean id="dataSource" class="com.alibaba.druid.pool.DruidDataSource"
destroy-method="close">
<property name="url" value="jdbc:mysql://localhost:3306/book" />
<property name="username" value="root" />
<property name="password" value="000000" />
<property name="driverClassName" value="com.mysql.jdbc.Driver" />
</bean>
<!--创建JdbcTemplate对象-->
<bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
<!--注入数据库连接池-->
<property name="dataSource" ref="dataSource"></property>
</bean>
<!--创建事务管理器-->
<bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
<property name="dataSource" ref="dataSource"/>
</bean>
<!--开启事务注解-->
<tx:annotation-driven transaction-manager="transactionManager"></tx:annotation-driven>
在 service 类上面或者 service 类的方法上面添加事务注解 @Transactional
- 如果把
@Transactional
添加在类上面,这个类里面所有方法都添加事务。 - 如果只是添加在方法上面,则只为这个方法添加事务。
java
@Service
@Transactional
public class UserService {}
声明式事务管理的参数配置:
propagation:事务传播行为,总共有 7 种,这一块讲的不是很清楚
isolation:事务隔离级别 有三个读问题:脏读,不可重复读,虚读(幻读)。 设置隔离级别,解决读问题:
脏读 不可重复读 虚读 READ UNCOMMITED(读未提交) 有 有 有 READ COMMITED(读已提交) 无 有 有 REPEATABLE READ(可重复读) 无 无 有 SERIALIZABLE(串行化) 无 无 无 timeout:超时时间
- 事务需要在一定时间内进行提交,超过时间后回滚。
- 默认值是-1,设置时间以秒为单位。
- readOnly:是否只读
- 默认值为 false,表示可以查询,也可以增删改。
- 设置为 true,只能查询。
- rollbackFor:回滚,设置出现哪些异常进行事务回滚。
- noRollbackFor:不回滚,设置出现哪些异常不进行事务回滚。
java
@Service
@Transactional(propagation = Propagation.REQUIRED,isolation = Isolation.READ_COMMITTED)
public class AccountService {}
完全注解实现声明式事务管理:
配置类:
java
@Configuration //配置类
@ComponentScan(basePackages = "com.oymn.spring5") //开启组件扫描
@EnableTransactionManagement //开启事务
public class Config {
//创建数据库连接池
@Bean
public DruidDataSource getDruidDataSource(){
DruidDataSource druidDataSource = new DruidDataSource();
druidDataSource.setDriverClassName("com.mysql.jdbc.Driver");
druidDataSource.setUrl("jdbc:mysql://localhost:3306/book");
druidDataSource.setUsername("root");
druidDataSource.setPassword("000000");
return druidDataSource;
}
//创建JdbcTemplate对象
@Bean
public JdbcTemplate getJdbcTemplate(DataSource dataSource){
JdbcTemplate jdbcTemplate = new JdbcTemplate();
jdbcTemplate.setDataSource(dataSource);
return jdbcTemplate;
}
//创建事务管理器
@Bean
public DataSourceTransactionManager getDataSourceTransactionManager(DataSource dataSource){
DataSourceTransactionManager transactionManager = new DataSourceTransactionManager();
transactionManager.setDataSource(dataSource);
return transactionManager;
}
}
java
@Service
public class AccountService {
@Autowired
private AccountDao accountDao;
@Transactional
public void accountMoney(){
accountDao.add();
//int i=1/0; //用来模拟转账失败
accountDao.reduce();
}
}
2.xml 实现声明式事务管理
xml
<context:component-scan base-package="com.oymn"></context:component-scan>
<!-- 数据库连接池 -->
<bean id="dataSource" class="com.alibaba.druid.pool.DruidDataSource"
destroy-method="close">
<property name="url" value="jdbc:mysql://localhost:3306/book" />
<property name="username" value="root" />
<property name="password" value="000000" />
<property name="driverClassName" value="com.mysql.jdbc.Driver" />
</bean>
<!--创建JdbcTemplate对象-->
<bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
<!--注入数据库连接池-->
<property name="dataSource" ref="dataSource"></property>
</bean>
<!--创建事务管理器-->
<bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
<property name="dataSource" ref="dataSource"/>
</bean>
<!--配置事务通知-->
<tx:advice id="txadvice">
<!--配置事务参数-->
<tx:attributes>
<tx:method name="accountMoney" propagation="REQUIRED" />
</tx:attributes>
</tx:advice>
<!--配置切入点和切面-->
<aop:config>
<!--配置切入点-->
<aop:pointcut id="pt" expression="execution(* com.oymn.spring5.Service.*.*(..))"/>
<!--配置切面-->
<aop:advisor advice-ref="txadvice" pointcut-ref="pt"/>
</aop:config>