- 事务是数据库 *** 作最基本单元,逻辑上一组 *** 作,要么都成功,如果有一个失败所有 *** 作都失败
- 原子性 : *** 作不可分割,数据要么一起成功,要么一起失败,即事务提交(commit)和事务回滚(rollback)。
- 一致性 : *** 作之前和 *** 作之后总量不变
- 隔离性 : 多事务 *** 作之间不会互相产生影响
- 持久性 : 一个事务一旦提交,它对数据库中数据的改变就应该是持久性的
例子:银行转账 * lucy 转账 100 元 给 mary * lucy 少 100, mary 多 100
(1) 创建数据库表,添加记录
(2) 创建service ,搭建dao,完成对象创建和注入关系
- service注入dao,在dao注入JdbcTemplate,在JdbcTemplate注入DataSource
service:
@Service
public class UserService {
@Autowired
private UserDao userDao;
}
dao:
public interface UserDao {
}
daoImpl:
@Repository
public class UserDaoImpl implements UserDao{
@Autowired
private JdbcTemplate jdbcTemplate;
}
(3) 在dao中创建方法:多钱和少钱,在service创建转账的方法
@Repository
public class UserDaoImpl implements UserDao {
@Autowired
private JdbcTemplate jdbcTemplate;
@Override
public void addMoney() {
String sql="update t_account set money=money+? where username=?";
jdbcTemplate.update(sql,100,"mary");
}
@Override
public void reduceMoney() {
String sql="update t_account set money=money-? where username=?";
jdbcTemplate.update(sql,100,"lucy");
}
}
@Service
public class UserService {
@Autowired
private UserDao userDao;
public void accountMoney(){
userDao.reduceMoney();
userDao.addMoney();
}
}
4.如果代码在执行过程中出现异常,如何解决
异常:
public void accountMoney(){
userDao.reduceMoney();
int i=10/0;
userDao.addMoney();
}
解决方法:
通过事务进行解决
事务的 *** 作过程:
- 第一步,开启事务
- 第二步,进行业务 *** 作,对异常进行捕获
- 第三步,没有发生异常,提交事务
- 第四步,出现异常,事务回滚,回到业务 *** 作之前的状态
(1) 事务建议添加到Service层(业务逻辑层)
(2) 在Spring进行事务管理 *** 作:
- 编程式事务管理 – 一般不用
- 声明式事务管理 – 常用
(3) 声明式事务管理:
- 基于注解方式 – 常用
- 基于xml配置文件方式
(4) Spring中进行声明式事务管理,底层使用AOP原理
(5) Spring事务管理API
- 提供一个接口,代表事务管理器,针对不同的框架提供不同的实现类
(1) 在spring中配置文件配置事务管理器
<bean id="transactionalManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
<property name="dataSource" ref="dataSource">property>
bean>
(2) 在Spring配置文件中开启事务注解
-
引入名称空间tx
-
<beans ... xmlns:tx="http://www.springframework.org/schema/tx" xsi:schemaLocation="... http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx.xsd ">
-
开启事务注解
-
<tx:annotation-driven transaction-manager="transactionalManager">tx:annotation-driven>
(3) 在Service 类上面(或者service类里面方法上面)添加事务注解
-
@Transactional , 这个注解添加到类上面,也可以添加方法上面
- 如果把这个注解添加类上面,这个类里面所有的方法都添加事务
- 如果把这个注解添加到方法上面,为这个方法添加事务
@Service @Transactional public class UserService {...}
在 service 类上面添加注解@Transactional,在这个注解里面可以配置事务相关参数
参数 | 含义 |
---|---|
propagation | 事务传播行为 |
ioslation | 事务隔离级别 |
timeout | 超时时间 |
readOnly | 是否只读 |
rollbackFor | 回滚 |
noRollbackFor | 不回滚 |
(1) propagation : 事务传播行为
事务传播行为:多事务方法直接进行调用,这个过程中事务是如何进行管理的(理解:在多事务方法调用的时候,指定事务的管理方式)
传播属性 | 描述 |
---|---|
Propagation.REQUIRED | 如果当前没有事务,就创建一个新事务;如果当前存在事务,就加入该事务 |
Propagation.REQUIRES_NEW | 创建新事务,无论当前存不存在事务,都创建新事务。 |
Propagation.SUPPORTS | 支持当前事务,如果当前存在事务,就加入该事务,如果当前不存在事务,就以非事务执行。 |
Propagation.NOT_SUPPORTED | 以非事务方式执行 *** 作,如果当前存在事务,就把当前事务挂起。 |
Propagation.MANDATORY | 支持当前事务,如果当前存在事务,就加入该事务,如果当前不存在事务,就抛出异常。 |
Propagation.NEVER | 以非事务方式执行,如果当前存在事务,则抛出异常。 |
Propagation.NESTED | 如果当前存在事务,则在嵌套事务内执行。如果当前没有事务,则按REQUIRED属性执行。 |
@Service
@Transactional(propagation = Propagation.REQUIRED)
public class UserService {...}
(2) ioslation : 事务隔离级别
-
默认为 REPEATABLE READ
-
事务隔离性:多事务 *** 作之间不会产生影响.
-
不考虑隔离性会出现:脏读,不可重复读,虚(幻)读
- 脏读:一个未提交事务读取到另一个为提交事务的数据
- 不可重复读:一个未提交事务读取到另一提交事务修改数据
- 虚读:一个未提交事务读取到另一提交事务添加数据
-
通过设置事务隔离级别,解决读问题
隔离级别 | 脏读 | 不可重读读 | 幻读 |
---|---|---|---|
READ_UNCOMMITTED(读为提交) | ✔ | ✔ | ✔ |
READ_COMMITTED(读已提交) | ❌ | ✔ | ✔ |
REPEATABLE_READ(可重复读) | ❌ | ❌ | ✔ |
SERIALIZABLE(串行化) | ❌ | ❌ | ❌ |
@Service
@Transactional(propagation = Propagation.REQUIRED,isolation = Isolation.REPEATABLE_READ)
public class UserService {...}
(3) timeout : 超时时间
- 事务需要在一定时间内进行提交,如果不提交进行回滚
- 默认值为-1,设置时间以秒单位进行计算
(4) readOnly : 是否只读
- 读 : 查询 *** 作 , 写 : 添加修改删除 *** 作
- readOnly 默认值 false,表示可以查询,可以添加修改删除 *** 作
- 设置 readOnly 值是 true,设置成 true 之后,只能查询
(5) rollbackFor : 回滚
- 设置出现哪些异常进行事务回滚
(6) noRollbackFor : 不回滚
- 设置出现哪些异常不进行事务回滚
-
第一步 配置事务管理器
-
<bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager"> <property name="dataSource" ref="dataSource">property> 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.syy.spring5.service.UserService.*(..))"/> <aop:advisor advice-ref="txadvice" pointcut-ref="pt"/> aop:config>
-
创建配置类,使用配置类替代xml配置文件
-
@Configuration @ComponentScan(basePackages = "com.syy") @EnableTransactionManagement public class TxConfig { //创建数据库连接池 @Bean public DruidDataSource getDruidDataSource() { DruidDataSource dataSource = new DruidDataSource(); dataSource.setDriverClassName("com.mysql.jdbc.Driver"); dataSource.setUrl("jdbc:mysql://localhost:13306/user"); dataSource.setUsername("root"); dataSource.setPassword("rootroot"); return dataSource; } //创建JdbcTemplate对象 @Bean public JdbcTemplate getJdbcTemplate(DataSource dataSource){ //到IOC容器中根据类型找到dataSource JdbcTemplate jdbcTemplate = new JdbcTemplate(); //注入dataSource jdbcTemplate.setDataSource(dataSource); return jdbcTemplate; } //创建事务管理器 @Bean public DataSourceTransactionManager getDataSourceTransactionManager(DataSource dataSource){ DataSourceTransactionManager transactionManager = new DataSourceTransactionManager(); transactionManager.setDataSource(dataSource); return transactionManager; } }
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)