TransactionRollback
title: 事务回滚 tags:
事务回滚
SpringMVC
categories:
JavaEE
配置
相关
<!-- 事务管理器 -->
<bean id="transactionManager"
class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
<!-- 数据源 -->
<property name="dataSource" ref="dataSource" />
</bean>
<!-- 通知 -->
<tx:advice id="txAdvice" transaction-manager="transactionManager">
<tx:attributes>
<!-- 传播行为 -->
<tx:method name="save*" propagation="REQUIRED" />
<tx:method name="insert*" propagation="REQUIRED" />
<tx:method name="add*" propagation="REQUIRED" />
<tx:method name="create*" propagation="REQUIRED" />
<tx:method name="delete*" propagation="REQUIRED" />
<tx:method name="update*" propagation="REQUIRED" />
<tx:method name="find*" propagation="SUPPORTS" read-only="true" />
<tx:method name="select*" propagation="SUPPORTS" read-only="true" />
<tx:method name="get*" propagation="SUPPORTS" read-only="true" />
</tx:attributes>
</tx:advice>
<!-- transaction support-->
<!-- enable transaction annotation support -->
<tx:annotation-driven transaction-manager="transactionManager" />全部
springmvc.xml
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:context="http://www.springframework.org/schema/context" xmlns:p="http://www.springframework.org/schema/p"
xmlns:aop="http://www.springframework.org/schema/aop" xmlns:tx="http://www.springframework.org/schema/tx"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
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/aop http://www.springframework.org/schema/aop/spring-aop-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/util http://www.springframework.org/schema/util/spring-util-4.0.xsd">
<!-- 数据库连接池 -->
<!-- 加载配置文件 -->
<context:property-placeholder location="classpath:resource/*.properties" />
<!-- 数据库连接池 -->
<bean id="dataSource" class="com.alibaba.druid.pool.DruidDataSource"
destroy-method="close">
<property name="url" value="${jdbc.url}" />
<property name="username" value="${jdbc.username}" />
<property name="password" value="${jdbc.password}" />
<property name="driverClassName" value="${jdbc.driver}" />
<property name="maxActive" value="10" />
<property name="minIdle" value="5" />
</bean>
<!-- 配置sqlsessionFactory -->
<bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">
<property name="configLocation" value="classpath:mybatis/SqlMapConfig.xml"></property>
<property name="dataSource" ref="dataSource"></property>
</bean>
<!-- 配置扫描包，加载mapper代理对象 -->
<bean class="org.mybatis.spring.mapper.MapperScannerConfigurer">
<property name="basePackage" value="com.neu.cse.powercloud.mapper"></property>
</bean>
<!-- 扫描包加载Service实现类 -->
<context:component-scan base-package="com.neu.cse.powercloud.serviceImpl"></context:component-scan>
<!-- 事务管理器 -->
<bean id="transactionManager"
class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
<!-- 数据源 -->
<property name="dataSource" ref="dataSource" />
</bean>
<!-- 通知 -->
<tx:advice id="txAdvice" transaction-manager="transactionManager">
<tx:attributes>
<!-- 传播行为 -->
<tx:method name="save*" propagation="REQUIRED" />
<tx:method name="insert*" propagation="REQUIRED" />
<tx:method name="add*" propagation="REQUIRED" />
<tx:method name="create*" propagation="REQUIRED" />
<tx:method name="delete*" propagation="REQUIRED" />
<tx:method name="update*" propagation="REQUIRED" />
<tx:method name="find*" propagation="SUPPORTS" read-only="true" />
<tx:method name="select*" propagation="SUPPORTS" read-only="true" />
<tx:method name="get*" propagation="SUPPORTS" read-only="true" />
</tx:attributes>
</tx:advice>
<!-- transaction support-->
<!-- enable transaction annotation support -->
<tx:annotation-driven transaction-manager="transactionManager" />
<!-- 切面 -->
<aop:config>
<aop:advisor advice-ref="txAdvice"
pointcut="execution(* com.neu.cse.powercloud.service.*.*(..))" />
</aop:config>
</beans>示例代码
相关
/**
* 添加系统用户
* @param user SysUser实例
* @param roles 角色列表
* @param dataAuthorities 用户数据权限列表
* @return ResponseResult
*/
@Transactional(rollbackFor = Exception.class)
@Override
public ResponseResult addUser(SysUser user, List<Integer> roles, List<Integer> dataAuthorities) throws Exception {
try {
SysUserExample example = new SysUserExample();
SysUserExample.Criteria criteria = example.createCriteria();
criteria.andUsernameEqualTo(user.getUsername());
if (sysUserMapper.selectByExample(example).isEmpty()) { // 判断用户名是否已存在
try {
user.setPassword(MD5Encoder.encoderStringByMD5(user.getPassword())); // 对密码加密
sysUserMapper.insert(user); // 向数据库插入新用户信息
// 设置角色
// TODO
// 设置数据权限
// TODO
} catch (Exception e) {
e.printStackTrace();
logger.error(e);
return ResponseResult.no("用户信息不正确");
}
// TODO 删除事务回滚测试抛出异常
throw new Exception("事务回滚测试");
// return ResponseResult.ok();
} else {
return ResponseResult.no("用户已存在");
}
} catch (Exception e) {
logger.error(e);
if (e.toString().contains("事务")) {
throw new Exception("事务回滚测试");
}
return ResponseResult.no("未知异常！");
}
}全部
package com.neu.cse.powercloud.serviceImpl.sysmanage;
import com.github.pagehelper.PageHelper;
import com.neu.cse.powercloud.mapper.sysmanage.SysUserMapper;
import com.neu.cse.powercloud.pojo.sysmanage.SysUser;
import com.neu.cse.powercloud.pojo.sysmanage.SysUserExample;
import com.neu.cse.powercloud.service.sysmanage.UserManageService;
import com.neu.cse.powercloud.serviceImpl.PropertiesServiceImpl;
import com.neu.cse.powercloud.util.MD5Encoder;
import com.neu.cse.powercloud.util.ResponseResult;
import org.apache.log4j.Logger;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import java.util.List;
/**
* 用户管理服务实现
* @author szk
*/
@Service
public class UserManageServiceImpl implements UserManageService {
private Logger logger = Logger.getLogger(UserManageServiceImpl.class);
@Autowired(required = true)
private SysUserMapper sysUserMapper;
@Autowired
private PropertiesServiceImpl propertiesServiceImpl;
/**
* 添加系统用户
* @param name 用户名
* @param password 原始(未经md5加密)密码
* @param customerId 客户id
* @param tel 电话
* @param status 状态
* @param roles 角色列表
* @param dataAuthorities 用户数据权限列表
* @return ResponseResult
*/
@Transactional(rollbackFor = Exception.class)
@Override
public ResponseResult addUser(String name, String password, int customerId, String tel, String status,
List<Integer> roles, List<Integer> dataAuthorities) throws Exception {
SysUser user = new SysUser();
user.setPassword(password);
user.setCustomerid(customerId);
user.setStatus(status);
user.setTel(tel);
user.setUsername(name);
return this.addUser(user, roles, dataAuthorities);
}
/**
* 添加系统用户
* @param user SysUser实例
* @param roles 角色列表
* @param dataAuthorities 用户数据权限列表
* @return ResponseResult
*/
@Transactional(rollbackFor = Exception.class)
@Override
public ResponseResult addUser(SysUser user, List<Integer> roles, List<Integer> dataAuthorities) throws Exception {
try {
SysUserExample example = new SysUserExample();
SysUserExample.Criteria criteria = example.createCriteria();
criteria.andUsernameEqualTo(user.getUsername());
if (sysUserMapper.selectByExample(example).isEmpty()) { // 判断用户名是否已存在
try {
user.setPassword(MD5Encoder.encoderStringByMD5(user.getPassword())); // 对密码加密
sysUserMapper.insert(user); // 向数据库插入新用户信息
// 设置角色
// TODO
// 设置数据权限
// TODO
} catch (Exception e) {
e.printStackTrace();
logger.error(e);
return ResponseResult.no("用户信息不正确");
}
// TODO 删除事务回滚测试抛出异常
throw new Exception("事务回滚测试");
// return ResponseResult.ok();
} else {
return ResponseResult.no("用户已存在");
}
} catch (Exception e) {
logger.error(e);
if (e.toString().contains("事务")) {
throw new Exception("事务回滚测试");
}
return ResponseResult.no("未知异常！");
}
}
/**
* 获取用户列表
* 获取区间： [start, min(start+length, total))
* @param start 开始索引，从0开始
* @param length 获取长度
* @return ResponseResult
*/
@Override
public ResponseResult getUsers(int start, int length) {
try {
SysUserExample example = new SysUserExample();
int page = start / length + 1; // Page 从1开始
PageHelper.startPage(page, length); // 设置PageHelper；此处开始分页，获取记录必须放在该语句之后
List<SysUser> users = sysUserMapper.selectByExample(example); // 已经被分页
return ResponseResult.ok(users);
} catch (Exception e) {
logger.error(e);
e.printStackTrace();
return ResponseResult.no("未知异常！");
}
}
/**
* 删除指定id用户
*
* @param userId 用户id
* @return 操作结果
*/
@Override
public ResponseResult deleteUser(int userId) {
try {
sysUserMapper.deleteByPrimaryKey(userId);
return ResponseResult.ok();
} catch (Exception e) {
logger.error(e);
return ResponseResult.no("未知异常！");
}
}
}测试代码
相关
@Test
public void addUser2() throws Exception {
// 测试事务回滚
SysUser user = new SysUser();
user.setUsername("name" + new Random().nextInt());
user.setTel("1213123");
user.setStatus("事务回滚测试");
user.setCustomerid(10010);
user.setPassword("passwordPass");
// 角色
List<Integer> roles = new ArrayList<Integer>();
roles.add(1);
// TODO
ResponseResult result = userManageService.addUser(user, roles, null);
}全部
package com.neu.cse.powercloud.serviceImpl.sysmanage;
import com.github.pagehelper.Page;
import com.neu.cse.powercloud.pojo.sysmanage.SysUser;
import com.neu.cse.powercloud.service.sysmanage.UserManageService;
import com.neu.cse.powercloud.util.ResponseResult;
import org.junit.Assert;
import org.junit.Before;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.MediaType;
import org.springframework.mock.web.MockHttpSession;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
import org.springframework.test.context.web.WebAppConfiguration;
import org.springframework.test.web.servlet.MockMvc;
import org.springframework.test.web.servlet.MvcResult;
import org.springframework.test.web.servlet.setup.MockMvcBuilders;
import org.springframework.web.context.WebApplicationContext;
import javax.servlet.http.HttpSession;
import java.util.ArrayList;
import java.util.List;
import java.util.Random;
import static org.springframework.test.web.servlet.request.MockMvcRequestBuilders.post;
import static org.springframework.test.web.servlet.result.MockMvcResultHandlers.print;
import static org.springframework.test.web.servlet.result.MockMvcResultMatchers.status;
/**
* 系统用户管理测试类
* @author szk
*/
@RunWith(SpringJUnit4ClassRunner.class)
@WebAppConfiguration(value = "src/main/webapp")
@ContextConfiguration(locations = { "classpath:spring/springmvc.xml", "classpath:mybatis/SqlMapConfig.xml", "classpath:spring/applicationContext.xml"})
public class UserManageServiceImplTest {
@Autowired
private UserManageService userManageService;
@Autowired
private WebApplicationContext wac;
private MockMvc mockMvc;
private MockHttpSession session;
@Before
public void setUp() {
mockMvc = MockMvcBuilders.webAppContextSetup(wac).build();
session = new MockHttpSession();
}
@Test
public void addUser() throws Exception {
// 需要登录
// 发送请求
String sysUserJson = "{ \"username\": \"admin" + new Random().nextInt() + "\", \"password\": \"admin1\", \"passwordrepeat\": \"admin1\", " +
"\"customerid\": \"100010\", \"tel\": \"191717171\", \"status\": \"1\"}";
System.out.println(sysUserJson);
MvcResult result = this.mockMvc.perform(
post("/user/add")
.contentType(MediaType.APPLICATION_JSON)
.content(sysUserJson)
.session((MockHttpSession)getLoginSession()))
.andDo(print())
.andExpect(status().isOk())
// .andExpect(jsonPath("$.msg").value("OK"))
.andReturn();
String content = result.getResponse().getContentAsString();
System.out.println(content);
// System.out.println(userManageService.getUsers(0, 10));
}
@Test
public void addUser1() throws Exception {
ResponseResult result = userManageService.addUser("name"+new Random().nextInt(), "password", 10010, "18283892", "1", null, null);
Assert.assertEquals(result.isOk(), true);
}
@Test
public void addUser2() throws Exception {
// 测试事务回滚
SysUser user = new SysUser();
user.setUsername("name" + new Random().nextInt());
user.setTel("1213123");
user.setStatus("事务回滚测试");
user.setCustomerid(10010);
user.setPassword("passwordPass");
// 角色
List<Integer> roles = new ArrayList<Integer>();
roles.add(1);
// TODO
ResponseResult result = userManageService.addUser(user, roles, null);
}
@Test
public void getUsers() throws Exception {
ResponseResult result = userManageService.getUsers(0, 3);
Page page = (Page)result.getData();
System.out.println(page.getTotal());
System.out.println(page.getResult());
System.out.println(page.size()); // 该页记录数量
for (int i=0; i < page.size(); ++i) {
SysUser tUser = (SysUser) page.get(i);
System.out.println(tUser);
}
}
@Test
public void deleteUser() throws Exception {
ResponseResult result = userManageService.getUsers(0, 3);
System.out.println(result.getData());
Assert.assertTrue(result.getData() instanceof Page);
Page page = (Page)result.getData();
System.out.println(page);
long totalBefore = page.getTotal();
if (page.size() > 0) {
SysUser deleteUser = (SysUser) page.get(0);
System.out.println("删除用户:" + deleteUser);
userManageService.deleteUser(deleteUser.getId());
result = userManageService.getUsers(0, 3);
page = (Page)result.getData();
if (page.size() > 0) {
Assert.assertNotEquals(((SysUser) page.get(0)).getId(), deleteUser.getId());
}
Assert.assertEquals(totalBefore, page.getTotal() + 1);
}
}
/**
* 获取登录session
* @return Session
* @throws Exception E
*/
private HttpSession getLoginSession() throws Exception {
MvcResult result = this.mockMvc.perform(
post("/login/userLogin")
.contentType(MediaType.APPLICATION_FORM_URLENCODED)
.param("account", "admin")
.param("password", "admin"))
.andExpect(status().isOk())
.andDo(print())
.andReturn();
return result.getRequest().getSession();
}
}效果
未插入用户
测试日志如下
/usr/lib/jvm/jdk/bin/java -ea -Didea.test.cyclic.buffer.size=1048576 -javaagent:/home/public/installed/idea/lib/idea_rt.jar=41509:/home/public/installed/idea/bin -Dfile.encoding=UTF-8 -classpath /home/public/installed/idea/lib/idea_rt.jar:/home/public/installed/idea/plugins/junit/lib/junit-rt.jar:/usr/lib/jvm/jdk/jre/lib/charsets.jar:/usr/lib/jvm/jdk/jre/lib/deploy.jar:/usr/lib/jvm/jdk/jre/lib/ext/cldrdata.jar:/usr/lib/jvm/jdk/jre/lib/ext/dnsns.jar:/usr/lib/jvm/jdk/jre/lib/ext/jaccess.jar:/usr/lib/jvm/jdk/jre/lib/ext/jfxrt.jar:/usr/lib/jvm/jdk/jre/lib/ext/localedata.jar:/usr/lib/jvm/jdk/jre/lib/ext/nashorn.jar:/usr/lib/jvm/jdk/jre/lib/ext/sunec.jar:/usr/lib/jvm/jdk/jre/lib/ext/sunjce_provider.jar:/usr/lib/jvm/jdk/jre/lib/ext/sunpkcs11.jar:/usr/lib/jvm/jdk/jre/lib/ext/zipfs.jar:/usr/lib/jvm/jdk/jre/lib/javaws.jar:/usr/lib/jvm/jdk/jre/lib/jce.jar:/usr/lib/jvm/jdk/jre/lib/jfr.jar:/usr/lib/jvm/jdk/jre/lib/jfxswt.jar:/usr/lib/jvm/jdk/jre/lib/jsse.jar:/usr/lib/jvm/jdk/jre/lib/management-agent.jar:/usr/lib/jvm/jdk/jre/lib/plugin.jar:/usr/lib/jvm/jdk/jre/lib/resources.jar:/usr/lib/jvm/jdk/jre/lib/rt.jar:/home/public/workspace/Idea/PowerCloud/target/test-classes:/home/public/workspace/Idea/PowerCloud/target/classes:/home/public/data/maven/repo/joda-time/joda-time/2.5/joda-time-2.5.jar:/home/public/data/maven/repo/org/apache/commons/commons-lang3/3.3.2/commons-lang3-3.3.2.jar:/home/public/data/maven/repo/commons-io/commons-io/1.3.2/commons-io-1.3.2.jar:/home/public/data/maven/repo/commons-net/commons-net/3.3/commons-net-3.3.jar:/home/public/data/maven/repo/com/fasterxml/jackson/core/jackson-databind/2.4.2/jackson-databind-2.4.2.jar:/home/public/data/maven/repo/com/fasterxml/jackson/core/jackson-annotations/2.4.0/jackson-annotations-2.4.0.jar:/home/public/data/maven/repo/com/fasterxml/jackson/core/jackson-core/2.4.2/jackson-core-2.4.2.jar:/home/public/data/maven/repo/org/apache/httpcomponents/httpclient/4.3.5/httpclient-4.3.5.jar:/home/public/data/maven/repo/org/apache/httpcomponents/httpcore/4.3.2/httpcore-4.3.2.jar:/home/public/data/maven/repo/commons-logging/commons-logging/1.1.3/commons-logging-1.1.3.jar:/home/public/data/maven/repo/commons-codec/commons-codec/1.6/commons-codec-1.6.jar:/home/public/data/maven/repo/junit/junit/4.12/junit-4.12.jar:/home/public/data/maven/repo/org/hamcrest/hamcrest-core/1.3/hamcrest-core-1.3.jar:/home/public/data/maven/repo/org/mockito/mockito-core/2.10.0/mockito-core-2.10.0.jar:/home/public/data/maven/repo/net/bytebuddy/byte-buddy/1.7.4/byte-buddy-1.7.4.jar:/home/public/data/maven/repo/net/bytebuddy/byte-buddy-agent/1.7.4/byte-buddy-agent-1.7.4.jar:/home/public/data/maven/repo/org/objenesis/objenesis/2.6/objenesis-2.6.jar:/home/public/data/maven/repo/com/jayway/jsonpath/json-path/2.4.0/json-path-2.4.0.jar:/home/public/data/maven/repo/net/minidev/json-smart/2.3/json-smart-2.3.jar:/home/public/data/maven/repo/net/minidev/accessors-smart/1.2/accessors-smart-1.2.jar:/home/public/data/maven/repo/org/ow2/asm/asm/5.0.4/asm-5.0.4.jar:/home/public/data/maven/repo/org/slf4j/slf4j-api/1.7.25/slf4j-api-1.7.25.jar:/home/public/data/maven/repo/org/slf4j/slf4j-log4j12/1.6.4/slf4j-log4j12-1.6.4.jar:/home/public/data/maven/repo/log4j/log4j/1.2.16/log4j-1.2.16.jar:/home/public/data/maven/repo/org/mybatis/mybatis/3.2.8/mybatis-3.2.8.jar:/home/public/data/maven/repo/org/mybatis/mybatis-spring/1.2.2/mybatis-spring-1.2.2.jar:/home/public/data/maven/repo/com/github/miemiedev/mybatis-paginator/1.2.15/mybatis-paginator-1.2.15.jar:/home/public/data/maven/repo/com/github/pagehelper/pagehelper/3.4.2/pagehelper-3.4.2.jar:/home/public/data/maven/repo/mysql/mysql-connector-java/5.1.32/mysql-connector-java-5.1.32.jar:/home/public/data/maven/repo/com/alibaba/druid/1.0.9/druid-1.0.9.jar:/usr/lib/jvm/jdk/lib/jconsole.jar:/usr/lib/jvm/jdk/lib/tools.jar:/home/public/data/maven/repo/org/springframework/spring-context/4.1.3.RELEASE/spring-context-4.1.3.RELEASE.jar:/home/public/data/maven/repo/org/springframework/spring-aop/4.1.3.RELEASE/spring-aop-4.1.3.RELEASE.jar:/home/public/data/maven/repo/aopalliance/aopalliance/1.0/aopalliance-1.0.jar:/home/public/data/maven/repo/org/springframework/spring-core/4.1.3.RELEASE/spring-core-4.1.3.RELEASE.jar:/home/public/data/maven/repo/org/springframework/spring-expression/4.1.3.RELEASE/spring-expression-4.1.3.RELEASE.jar:/home/public/data/maven/repo/org/springframework/spring-beans/4.1.3.RELEASE/spring-beans-4.1.3.RELEASE.jar:/home/public/data/maven/repo/org/springframework/spring-webmvc/4.1.3.RELEASE/spring-webmvc-4.1.3.RELEASE.jar:/home/public/data/maven/repo/org/springframework/spring-web/4.1.3.RELEASE/spring-web-4.1.3.RELEASE.jar:/home/public/data/maven/repo/org/springframework/spring-jdbc/4.1.3.RELEASE/spring-jdbc-4.1.3.RELEASE.jar:/home/public/data/maven/repo/org/springframework/spring-tx/4.1.3.RELEASE/spring-tx-4.1.3.RELEASE.jar:/home/public/data/maven/repo/org/springframework/spring-aspects/4.1.3.RELEASE/spring-aspects-4.1.3.RELEASE.jar:/home/public/data/maven/repo/org/aspectj/aspectjweaver/1.8.4/aspectjweaver-1.8.4.jar:/home/public/data/maven/repo/org/springframework/spring-test/4.1.3.RELEASE/spring-test-4.1.3.RELEASE.jar:/home/public/data/maven/repo/jstl/jstl/1.2/jstl-1.2.jar:/home/public/data/maven/repo/javax/servlet/javax.servlet-api/3.0.1/javax.servlet-api-3.0.1.jar:/home/public/data/maven/repo/javax/servlet/jsp-api/2.0/jsp-api-2.0.jar:/home/public/data/maven/repo/javax/servlet/servlet-api/2.4/servlet-api-2.4.jar:/home/public/data/maven/repo/commons-fileupload/commons-fileupload/1.3.1/commons-fileupload-1.3.1.jar com.intellij.rt.execution.junit.JUnitStarter -ideVersion5 com.neu.cse.powercloud.serviceImpl.sysmanage.UserManageServiceImplTest,addUser2
2017-10-16 10:11:47,027 [main] [com.neu.cse.powercloud.serviceImpl.sysmanage.UserManageServiceImpl]-[ERROR] java.lang.Exception: 事务回滚测试
java.lang.Exception: 事务回滚测试
at com.neu.cse.powercloud.serviceImpl.sysmanage.UserManageServiceImpl.addUser(UserManageServiceImpl.java:93)
at com.neu.cse.powercloud.serviceImpl.sysmanage.UserManageServiceImplTest.addUser2(UserManageServiceImplTest.java:97)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
at org.springframework.test.context.junit4.statements.RunBeforeTestMethodCallbacks.evaluate(RunBeforeTestMethodCallbacks.java:73)
at org.springframework.test.context.junit4.statements.RunAfterTestMethodCallbacks.evaluate(RunAfterTestMethodCallbacks.java:82)
at org.springframework.test.context.junit4.statements.SpringRepeat.evaluate(SpringRepeat.java:73)
at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:325)
at org.springframework.test.context.junit4.SpringJUnit4ClassRunner.runChild(SpringJUnit4ClassRunner.java:217)
at org.springframework.test.context.junit4.SpringJUnit4ClassRunner.runChild(SpringJUnit4ClassRunner.java:83)
at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
at org.springframework.test.context.junit4.statements.RunBeforeTestClassCallbacks.evaluate(RunBeforeTestClassCallbacks.java:61)
at org.springframework.test.context.junit4.statements.RunAfterTestClassCallbacks.evaluate(RunAfterTestClassCallbacks.java:68)
at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
at org.springframework.test.context.junit4.SpringJUnit4ClassRunner.run(SpringJUnit4ClassRunner.java:163)
at org.junit.runner.JUnitCore.run(JUnitCore.java:137)
at com.intellij.junit4.JUnit4IdeaTestRunner.startRunnerWithArgs(JUnit4IdeaTestRunner.java:68)
at com.intellij.rt.execution.junit.IdeaTestRunner$Repeater.startRunnerWithArgs(IdeaTestRunner.java:51)
at com.intellij.rt.execution.junit.JUnitStarter.prepareStreamsAndStart(JUnitStarter.java:242)
at com.intellij.rt.execution.junit.JUnitStarter.main(JUnitStarter.java:70)
Process finished with exit code 255问题
捕获异常不抛出就不会回滚
解决方法
例如service层处理事务，那么service中的方法中不做异常捕获，或者在catch语句中最后增加throw new RuntimeException()语句，以便让aop捕获异常再去回滚，并且在service上层（webservice客户端，view层action）要继续捕获这个异常并处理
if(userSave){ try { userDao.save(user); userCapabilityQuotaDao.save(capabilityQuota); } catch (Exception e) { logger.info("能力开通接口，开户异常，异常信息："+e); throw new RuntimeException(); } }
在service层方法的catch语句中增加：TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();语句，手动回滚，这样上层就无需去处理异常
if(userSave){ try { userDao.save(user); userCapabilityQuotaDao.save(capabilityQuota); } catch (Exception e) { logger.info("能力开通接口，开户异常，异常信息："+e); TransactionAspectSupport.currentTransactionStatus().setRollbackOnly(); } }
修改后代码
package com.neu.cse.powercloud.serviceImpl.sysmanage;
import com.github.pagehelper.PageHelper;
import com.neu.cse.powercloud.mapper.sysmanage.SysUserMapper;
import com.neu.cse.powercloud.pojo.sysmanage.SysUser;
import com.neu.cse.powercloud.pojo.sysmanage.SysUserExample;
import com.neu.cse.powercloud.service.sysmanage.UserManageService;
import com.neu.cse.powercloud.serviceImpl.PropertiesServiceImpl;
import com.neu.cse.powercloud.util.Exception.ServiceRuntimeException;
import com.neu.cse.powercloud.util.MD5Encoder;
import com.neu.cse.powercloud.util.ResponseResult;
import org.apache.log4j.Logger;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.transaction.interceptor.TransactionAspectSupport;
import java.util.List;
/**
* 用户管理服务实现
* @author szk
*/
@Service
public class UserManageServiceImpl implements UserManageService {
private Logger logger = Logger.getLogger(UserManageServiceImpl.class);
@Autowired(required = true)
private SysUserMapper sysUserMapper;
@Autowired
private PropertiesServiceImpl propertiesServiceImpl;
/**
* 添加系统用户
* @param name 用户名
* @param password 原始(未经md5加密)密码
* @param customerId 客户id
* @param tel 电话
* @param status 状态
* @param roles 角色列表
* @param dataAuthorities 用户数据权限列表
* @return ResponseResult
*/
@Transactional(rollbackFor = Exception.class)
@Override
public ResponseResult addUser(String name, String password, int customerId, String tel, String status,
List<Integer> roles, List<Integer> dataAuthorities) {
SysUser user = new SysUser();
user.setPassword(password);
user.setCustomerid(customerId);
user.setStatus(status);
user.setTel(tel);
user.setUsername(name);
return this.addUser(user, roles, dataAuthorities);
}
/**
* 添加系统用户
* @param user SysUser实例
* @param roles 角色列表
* @param dataAuthorities 用户数据权限列表
* @return ResponseResult
*/
@Transactional(rollbackFor = Exception.class)
@Override
public ResponseResult addUser(SysUser user, List<Integer> roles, List<Integer> dataAuthorities) {
try {
SysUserExample example = new SysUserExample();
SysUserExample.Criteria criteria = example.createCriteria();
criteria.andUsernameEqualTo(user.getUsername());
if (sysUserMapper.selectByExample(example).isEmpty()) { // 判断用户名是否已存在
try {
user.setPassword(MD5Encoder.encoderStringByMD5(user.getPassword())); // 对密码加密
sysUserMapper.insert(user); // 向数据库插入新用户信息
} catch (Exception e) {
throw new ServiceRuntimeException("用户信息错误");
}
// 设置角色
// TODO
// 设置数据权限
// TODO
throw new ServiceRuntimeException("回滚测试");
// return ResponseResult.ok();
} else {
throw new ServiceRuntimeException("用户已存在");
}
} catch (ServiceRuntimeException e) { // 处理自定义异常
logger.error(e);
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly(); // 如果修改数据修改失败，回滚事务
return ResponseResult.no(e.getMessage()); // 返回业务提示信息
} catch (Exception e) { // 处理未知异常
logger.error(e);
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly(); // 如果修改数据修改失败，回滚事务
return ResponseResult.no("未知异常");
}
}
/**
* 获取用户列表
* 获取区间： [start, min(start+length, total))
* @param start 开始索引，从0开始
* @param length 获取长度
* @return ResponseResult
*/
@Override
public ResponseResult getUsers(int start, int length) {
try {
SysUserExample example = new SysUserExample();
int page = start / length + 1; // Page 从1开始
PageHelper.startPage(page, length); // 设置PageHelper；此处开始分页，获取记录必须放在该语句之后
List<SysUser> users = sysUserMapper.selectByExample(example); // 已经被分页
return ResponseResult.ok(users);
} catch (Exception e) {
logger.error(e);
e.printStackTrace();
return ResponseResult.no("未知异常！");
}
}
/**
* 删除指定id用户
*
* @param userId 用户id
* @return 操作结果
*/
@Override
public ResponseResult deleteUser(int userId) {
try {
sysUserMapper.deleteByPrimaryKey(userId);
return ResponseResult.ok();
} catch (Exception e) {
logger.error(e);
return ResponseResult.no("未知异常！");
}
}
}参考
最后更新于
这有帮助吗？