java - 添加了@Tansactional，但是显式抛出检查异常时回滚仍然没有发生

Question

@Transactional(value="txManager", rollbackFor = DriverReassignmentException.class)
    public UserLoadAssocResponse<List<AssociateResponse>, UserLoadAssocResponseStatus> reassignAssignedLoad(String user, String scac, String adminId, DriverLoadAssocDetails driverLoadAssocDetails) throws DriverReassignmentException{

        UserLoadAssocResponse<Boolean, UserLoadAssocResponseStatus> removeUserResponse =null;

        UserLoadAssocResponse<List<AssociateResponse>, UserLoadAssocResponseStatus> userLoadAssignedResponse=null;

        if(!(StringUtils.isEmpty(driverLoadAssocDetails.getOrderNumber()) && StringUtils.isEmpty(user) && StringUtils.isEmpty(scac) && StringUtils.isEmpty(adminId))){
            try {
                removeUserResponse = this.userLoadAssociationClient.removeUserFromAssignedLoad(user, scac, driverLoadAssocDetails.getOrderNumber(),adminId, Constant.INTRANSIT);
            } catch (Exception e) {
                removeUserResponse = UserLoadAssocResponse.failure(UserLoadAssocResponseStatus.UNEXPECTED_ERROR);
                log.error("Unable to remove user {} from load {} scac: {} adminUser: {} admin", user, driverLoadAssocDetails.getOrderNumber(), scac, adminId, e);
            }
        } else{
            log.error("Insufficient data present to remove user {} from load {} scac: {} adminUser: {} admin", user, driverLoadAssocDetails.getOrderNumber()!=null?driverLoadAssocDetails.getOrderNumber():null, scac, adminId);
            return UserLoadAssocResponse.failure(UserLoadAssocResponseStatus.UNEXPECTED_ERROR);

        }

        if(removeUserResponse.isSuccess() && removeUserResponse.getStatus().toString().equalsIgnoreCase(UserLoadAssocResponseStatus.SUCCESS.toString())){
            try {
                userLoadAssignedResponse = this.associateSingleUserSingleLoad(scac, adminId, driverLoadAssocDetails);
            }catch(Exception ex){
                log.error("Unexpected error occured while assigning single load for carrierCode {} - {}", scac, ex);
                throw new DriverReassignmentException(UserLoadAssocResponseStatus.UNEXPECTED_ERROR.name());
            }
        }else{
            return UserLoadAssocResponse.failure(removeUserResponse.getStatus());
        }

        if(userLoadAssignedResponse.isSuccess() && userLoadAssignedResponse.getStatus().toString().equalsIgnoreCase(UserLoadAssocResponseStatus.SUCCESS.toString())){
            log.info("Load reassigned succesfully:{}", userLoadAssignedResponse);
            return userLoadAssignedResponse;
        }else{
            log.error("Error occured while assigning single load for carrierCode {}", scac);
            throw new DriverReassignmentException("Load reassigned Unsuccesfull");

        }

    }

// expecting to rollback this.userLoadAssociationClient.removeUserFromAssignedLoad(user, scac, driverLoadAssocDetails.getOrderNumber(),adminId, Constant.INTRANSIT) 

当抛出 new DriverReassignmentException("Load resigned Unsuccesfull") 时。但不是可以实现的

Answer 1

可能的实际错误

删除以下行中的 return 语句:

return UserLoadAssocResponse.failure

我认为您从该方法返回时没有评估会抛出正确异常的 if 条件。

额外的调试

你的逻辑有问题。真正调试事务注释是否正常工作的最佳方法是将以下行添加为方法的最后一行但不带 if 语句

throw new DriverReassignmentException("Load reassigned Unsuccessful");

然后您将能够评估是否发生回滚，因为您将知道对于每个请求，您都会抛出特定的异常。

然后，注释掉抛出，您应该注意到您的数据已保存，并且没有发生异常。

问题出在if 语句的条件上。您需要调试逻辑并了解为什么 if 语句 的计算结果不为 true。