Java -- Spring学习笔记7Spring事务
Posted 從未停步。
tags:
篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了Java -- Spring学习笔记7Spring事务相关的知识，希望对你有一定的参考价值。
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 -- Spring学习笔记7Spring事务的主要内容，如果未能解决你的问题，请参考以下文章
7Spring 源码学习 ~ 默认标签的解析之嵌入式 beans 标签的解析