使用mybatis批量添加保存报错Cannot change the ExecutorType when there is an existing transaction
报错内容
org.springframework.dao.TransientDataAccessResourceException: Cannot change the ExecutorType when there is an existing transaction
at org.mybatis.spring.SqlSessionUtils.sessionHolder(SqlSessionUtils.java:157)
at org.mybatis.spring.SqlSessionUtils.getSqlSession(SqlSessionUtils.java:91)
at com.baomidou.mybatisplus.core.toolkit.sql.SqlHelper.sqlSessionBatch(SqlHelper.java:55)
at com.baomidou.mybatisplus.extension.service.impl.ServiceImpl.sqlSessionBatch(ServiceImpl.java:75)
at com.baomidou.mybatisplus.extension.service.impl.ServiceImpl.saveOrUpdateBatch(ServiceImpl.java:172)
at com.baomidou.mybatisplus.extension.service.impl.ServiceImpl.saveOrUpdateBatch(ServiceImpl.java:163)
at com.baomidou.mybatisplus.extension.service.impl.ServiceImpl$$FastClassBySpringCGLIB$$76535273.invoke()
实际使用方法(错误示例)
@Override
@Transactional(rollbackFor = Exception.class)
public BaseResp saveOrUpdate(TestPlanParam param) {
//新增、更新
============================================================
省略业务代码
============================================================
//1.新增、更新扑火预案(现在增加主表)
this.saveOrUpdate(planEntity);
Integer testPlanId = planEntity.getId();
List teamEntities=new ArrayList<>();
List resourceEntities=new ArrayList<>();
//2.新增更新扑火队伍(批量增加附表,需要挂上主表的id)
teams.forEach(team->{
PlanTestTeamEntity teamEntity=new PlanTestTeamEntity();
BeanUtil.copyProperties(team,teamEntity);
teamEntity.setFireFightTestPlanId(testPlanId);
//planTestTeamService.saveOrUpdate(teamEntity); 解决方法,采用逐条更新
teamEntities.add(teamEntity);
});
//3.新增更新扑火物资(批量增加附表,需要挂上主表的id)
resources.forEach(res->{
PlanTestResourceEntity resourceEntity=new PlanTestResourceEntity();
BeanUtil.copyProperties(res,resourceEntity);
resourceEntity.setFireFightTestPlanId(testPlanId);
//planTestResourceService.saveOrUpdate(resourceEntity); 解决方法,采用逐条更新
resourceEntities.add(resourceEntity);
});
planTestTeamService.saveOrUpdateBatch(teamEntities);
planTestResourceService.saveOrUpdateBatch(resourceEntities);
return BaseResp.success();
}
报错原因
存在事务时无法更改 ExecutorType
解决方法
批量更新的时候,先把所有更新的对象查出来,然后循环更新