Spring事务管理-实现@Transactional事务回滚

59 阅读 0 评论 39 点赞

我是靠谱客的博主发嗲故事，最近开发中收集的这篇文章主要介绍Spring事务管理-实现@Transactional事务回滚，觉得挺不错的，现在分享给大家，希望可以做个参考。

概述

事务的概念

（1）什么是事务？
事务的作用:保证一组操作在进行过程中要么同时成功,要么同时失败.
1.目的:保持多并发情况下数据一致.
2.目的:如果出现错误的操作可以进行改正
（2）什么是事务的特性？
事务的特性(ACID)
原子性: 一个事务是最小的执行单元,不可以分割
一致性: 事务指定的前后,数据要保持一致.
持久性: 事务一旦提交或回滚,在数据库中持久的改变.
隔离性: 隔离性用来保证多个用户来操作数据库的同一份数据,不会受到相关干扰的特性.

事务的术语

（1）什么是事务的隔离级别？
在这里插入图片描述
（2）并发问题
》（1）脏读: 一个事务读到了另一个事务的还没有提交数据.

》（2）不可重复读一个事务中多次读到的数据不一致.一个事务读到了另一个事务修改后的数据.
在这里插入图片描述

》（3）幻读(虚读): 一个事务读到了insert的数据.

在这里插入图片描述

spring的事务实现方式:

1.编程式事务管理
2.声明式事务管理 (使用aop xml 或注解的配置即可实现事务管理)
（2）准备数据库
（3）POM.xml

sql

create database day23db ;
use day23db;
create table `account` (
  `id` int(8) not null  primary key auto_increment,
  `name` varchar(64) default null,
  `money` double default null
) 
insert into account values(null,'jack',1000);
insert into account values(null,'rose',1000);
# 转账
update account set money=money-500 where `name`='jack';
update account set money=money+500 where `name`='rose';

pom.xml

   <dependencies>
        <!-- jdbc-->
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <version>5.1.46</version>
        </dependency>
        <!-- ioc-->
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-context</artifactId>
            <version>5.2.9.RELEASE</version>
        </dependency>
        <!-- jdbctemplate-->
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-jdbc</artifactId>
            <version>5.2.9.RELEASE</version>
        </dependency>
        <!-- test-->
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-test</artifactId>
            <version>5.2.9.RELEASE</version>
        </dependency>
        <dependency>
            <groupId>junit</groupId>
            <artifactId>junit</artifactId>
            <version>4.12</version>
        </dependency>
       <!-- aop-->
        <dependency>
            <groupId>org.aspectj</groupId>
            <artifactId>aspectjweaver</artifactId>
            <version>1.7.2</version>
        </dependency>
    </dependencies>

编写TestAccountService

@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration("classpath:applicationContext.xml")
public class TestAccountServiceImpl {
    @Autowired
    IAccountService service ;
    @Test
    public void test01(){
        //业务对象
        //IAccountService service = new AccountServiceImpl();
        //调用方法 translate(一个人转出，另一个转入，金额)
        service.translate("jack","rose",500.00);
    }
}

IAccountService

public interface IAccountService {
    //转账本身就是从一个账户减钱，另一个账户加钱
    void translate(String from, String to, double money);
}

AccountDaoImpl


@Repository
public class AccountDaoImpl implements IAccountDao {
    @Autowired
    JdbcTemplate jdbcTemplate;
 
    @Override
    public void translateOut(String account, double v) {
        jdbcTemplate.update("update account set money=money-? where `name`=?",v,account);
    }

    @Override
    public void translateIn(String account, double v) {
        jdbcTemplate.update("update account set money=money+? where `name`=?",v,account);
    }
}
public interface IAccountDao {
    @Deprecated
    void update(String account, double v);
    void translateOut(String account, double v);
    void translateIn(String account, double v);
}

applicationContext.xml

<!-- 数据源-->
    <bean id="dataSource" class="org.springframework.jdbc.datasource.DriverManagerDataSource">
        <property name="url"
                  value="jdbc:mysql://localhost:3306/day23db?serverTimezone=GMT%2B8&amp;useUnicode=true&amp;characterEncoding=UTF-8"/>
        <property name="username" value="root"/>
        <property name="password" value="123456"/>
    </bean>
    <!-- jdbcTemplate-->
    <bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
        <constructor-arg name="dataSource" ref="dataSource"/>
    </bean>
    <!--1.要在bean.xml中创建spring的平台事务管理器  (DataSourceTransactionManager   )  注入dataSource-->
    <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
        <property name="dataSource" ref="dataSource"/>
    </bean>

    <tx:annotation-driven proxy-target-class="false" transaction-manager="transactionManager" />

    <!--包扫描创建对象 扫描包与它下面的子包中的所有类-->
    <context:component-scan base-package="com.qst"/>

AccountServiceImpl

@Service
//@Transactional(isolation = Isolation.REPEATABLE_READ ,propagation = Propagation.REQUIRED ,timeout = -1)
public class AccountServiceImpl implements IAccountService{
    @Autowired
    IAccountDao dao ;
    @Transactional(isolation = Isolation.REPEATABLE_READ ,propagation = Propagation.REQUIRED ,timeout = -1)
    @Override
    public void translate(String from, String to, double money) {
        //创建AccountDaoImpl
        //AccountDaoImpl dao = new AccountDaoImpl();
        //调用方法

        dao.translateOut(from,money);
        System.out.println(1/0); //断电
        dao.translateIn(to,money);
        System.out.println("--translate");
    }
}