spring注解事务及事务回滚失败的原因

迈不过友情╰ 2022-09-27 04:58 279阅读 0赞

背景

spring支持编程式事务管理和声明式事务管理两种方式。

编程式事务管理使用TransactionTemplate或者直接使用底层的PlatformTransactionManager。对于编程式事务管理,spring推荐使用TransactionTemplate。

声明式事务管理建立在AOP之上的。其本质是对方法前后进行拦截,然后在目标方法开始之前创建或者加入一个事务,在执行完目标方法之后根据执行情况提交或者回滚事务。

声明式事务管理也有两种常用的方式,一种是基于tx和aop名字空间的xml配置文件,另一种就是基于@Transactional注解。显然基于注解的方式更简单易用,更清爽。

自动提交(AutoCommit)与连接关闭时的是否自动提交

自动提交

默认情况下,数据库处于自动提交模式。每一条语句处于一个单独的事务中,在这条语句执行完毕时,如果执行成功则隐式的提交事务,如果
执行失败则隐式的回滚事务。

spring注解事务的实现

maven创建一个普通项目,当然web项目也可以,我这里是一个web项目
pom.xm如下,本身是用不到这么多jar,直接从项目中拷贝的,懒得删。

  1. <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
  2. <modelVersion>4.0.0</modelVersion>
  3. <groupId>com.bamboo</groupId>
  4. <artifactId>anoTest</artifactId>
  5. <packaging>war</packaging>
  6. <version>0.0.1-SNAPSHOT</version>
  7. <name>anoTest Maven Webapp</name>
  8. <url>http://maven.apache.org</url>
  9. <repositories>
  10. <repository>
  11. <id>nexus_public</id>
  12. <name>nexus_public</name>
  13. <url>http://repo.maven.apache.org/maven2/</url>
  14. <releases>
  15. <enabled>true</enabled>
  16. </releases>
  17. <snapshots>
  18. <enabled>false</enabled>
  19. </snapshots>
  20. </repository>
  21. </repositories>
  22. <pluginRepositories>
  23. <pluginRepository>
  24. <id>nexus_public</id>
  25. <name>nexus_public</name>
  26. <!-- <url>http://repository.jboss.org/nexus/content/repositories/root_repository/maven2/</url> -->
  27. <url>http://repo.maven.apache.org/maven2/</url>
  28. <layout>default</layout>
  29. <snapshots>
  30. <enabled>false</enabled>
  31. </snapshots>
  32. <releases>
  33. <updatePolicy>never</updatePolicy>
  34. </releases>
  35. </pluginRepository>
  36. </pluginRepositories>
  37. <!-- 项目属性 -->
  38. <properties>
  39. <!-- jar 版本设置 -->
  40. <spring.version>4.1.0.RELEASE</spring.version>
  41. <shiro.version>1.2.3</shiro.version>
  42. <mybatis.version>3.2.8</mybatis.version>
  43. <mybatis-spring.version>1.2.2</mybatis-spring.version>
  44. <mysql.version>5.1.26</mysql.version>
  45. <druid.version>1.0.9</druid.version>
  46. <junit.version>3.8.1</junit.version>
  47. <log4j.version>1.2.17</log4j.version>
  48. <slf4j.version>1.7.5</slf4j.version>
  49. <poi.version>3.10-FINAL</poi.version>
  50. <commons-lang3.version>3.1</commons-lang3.version>
  51. <commons-io.version>2.4</commons-io.version>
  52. <commons-codec.version>1.8</commons-codec.version>
  53. <commons-fileupload.version>1.3.1</commons-fileupload.version>
  54. <commons-beanutils.version>1.8.3</commons-beanutils.version>
  55. <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
  56. <jdk.version>1.7</jdk.version>
  57. </properties>
  58. <dependencies>
  59. <!-- spring相关包 -->
  60. <!-- Spring -->
  61. <dependency>
  62. <groupId>org.apache.tomcat</groupId>
  63. <artifactId>servlet-api</artifactId>
  64. <version>6.0.37</version>
  65. </dependency>
  66. <dependency>
  67. <groupId>org.springframework</groupId>
  68. <artifactId>spring-core</artifactId>
  69. <version>${spring.version}</version>
  70. </dependency>
  71. <dependency>
  72. <groupId>org.springframework</groupId>
  73. <artifactId>spring-context</artifactId>
  74. <version>${spring.version}</version>
  75. </dependency>
  76. <dependency>
  77. <groupId>org.springframework</groupId>
  78. <artifactId>spring-context-support</artifactId>
  79. <version>${spring.version}</version>
  80. </dependency>
  81. <dependency>
  82. <groupId>org.springframework</groupId>
  83. <artifactId>spring-webmvc</artifactId>
  84. <version>${spring.version}</version>
  85. </dependency>
  86. <dependency>
  87. <groupId>org.springframework</groupId>
  88. <artifactId>spring-jdbc</artifactId>
  89. <version>${spring.version}</version>
  90. </dependency>
  91. <dependency>
  92. <groupId>org.springframework</groupId>
  93. <artifactId>spring-orm</artifactId>
  94. <version>${spring.version}</version>
  95. </dependency>
  96. <dependency>
  97. <groupId>org.springframework</groupId>
  98. <artifactId>spring-tx</artifactId>
  99. <version>${spring.version}</version>
  100. </dependency>
  101. <dependency>
  102. <groupId>org.springframework</groupId>
  103. <artifactId>spring-test</artifactId>
  104. <version>${spring.version}</version>
  105. </dependency>
  106. <!-- 切面jar -->
  107. <dependency>
  108. <groupId>aspectj</groupId>
  109. <artifactId>aspectjweaver</artifactId>
  110. <version>1.5.4</version>
  111. </dependency>
  112. <!-- javax提供的annotation,注入的注解jar -->
  113. <dependency>
  114. <groupId>javax.inject</groupId>
  115. <artifactId>javax.inject</artifactId>
  116. <version>1</version>
  117. </dependency>
  118. <!-- 日志架包 -->
  119. <dependency>
  120. <groupId>log4j</groupId>
  121. <artifactId>log4j</artifactId>
  122. <version>1.2.16</version>
  123. </dependency>
  124. <dependency>
  125. <groupId>org.slf4j</groupId>
  126. <artifactId>slf4j-log4j12</artifactId>
  127. <version>1.7.21</version>
  128. </dependency>
  129. <dependency>
  130. <groupId>org.codehaus.jackson</groupId>
  131. <artifactId>jackson-mapper-asl</artifactId>
  132. <version>1.9.13</version>
  133. </dependency>
  134. <dependency>
  135. <groupId>junit</groupId>
  136. <artifactId>junit</artifactId>
  137. <version>3.8.1</version>
  138. <scope>test</scope>
  139. </dependency>
  140. <!--springMVC 依赖json解析jar -->
  141. <dependency>
  142. <groupId>com.fasterxml.jackson.core</groupId>
  143. <artifactId>jackson-core</artifactId>
  144. <version>2.1.0</version>
  145. </dependency>
  146. <dependency>
  147. <groupId>com.fasterxml.jackson.core</groupId>
  148. <artifactId>jackson-databind</artifactId>
  149. <version>2.1.0</version>
  150. </dependency>
  151. <dependency>
  152. <groupId>com.fasterxml.jackson.core</groupId>
  153. <artifactId>jackson-annotations</artifactId>
  154. <version>2.1.0</version>
  155. </dependency>
  156. <!--Apache Shiro所需的jar包 -->
  157. <dependency>
  158. <groupId>org.apache.shiro</groupId>
  159. <artifactId>shiro-core</artifactId>
  160. <version>${shiro.version}</version>
  161. </dependency>
  162. <!-- <dependency> <groupId>org.apache.shiro</groupId> <artifactId>shiro-ehcache</artifactId> <version>${shiro.version}</version> </dependency> -->
  163. <dependency>
  164. <groupId>org.apache.shiro</groupId>
  165. <artifactId>shiro-web</artifactId>
  166. <version>${shiro.version}</version>
  167. </dependency>
  168. <!-- <dependency> <groupId>org.apache.shiro</groupId> <artifactId>shiro-quartz</artifactId> <version>${shiro.version}</version> </dependency> -->
  169. <dependency>
  170. <groupId>org.apache.shiro</groupId>
  171. <artifactId>shiro-spring</artifactId>
  172. <version>${shiro.version}</version>
  173. </dependency>
  174. <!-- 数据库连接dbcp -->
  175. <dependency>
  176. <groupId>commons-dbcp</groupId>
  177. <artifactId>commons-dbcp</artifactId>
  178. <version>1.4</version>
  179. </dependency>
  180. <!-- mybatis -->
  181. <dependency>
  182. <groupId>org.mybatis</groupId>
  183. <artifactId>mybatis</artifactId>
  184. <version>${mybatis.version}</version>
  185. </dependency>
  186. <dependency>
  187. <groupId>org.mybatis</groupId>
  188. <artifactId>mybatis-spring</artifactId>
  189. <version>${mybatis-spring.version}</version>
  190. </dependency>
  191. <!-- mysql -->
  192. <dependency>
  193. <groupId>mysql</groupId>
  194. <artifactId>mysql-connector-java</artifactId>
  195. <version>${mysql.version}</version>
  196. </dependency>
  197. <!-- fileupload的jar -->
  198. <dependency>
  199. <groupId>commons-io</groupId>
  200. <artifactId>commons-io</artifactId>
  201. <version>${commons-io.version}</version>
  202. </dependency>
  203. <dependency>
  204. <groupId>commons-fileupload</groupId>
  205. <artifactId>commons-fileupload</artifactId>
  206. <version>${commons-fileupload.version}</version>
  207. </dependency>
  208. <!-- apache 常用包 -->
  209. <dependency>
  210. <groupId>commons-beanutils</groupId>
  211. <artifactId>commons-beanutils</artifactId>
  212. <version>1.8.3</version>
  213. <type>jar</type>
  214. <scope>compile</scope>
  215. </dependency>
  216. <dependency>
  217. <groupId>org.apache.commons</groupId>
  218. <artifactId>commons-lang3</artifactId>
  219. <version>3.1</version>
  220. <type>jar</type>
  221. <scope>compile</scope>
  222. </dependency>
  223. <!-- 页面装饰 -->
  224. <dependency>
  225. <groupId>opensymphony</groupId>
  226. <artifactId>sitemesh</artifactId>
  227. <version>2.4.2</version>
  228. </dependency>
  229. <!-- jstl -->
  230. <dependency>
  231. <groupId>jstl</groupId>
  232. <artifactId>jstl</artifactId>
  233. <version>1.2</version>
  234. </dependency>
  235. <!-- 缓存ehcache -->
  236. <dependency>
  237. <groupId>net.sf.ehcache</groupId>
  238. <artifactId>ehcache-core</artifactId>
  239. <version>2.8.3</version>
  240. </dependency>
  241. <!-- ehcache缓存jar -->
  242. <!-- <dependency> <groupId>com.googlecode.ehcache-spring-annotations</groupId> <artifactId>ehcache-spring-annotations</artifactId> <version>1.2.0</version> <type>jar</type> <scope>compile</scope> </dependency> -->
  243. </dependencies>
  244. <build>
  245. <finalName>onedollar</finalName>
  246. </build>
  247. </project>

spring.xml

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:p="http://www.springframework.org/schema/p" xmlns:context="http://www.springframework.org/schema/context" xmlns:mvc="http://www.springframework.org/schema/mvc" xmlns:tx="http://www.springframework.org/schema/tx" xmlns:ehcache="http://ehcache-spring-annotations.googlecode.com/svn/schema/ehcache-spring" xmlns:cache="http://www.springframework.org/schema/cache" xmlns:aop="http://www.springframework.org/schema/aop" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.0.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-4.0.xsd http://www.springframework.org/schema/mvc http://www.springframework.org/schema/mvc/spring-mvc-4.0.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-4.0.xsd http://www.springframework.org/schema/cache http://www.springframework.org/schema/cache/spring-cache.xsd http://ehcache-spring-annotations.googlecode.com/svn/schema/ehcache-spring http://ehcache-spring-annotations.googlecode.com/svn/schema/ehcache-spring/ehcache-spring-1.1.xsd http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-4.1.xsd">
  3. <!-- 自动扫描 -->
  4. <context:component-scan base-package="anotest" />
  5. <!-- 定义一个数据源 -->
  6. <bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close">
  7. <property name="driverClassName" value="com.mysql.jdbc.Driver" />
  8. <property name="url" value="jdbc:mysql://127.0.0.1/shiro" />
  9. <property name="username" value="root" />
  10. <property name="password" value="root" />
  11. <property name="initialSize" value="3" /><!-- initial connections -->
  12. <property name="maxActive" value="10" /><!-- MAX connections -->
  13. <property name="maxIdle" value="5" /><!-- MAX idle connections -->
  14. <property name="minIdle" value="2" /><!-- MIN idle connections -->
  15. <property name="testWhileIdle" value="true" />
  16. <property name="testOnBorrow" value="false" />
  17. <property name="testOnReturn" value="false" />
  18. <property name="validationQuery" value="select 1" />
  19. <property name="timeBetweenEvictionRunsMillis" value="20000" />
  20. <property name="numTestsPerEvictionRun" value="100" />
  21. </bean>
  22. <!-- spring和MyBatis完美整合,不需要mybatis的配置映射文件 -->
  23. <bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">
  24. <property name="dataSource" ref="dataSource" />
  25. <!-- 自动扫描mapping.xml文件 -->
  26. <property name="mapperLocations" value="classpath:anotest/mapper/*.xml"></property>
  27. <property name="typeAliasesPackage" value="anotest" />
  28. </bean>
  29. <!-- DAO接口所在包名,Spring会自动查找其下的类 -->
  30. <bean class="org.mybatis.spring.mapper.MapperScannerConfigurer">
  31. <property name="basePackage" value="anotest.dao" />
  32. <property name="sqlSessionFactoryBeanName" value="sqlSessionFactory"></property>
  33. </bean>
  34. <!-- 配置事务管理器 -->
  35. <bean id="txManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager" p:dataSource-ref="dataSource">
  36. </bean>
  37. <!-- enables scanning for @Transactional annotations -->
  38. <tx:annotation-driven transaction-manager="txManager" proxy-target-class="true" />
  39. <!-- 配置事物的拦截方式 -->
  40. <!-- <tx:advice id="transAdvice" transaction-manager="txManager"> <tx:attributes> <tx:method name="delete*" propagation="REQUIRED" /> <tx:method name="insert*" propagation="REQUIRED" /> <tx:method name="update*" propagation="REQUIRED" /> <tx:method name="add*" propagation="REQUIRED" /> <tx:method name="modify*" propagation="REQUIRED" /> <tx:method name="remove*" propagation="REQUIRED" /> <tx:method name="find*" propagation="SUPPORTS" /> <tx:method name="get*" propagation="SUPPORTS" /> <tx:method name="select*" propagation="SUPPORTS" /> <tx:method name="query*" propagation="SUPPORTS" /> <tx:method name="*" propagation="SUPPORTS" /> </tx:attributes> </tx:advice> -->
  41. <!-- 事物配置扫描包 -->
  42. <!-- <aop:config proxy-target-class="true"> <aop:pointcut expression="execution(* anotest.*impl.*(..))" id="transcationPointcut" /> <aop:advisor advice-ref="transAdvice" pointcut-ref="transcationPointcut" /> </aop:config> -->
  43. </beans>

代码片段

创建包名
anotest.dao
anotest.mapper
anotest.service.impl

LogDao.java

  1. package anotest.dao;
  2. import anotest.Log;
  3. /** * log页面表 数据库处理类 */
  4. public interface LogDao {
  5. void add(Log log);
  6. }

LogMapper.xml

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
  3. <mapper namespace="anotest.dao.LogDao">
  4. <resultMap type="Log" id="Log">
  5. <id column="LOG_ID" property="logId" javaType="java.lang.Long" jdbcType="BIGINT"/>
  6. <result column="IMEI_CODE" property="imeiCode" javaType="java.lang.String" jdbcType="VARCHAR"/>
  7. <result column="DAY_TIME" property="dayTime" javaType="java.lang.String" jdbcType="VARCHAR"/>
  8. </resultMap>
  9. <!-- 全部字段,一般用于明细查询 -->
  10. <sql id="AllColumnlist">
  11. LOG_ID,IMEI_CODE,DAY_TIME
  12. </sql>
  13. <!-- 常见字段,一般用于列表查询,可能不包含备注之类的字段 -->
  14. <sql id="CommonColumnlist">
  15. LOG_ID,IMEI_CODE,DAY_TIME
  16. </sql>
  17. <insert id="add" parameterType="Log" useGeneratedKeys="true" keyProperty="LogId">
  18. insert into T_LOG (
  19. <if test="logId!=null">
  20. LOG_ID,
  21. </if>
  22. IMEI_CODE,
  23. DAY_TIME
  24. ) values (
  25. <if test="logId!=null">
  26. #{logId,jdbcType = BIGINT},
  27. </if>
  28. #{imeiCode,jdbcType = VARCHAR},
  29. #{dayTime,jdbcType = VARCHAR}
  30. )
  31. </insert>
  32. <delete id="delete">
  33. delete from T_LOG
  34. <where>
  35. Log_ID=#{0}
  36. </where>
  37. </delete>
  38. <select id="get" resultMap="Log">
  39. select <include refid="AllColumnlist"/> from T_LOG
  40. <where>
  41. LOG_ID=#{0}
  42. </where>
  43. </select>
  44. <select id="getLogByCode" parameterType="java.lang.String" resultMap="Log">
  45. select * from T_LOG
  46. <where>
  47. IMEI_CODE=#{0}
  48. </where>
  49. </select>
  50. </mapper>

Log.java

  1. package anotest;
  2. public class Log {
  3. private static final long serialVersionUID = 1l;
  4. /*Auto generated properties start*/
  5. //log-id
  6. private Long logId;
  7. //IMEI编号
  8. private String imeiCode;
  9. //年月日
  10. private String dayTime;
  11. /*Auto generated methods start*/
  12. public Log() {
  13. }
  14. /** * @param imeiCode * @param dayTime */
  15. public Log(String imeiCode, String dayTime) {
  16. super();
  17. this.imeiCode = imeiCode;
  18. this.dayTime = dayTime;
  19. }
  20. /*Auto generated methods end*/
  21. /*Customized methods start*/
  22. /*Customized methods end*/
  23. public Long getLogId() {
  24. return logId;
  25. }
  26. public void setLogId(Long logId) {
  27. this.logId = logId;
  28. }
  29. public String getImeiCode() {
  30. return imeiCode;
  31. }
  32. public void setImeiCode(String imeiCode) {
  33. this.imeiCode = imeiCode;
  34. }
  35. public String getDayTime() {
  36. return dayTime;
  37. }
  38. public void setDayTime(String dayTime) {
  39. this.dayTime = dayTime;
  40. }
  41. @Override
  42. public String toString() {
  43. return "Log [logId=" + logId + ", imeiCode=" + imeiCode + ", dayTime="
  44. + dayTime + "]";
  45. }
  46. }

TestService.java

  1. package anotest.service;
  2. import anotest.Log;
  3. /** * @ClassName: TestService * @Description: TODO(这里用一句话描述这个类的作用) * @author bamboo <a href="mailto:zjcjava@163.com?subject=hello,bamboo&body=Dear Bamboo:%0d%0a描述你的问题:">Bamboo</a> * @date 2017年3月7日 上午10:17:06 * @since */
  4. public interface TestService {
  5. public void addCatch() throws Exception;
  6. public void addTest();
  7. }

TestServiceImpl.java

  1. package anotest.service.impl;
  2. import java.text.SimpleDateFormat;
  3. import java.util.Date;
  4. import javax.annotation.Resource;
  5. import org.springframework.stereotype.Service;
  6. import org.springframework.transaction.annotation.Transactional;
  7. import anotest.Log;
  8. import anotest.dao.LogDao;
  9. import anotest.service.TestService;
  10. /** * @ClassName: TestServiceImpl * @Description: TODO(这里用一句话描述这个类的作用) * @author bamboo <a href="mailto:zjcjava@163.com?subject=hello,bamboo&body=Dear Bamboo:%0d%0a描述你的问题:">Bamboo</a> * @date 2017年3月7日 上午10:38:42 * @since */
  11. @Service
  12. //默认将类中的所有函数纳入事务管理.
  13. @Transactional
  14. public class TestServiceImpl implements TestService{
  15. @Resource
  16. private LogDao logDao;
  17. /*** * 捕获异常后但是不抛出去是无法执行回滚事务的 * 建议:用本方式写,使上层方法能够检测到数据插入失败,因此必须抛出异常,然后在调用它的方法中捕获异常并提示用户数据提交失败 * @throws Exception */
  18. @Transactional
  19. public void addCatch() throws Exception {
  20. // TODO Auto-generated method stub
  21. try {
  22. SimpleDateFormat format = new SimpleDateFormat("yyyyMMdd");
  23. String dayTime=format.format(new Date());
  24. Log log =new Log("ABCD", dayTime);
  25. log.setLogId(System.currentTimeMillis());
  26. System.out.println(log.toString());
  27. // 调用Dao执行插入操作
  28. logDao.add(log);//正常常数据
  29. log.setDayTime(dayTime+"yyyyyyyyyyyyyyyyyyy");
  30. // 调用Dao执行插入操作
  31. logDao.add(log);//异常数据
  32. } catch (Exception e) {
  33. // TODO Auto-generated catch block
  34. System.out.println("插入失败");
  35. //throw new Exception(e);//注意:正常环境中必须去掉本行注释,当把这行去掉注释事务回滚就会起作用
  36. }
  37. }
  38. /****** * 运行时异常不作捕获则则能够正常执行回滚事务 */
  39. @Transactional
  40. public void addTest() {
  41. // TODO Auto-generated method stub
  42. SimpleDateFormat format = new SimpleDateFormat("yyyyMMdd");
  43. String dayTime=format.format(new Date());
  44. Log log =new Log("ABCD", dayTime);
  45. log.setLogId(System.currentTimeMillis());
  46. System.out.println(log.toString());
  47. // 调用Dao执行插入操作
  48. logDao.add(log);
  49. log.setDayTime(dayTime+"yyyyyyyyyyyyyyyyyyy");
  50. // 调用Dao执行插入操作
  51. logDao.add(log);//异常数据
  52. }
  53. }

测试类

ContextConfig.java

  1. import org.junit.runner.RunWith;
  2. import org.springframework.test.context.ContextConfiguration;
  3. import org.springframework.test.context.junit4.AbstractJUnit4SpringContextTests;
  4. import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
  5. //指定bean注入的配置文件
  6. @ContextConfiguration(locations = { "classpath:spring.xml" })
  7. //使用标准的JUnit @RunWith注释来告诉JUnit使用Spring TestRunner
  8. @RunWith(SpringJUnit4ClassRunner.class)
  9. public class ContextConfig extends AbstractJUnit4SpringContextTests {
  10. }

TestCase.java

  1. import org.junit.Test;
  2. import org.springframework.beans.factory.annotation.Autowired;
  3. import anotest.service.TestService;
  4. public class TestCase extends ContextConfig {
  5. @Autowired
  6. private TestService testService;
  7. @Test
  8. public void getTimestampTest() throws Exception{
  9. testService.addCatch();//1捕获异常的方法,注释掉异常抛出则不会回滚
  10. testService.addTest();//2没有任何捕获,能够正常回滚
  11. }
  12. }

测试结果

当注释掉注释//2所在的行只执行addCatch()方法时

  1. log4j:WARN No appenders could be found for logger (org.springframework.test.context.junit4.SpringJUnit4ClassRunner).
  2. log4j:WARN Please initialize the log4j system properly.
  3. log4j:WARN See http://logging.apache.org/log4j/1.2/faq.html#noconfig for more info.
  4. Log [logId=1488871162669, imeiCode=ABCD, dayTime=20170307]
  5. 插入失败

插入失败,但是我们看数据库,依然会有数据被插入了

  1. mysql> select * from t_log; +---------------+-----------+------------+
  2. | LOG_ID | IMEI_CODE | DAY_TIME | +---------------+-----------+------------+
  3. | 1488871162669 | ABCD | 2017-03-07 | +---------------+-----------+------------+
  4. 1 row in set (0.00 sec)

当注释掉注释//1所在的行只执行addTest()方法时
OUTPUT:

  1. log4j:WARN No appenders could be found for logger (org.springframework.test.context.junit4.SpringJUnit4ClassRunner).
  2. log4j:WARN Please initialize the log4j system properly.
  3. log4j:WARN See http://logging.apache.org/log4j/1.2/faq.html#noconfig for more info.
  4. Log [logId=1488871460315, imeiCode=ABCD, dayTime=20170307]

看数据库,显然数据没有被插入,而是发生了回滚

  1. mysql> select * from t_log; +---------------+-----------+------------+
  2. | LOG_ID | IMEI_CODE | DAY_TIME | +---------------+-----------+------------+
  3. | 1488871162669 | ABCD | 2017-03-07 | +---------------+-----------+------------+
  4. 1 row in set (0.00 sec)

我们在回到addCatch()方法,把下面这行的注释去掉

  1. //throw new Exception(e);//注意:正常环境中必须去掉本行注释,当把这行去掉注释事务回滚就会起作用

运行测试

OUTPUT:

  1. log4j:WARN No appenders could be found for logger (org.springframework.test.context.junit4.SpringJUnit4ClassRunner).
  2. log4j:WARN Please initialize the log4j system properly.
  3. log4j:WARN See http://logging.apache.org/log4j/1.2/faq.html#noconfig for more info.
  4. Log [logId=1488871709355, imeiCode=ABCD, dayTime=20170307]
  5. 插入失败

查看表数,可以看到这次数据并没有被插入

  1. mysql> select * from t_log; +---------------+-----------+------------+
  2. | LOG_ID | IMEI_CODE | DAY_TIME | +---------------+-----------+------------+
  3. | 1488871162669 | ABCD | 2017-03-07 | +---------------+-----------+------------+
  4. 1 row in set (0.00 sec)

结论

spring的事务只有在触发运行时异常时才会发生回滚,并且这个异常是在切面中是可以被事务管理器捕获到的,如果我们自己在方法体中捕获而不把这个异常抛出(不通知事务管理器)它就不会除非事务回滚。因此在dao层基本不处理数据库插入异常。

其他原因

mysql数据库引擎的问题
mysql数据库引擎分为两种
innodb:支持事务和索引
myisam:不支持事务和索引,因此这种类型的引擎即使你的代码写的是正确的但是依然不会触发事务回滚。

配置文件扫描的问题
因为spring的容器(applicationContext)和springMVC的(applicationContext)是不同的。

spring容器加载得时候,优先加载ServletContextListener(对应spring.xml)产生的父容器,而springMVC(对应springMVC.xml)产生的是子容器。子容器Controller进行扫描装配时装配的@Service注解的实例是没有经过事务加强处理,

即没有事务处理能力的Service。而父容器进行初始化的Service是保证事务的增强处理能力的。如果不在子容器中将Service除去掉,此时得到的将是原样的无事务处理能力的Service。

所以,我们应把扫描Service的工作放在spring.xml中。让Service和事务注解存在于同一个容器中,这样配置的事务注解就能起作用了。也就是说把这个配置从

springMVC.xml中移到spring.xml的配置中。事务不回滚的问题就能解决了。

本demo下载

http://download.csdn.net/detail/zjcjava/9773010

发表评论

表情:
评论列表 (有 0 条评论,279人围观)

还没有评论,来说两句吧...

相关阅读