ICode9
精准搜索请尝试： 精确搜索
首页
编程语言>
数据库
系统相关
互联网
其他分享
Python
Java
JavaScript
android
PHP
首页 > 编程语言> 文章详细

Java -- Spring学习笔记7、Spring事务

2021-05-15 18:05:23  阅读：119  来源： 互联网

标签：事务 Java nums -- Spring goodsDao int goodId public


1、Spring的事务管理

事务原本是数据库中的概念，在Dao层。但一般情况下，需要将事务提升到业务层，即Service层。这样做是为了能够使用事务的特性来管理具体的业务。

  • 在Spring中通常可以通过以下两种方式来实现对事务的管理：

    • 使用Spring的事务注解管理事务
    • 使用AspectJ的AOP配置管理事务

2、事务管理器接口

事务管理器是 PlatformTransactionManager 接口对象。其主要用于完成事务的提交、回滚，及获取事务的状态信息。

2.1、常用的两个实现类

  • PlatformTransactionManager接口有两个常用的实现类：

    • DataSourceTransactionManager：使用JDBC或 MyBatis进行数据库操作时使用。
    • HibernateTransactionManager：使用 Hibernate 进行持久化数据时使用。

3、事务定义接口

事务定义接口TransactionDefinition中定义了事务描述相关的三类常量：事务隔离级别、事务传播行为、事务默认超时时限，及对它们的操作。

3.1、定义了五个事务隔离级别常量

  • 这些常量均是以 ISOLATION_开头。即形如 ISOLATION_XXX。

    • DEFAULT：采用DB默认的事务隔离级别。MySql的默认为 REPEATABLE_READ；Oracle默认为READ_COMMITTED。
    • READ_UNCOMMITTED：读未提交。未解决任何并发问题。
    • READ_COMMITTED：读已提交。解决脏读，存在不可重复读与幻读。
    • REPEATABLE_READ：可重复读。解决脏读、不可重复读，存在幻读
    • SERIALIZABLE：串行化。不存在并发问题。

3.2、定义了七个事务传播行为常量

所谓事务传播行为是指，处于不同事务中的方法在相互调用时，执行期间事务的维护情况。如，A事务中的方法getUser()调用 B 事务中的方法getName()，在调用执行期间事务的维护情况，就称为事务传播行为。事务传播行为是加在方法上的。事务传播行为常量都是以PROPAGATION_ 开头，形如 PROPAGATION_XXX。

  • 常用的有三种：

    • PROPAGATION_REQUIRED
    • PROPAGATION_REQUIRES_NEW
    • PROPAGATION_SUPPORTS

PROPAGATION_REQUIRED

指定的方法必须在事务内执行。若当前存在事务，就加入到当前事务中；若当前没有事务，则创建一个新事务。这种传播行为是最常见的选择，也是Spring默认的事务传播行为。

PROPAGATION_SUPPORTS

指定的方法支持当前事务，但若当前没有事务，也可以以非事务方式执行。

PROPAGATION_REQUIRES_NEW

总是新建一个事务，若当前存在事务，就将当前事务挂起，直到新事务执行完毕。

4、案列

模拟购买商品、商品表商品数量减少、销售记录表增加记录

  • 创建两个实体类：
//商品
public class Goods
{
    private int id;
    private String name;
    private int amount;
    private float price;
    //getter setter toString()....
}
//销售记录
public class Sales
{
    private int id;
    private int gid;
    private int nums;
    //getter setter toString()....
}
  • 添加依赖：
<dependencies>
    <dependency>
      <groupId>junit</groupId>
      <artifactId>junit</artifactId>
      <version>4.11</version>
      <scope>test</scope>
    </dependency>
    <dependency>
      <groupId>org.springframework</groupId>
      <artifactId>spring-context</artifactId>
      <version>5.2.5.RELEASE</version>
    </dependency>
    <dependency>
      <groupId>org.springframework</groupId>
      <artifactId>spring-tx</artifactId>
      <version>5.2.5.RELEASE</version>
    </dependency>
    <dependency>
      <groupId>org.springframework</groupId>
      <artifactId>spring-jdbc</artifactId>
      <version>5.2.5.RELEASE</version>
    </dependency>
    <dependency>
      <groupId>org.mybatis</groupId>
      <artifactId>mybatis</artifactId>
      <version>3.5.1</version>
    </dependency>
    <dependency>
      <groupId>org.mybatis</groupId>
      <artifactId>mybatis-spring</artifactId>
      <version>1.3.1</version>
    </dependency>
    <dependency>
      <groupId>mysql</groupId>
      <artifactId>mysql-connector-java</artifactId>
      <version>5.1.9</version>
    </dependency>
    <dependency>
      <groupId>com.alibaba</groupId>
      <artifactId>druid</artifactId>
      <version>1.1.12</version>
    </dependency>
  </dependencies>

  <build>
    <resources>
      <resource>
        <directory>src/main/java</directory><!--所在的目录-->
        <includes><!--包括目录下的.properties,.xml 文件都会扫描到-->
          <include>**/*.properties</include>
          <include>**/*.xml</include>
        </includes>
        <filtering>false</filtering>
      </resource>
    </resources>
    <plugins>
      <plugin>
        <artifactId>maven-compiler-plugin</artifactId>
        <version>3.1</version>
        <configuration>
          <source>1.8</source>
          <target>1.8</target>
        </configuration>
      </plugin>
    </plugins>
  </build>
  • 在dao层创建GoodsDao接口：
public interface GoodsDao
{
    Goods selectGoods(int id);

    int updateGoods(Goods goods);
}
  • 在dao层创建SalesDao接口：
public interface SalesDao
{
    int insertSales(Sales sales);
}
  • GoodsDao对应的mapper文件：
<!-- GoodsDao对应的mapper文件 -->
<mapper namespace="com.rg.dao.GoodsDao">
    <select id="selectGoods" resultType="Goods" parameterType="int">
        select * from goods where id=#{id}
    </select>
    <update id="updateGoods" parameterType="Goods">
        update goods set amount = amount - #{amount} where id=#{id}
    </update>
</mapper>
  • SalesDao对应的mapper文件：
<!-- SalesDao对应的mapper文件 -->
<mapper namespace="com.rg.dao.SalesDao">
    <insert id="insertSales" parameterType="Sales">
        insert into sales(gid,nums) values(#{gid},#{nums})
    </insert>
</mapper>
  • 定义异常类：
public class NotEnoughException extends RuntimeException
{
    public NotEnoughException()
    {
        super();
    }

    public NotEnoughException(String message)
    {
        super(message);
    }
}
  • 在service层定义接口：
public interface BuyGoodsService
{
    void buy(int goodId, int nums);
}
  • 接口实现类：
public class BuyGoodsServiceImpl implements BuyGoodsService
{
    private GoodsDao goodsDao;
    private SalesDao salesDao;

    public void setGoodsDao(GoodsDao goodsDao)
    {
        this.goodsDao = goodsDao;
    }

    public void setSalesDao(SalesDao salesDao)
    {
        this.salesDao = salesDao;
    }

    /**
     *购买商品
     * @param goodId 商品id
     * @param nums 购买数量
     */
    @Override
    public void buy(int goodId, int nums)
    {
        Sales sales = new Sales();
        sales.setGid(goodId);
        sales.setNums(nums);
        salesDao.insertSales(sales);


        Goods goods = goodsDao.selectGoods(goodId);
        if (goods == null)
        {
            throw new NullPointerException("无此商品");
        }
        if (goods.getAmount() < nums)
        {
            throw new NotEnoughException("商品数量不足");
        }

        Goods newGoods = new Goods();
        newGoods.setId(goodId);
        newGoods.setAmount(nums);
        goodsDao.updateGoods(newGoods);
    }
}
  • 添加配置文件：
<bean id="myDataSource" class="com.alibaba.druid.pool.DruidDataSource">
        <property name="url" value="${jdbc.url}"/>
        <property name="username" value="${jdbc.username}"/>
        <property name="password" value="${jdbc.password}"/>
    </bean>
    <context:property-placeholder location="classpath:jdbc.properties"/>

    <bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">
        <property name="dataSource" ref="myDataSource"/>
        <property name="configLocation" value="classpath:mybatis.xml"/>
    </bean>
    <bean class="org.mybatis.spring.mapper.MapperScannerConfigurer">
        <property name="sqlSessionFactoryBeanName" value="sqlSessionFactory"/>
        <property name="basePackage" value="com.rg.dao"/>
    </bean>
    <bean id="buyService" class="com.rg.service.impl.BuyGoodsServiceImpl">
        <property name="goodsDao" ref="goodsDao"/>
        <property name="salesDao" ref="salesDao"/>
    </bean>

    <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
        <property name="dataSource" ref="myDataSource"/>
    </bean>
    <tx:annotation-driven transaction-manager="transactionManager"/>
  • 测试方法：
@Test
    public void test01()
    {
        String config = "applicationContext.xml";
        ApplicationContext apx = new ClassPathXmlApplicationContext(config);
        BuyGoodsService buyGoodsService = (BuyGoodsService) apx.getBean("buyService");
        buyGoodsService.buy(1, 120);
    }

这个时候如果执行程序、数据库中商品表的的商品数量不会变、但是销售记录表会增加一条记录。下边给方法添加事务。

5、使用Spring的事务注解管理事务

通过@Transactional注解方式，可将事务织入到相应 public方法中，实现事务管理。

  • @Transactional的所有可选属性如下所示：

    • propagation：用于设置事务传播属性。该属性类型为 Propagation枚举，默认值为Propagation.REQUIRED。
    • isolation：用于设置事务的隔离级别。该属性类型为 Isolation 枚举，默认值为Isolation.DEFAULT。
    • readOnly：用于设置该方法对数据库的操作是否是只读的。该属性为 boolean，默认值为false。
    • timeout：用于设置本操作与数据库连接的超时时限。单位为秒，类型为int，默认值为-1，即没有时限。
    • rollbackFor：指定需要回滚的异常类。类型为Class[]，默认值为空数组。当然，若只有一个异常类时，可以不使用数组。
    • rollbackForClassName：指定需要回滚的异常类类名。类型为 String[]，默认值为空数组。当然，若只有一个异常类时，可以不使用数组。
    • noRollbackFor：指定不需要回滚的异常类。类型为Class[]，默认值为空数组。当然，若只有一个异常类时，可以不使用数组。
    • noRollbackForClassName：指定不需要回滚的异常类类名。类型为 String[]，默认值为空数组。当然，若只有一个异常类时，可以不使用数组。需要注意的是@Transactional若用在方法上，只能用于public方法上。对于其他非public方法，如果加上了注解@Transactional，虽然Spring不会报错，但不会将指定事务织入到该方法中。因为Spring会忽略掉所有非public方法上的@Transaction注解。若@Transaction 注解在类上，则表示该类上所有的方法均将在执行时织入事务。

5.1、修改配置文件

  • 声明事务管理器和开启注解驱动
<!-- 声明事务管理器 -->
<bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
    <property name="dataSource" ref="myDataSource"/>
</bean>
<!-- 
    tx:annotation-driven：开启注解驱动 
    transaction-manager：事务管理器 bean 的 id
-->
<tx:annotation-driven transaction-manager="transactionManager"/>
  • 修改业务层接口实现类代码：
public class BuyGoodsServiceImpl implements BuyGoodsService
{
    private GoodsDao goodsDao;
    private SalesDao salesDao;

    public void setGoodsDao(GoodsDao goodsDao)
    {
        this.goodsDao = goodsDao;
    }

    public void setSalesDao(SalesDao salesDao)
    {
        this.salesDao = salesDao;
    }

    /**
     *购买商品
     * @param goodId 商品id
     * @param nums 购买数量
     */
    @Transactional(
            propagation = Propagation.REQUIRED,
            isolation = Isolation.DEFAULT,
            readOnly = false,
            rollbackFor = {
                    NotEnoughException.class,
                    NullPointerException.class
            }
    )
    @Override
    public void buy(int goodId, int nums)
    {
        Sales sales = new Sales();
        sales.setGid(goodId);
        sales.setNums(nums);
        salesDao.insertSales(sales);


        Goods goods = goodsDao.selectGoods(goodId);
        if (goods == null)
        {
            throw new NullPointerException("无此商品");
        }
        if (goods.getAmount() < nums)
        {
            throw new NotEnoughException("商品数量不足");
        }

        Goods newGoods = new Goods();
        newGoods.setId(goodId);
        newGoods.setAmount(nums);
        goodsDao.updateGoods(newGoods);
    }
}

这样、在方法上边使用@Transactional后、该方法就有了事务、如果发生的异常在rollbackFor的列表中、就会回滚、从而保证数据的完整性。另外、注解里边的属性值用的都是默认的，所以只写一个@Transactional也可以、在日常开发中、这种方式也是比较常用的方式。

@Transactional
@Override
public void buy(int goodId, int nums)
{
    //.......
}

标签：事务,Java,nums,--,Spring,goodsDao,int,goodId,public
来源： https://www.cnblogs.com/dcy521/p/14772068.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

关于我们 | 联系我们 | 留言反馈

专注分享技术，共同学习，共同进步。侵权联系[81616952@qq.com]

Copyright (C)ICode9.com, All Rights Reserved.

ICode9版权所有