Spring声明式事务

2020-04-22 本文已影响0人小杨小杨神采飞杨

模拟一个买书结账的环境
环境搭建：
bookDao类，与数据库交互

@Repository
public class bookDao {
    @Autowired
    private JdbcTemplate template;

    //根据isbn获取价格
    public int getPrice(String isbn) {
        String sql = "select price from book where isbn = ?";
        Integer price = template.queryForObject(sql, Integer.class, isbn);
        return price;
    }

    //根据价格减少钱
    public void reduceMoney(int price,String username) {
        String sql = "update account set balance = balance - ? where username = ?";
        template.update(sql,price,username);
    }

    //根据isbn减少库存
    public void reduceStock(String isbn,int num) {
        String sql = "update book_stock set stock = stock - ? where isbn = ?";
        template.update(sql,num,isbn);
    }
}

bookService类，逻辑操作

@Service
public class bookService {
    @Autowired
    private bookDao dao;

    //实现结账操作
    public void pay() throws IOException {
        Scanner s = new Scanner(System.in);
        System.out.print("请输入您的姓名：");
        String username = s.next();
        System.out.print("请输入购买的书籍编号：");
        String isbn = s.next();
        System.out.print("请输入购买数量：");
        int num = s.nextInt();

        System.out.println("正在结账...");

        int price = dao.getPrice(isbn);
        dao.reduceMoney((price*num),username);
        dao.reduceStock(isbn,num);

        System.out.println("购买成功");
    }
}

ioc容器xml配置，开启注解配置

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:context="http://www.springframework.org/schema/context"
       xmlns:aop="http://www.springframework.org/schema/aop"
       xsi:schemaLocation="http://www.springframework.org/schema/beans
        https://www.springframework.org/schema/beans/spring-beans.xsd
        http://www.springframework.org/schema/context
        https://www.springframework.org/schema/context/spring-context.xsd
        http://www.springframework.org/schema/aop
        https://www.springframework.org/schema/aop/spring-aop.xsd">

    <!--扫描指定包下配置了注解的bean-->
    <context:component-scan base-package="cn.yzx.dao"/>
    <context:component-scan base-package="cn.yzx.service"/>
    <!--开启注解配置-->
    <context:annotation-config/>
    <!--引入外部配置文件-->
    <context:property-placeholder location="classpath:db.properties"/>
    
    <!--获取druid数据库连接池-->
    <bean id="DataSource" class="com.alibaba.druid.pool.DruidDataSource">
        <property name="driverClassName" value="${driverClassName}"/>
        <property name="url" value="${url}"/>
        <property name="username" value="${jdbc.username}"/>
        <property name="password" value="${password}"/>
    </bean>

    <!--注册JdbcTemplate-->
    <bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
        <constructor-arg name="dataSource" ref="DataSource"/>
    </bean>
</beans>

测试类

public class mytest {
    public static void main(String[] args) throws IOException {
        ApplicationContext context = new ClassPathXmlApplicationContext("applicationContext.xml");
        bookService bean = context.getBean(bookService.class);
        bean.pay();
    }
}

实现需求，用户买了书，根据买书的数量以及书的价格，减少用户的钱，以及书的库存

无事务
显而易见一个很严重的问题，如果在减少用户钱、库存减少两次操作中，后执行的一个除了错误，则前一个执行的结果无法撤回，比如，我这里是用户先付钱再减少库存，在减少库存的sql语句中人为的制造错误

制造错误
此时，钱已经减少了，但是库存因为错误，并没有减少
运行结果
用户的钱
书的库存
此时，我们就需要使用事务，事务可以保证所有操作都正常执行数据库数据才会发生改变，之前我们使用的是手动的事务，较为麻烦，且在本案例中有多次数据库连接，要甄别他们也十分麻烦，而spring的AOP功能与事务的步骤基本吻合，所以可以使用AOP来实现事务，但是自己写AOP也很麻烦，所以spring为我们写好的基于AOP的声明式事务
使用声明式事务
首先修改IOC容器的配置文件，添加一下几行

xml

注意，使用tx需要导入tx的名称空间依赖