如何解决事务性不会在使用Data JPA的Spring Boot中回退已检查的异常
我有一个ProcessRecon
用例类,有一个名为execute
的方法。它使用Reconciliation
保存实体paymentRepository.saveRecon
,并使用paymentRepository.sendReconAck
调用Web服务作为确认的一部分。
现在,这种外部Web服务可能会失败,在这种情况下,我想回滚更改,即保存的实体。由于我使用的是Unirest,因此会抛出UnirestException,这是一个已检查的异常。
控制台上没有错误,但这可能会有所帮助。 [更新] 。
2020-08-20 17:21:42,035 DEBUG [http-nio-7012-exec-6] org.springframework.transaction.support.AbstractPlatformTransactionManager: Creating new transaction with name [com.eyantra.payment.features.payment.domain.usecases.ProcessRecon.execute]:PROPAGATION_required,ISOLATION_DEFAULT,-com.mashape.unirest.http.exceptions.UnirestException
...
2020-08-20 17:21:44,041 DEBUG [http-nio-7012-exec-2] org.springframework.transaction.support.AbstractPlatformTransactionManager: Initiating transaction rollback
2020-08-20 17:21:44,044 DEBUG [http-nio-7012-exec-2] org.springframework.orm.jpa.JpaTransactionManager: Rolling back JPA transaction on EntityManager [SessionImpl(621663440<open>)]
2020-08-20 17:21:44,059 DEBUG [http-nio-7012-exec-2] org.springframework.orm.jpa.JpaTransactionManager: Not closing pre-bound JPA EntityManager after transaction
2020-08-20 17:22:40,020 DEBUG [http-nio-7012-exec-2] org.springframework.orm.jpa.support.OpenEntityManagerInViewInterceptor: Closing JPA EntityManager in OpenEntityManagerInViewInterceptor
此刻我看到的是即使存在UnirestException
,实体也被推送到数据库。但我希望没有数据保存到数据库。
我正在将Spring Boot 2.3.3与MysqL 5.7一起使用。这是我的代码。
ProcessRecon.java
@Usecase // this custom annotation is derived from @service
public class ProcessRecon {
private final PaymentRepository paymentRepository;
@Autowired
public ProcessRecon(PaymentRepository paymentRepository) {
this.paymentRepository = paymentRepository;
}
@Transactional(rollbackFor = UnirestException.class)
public Reconciliation execute(final Reconciliation reconciliation) throws UnirestException {
PaymentDetails paymentDetails = paymentRepository.getByReqId(reconciliation.getReqId());
if (paymentDetails == null)
throw new EntityNotFoundException(ExceptionMessages.PAYMENT_DETAILS_NOT_FOUND);
reconciliation.setPaymentDetails(paymentDetails);
Long transId = null;
if (paymentDetails.getImmediateResponse() != null)
transId = paymentDetails.getImmediateResponse().getTransId();
if (transId != null)
reconciliation.setTransId(transId);
if (reconciliation.getTransId() == null)
throw new ValidationException("transId should be provided in Reconciliation if there is no immediate" +
" response for a particular reqId!");
// THIS GETS SAVED
Reconciliation savedRecon = paymentRepository.saveRecon(reconciliation);
paymentDetails.setReconciliation(savedRecon);
// IF THROWS SOME ERROR,ROLLBACK
paymentRepository.sendReconAck(reconciliation);
return savedRecon;
}
}
PaymentRepositoryImpl.java
@CleanRepository
public class PaymentRepositoryImpl implements PaymentRepository {
@Override
public String sendReconAck(final Reconciliation recon) throws UnirestException {
// AckNowledge OP
return sendAck(recon.getRequestType(),recon.getTransId());
}
String sendAck(final String requestType,final Long transId) throws UnirestException {
// Todo: Check if restTemplate can work with characters (requestType)
final Map<String,Object> queryParams = new HashMap<String,Object>();
queryParams.put("transId",transId);
queryParams.put("requestType",requestType);
logger.debug("{}",queryParams);
final HttpResponse<String> result = Unirest.get(makeAckUrl()).queryString(queryParams).asstring();
logger.debug("Output of ack with queryParams {} is {}",queryParams,result.getBody());
return result.getBody();
}
@Override
public Reconciliation saveRecon(final Reconciliation recon) {
try {
return reconDS.save(recon);
}
catch (DataIntegrityViolationException ex) {
throw new EntityExistsException(ExceptionMessages.CONSTRAINT_VIOLATION);
}
}
}
ReconciliationDatasource.java
@Datasource // extends from @Repository
public interface ReconciliationDatasource extends JpaRepository<Reconciliation,Long> {
List<Reconciliation> findByPaymentDetails_User_Id(Long userId);
}
解决方法
要使注释生效,您必须使用接口而不是使用类进行依赖项注入。
interface ProcessRecon {
Reconciliation execute(final Reconciliation reconciliation)
throws UnirestException;
}
然后
@Usecase
public class ProcessReconImpl implements ProcessRecon {
private final PaymentRepository paymentRepository;
@Autowired
public ProcessReconImpl(PaymentRepository paymentRepository) {
this.paymentRepository = paymentRepository;
}
@Transactional(rollbackFor = UnirestException.class)
public Reconciliation execute(final Reconciliation reconciliation) throws UnirestException {
//method implementation...
}
}
用法
@Autowired
ProcessRecon processRecon;
public void executeServiceMethod(Reconciliation reconciliation) {
processRecon.execute(reconciliation)
}
通过这种方式,您可以获得ProcessReconImpl
的代理,并通过注释提供了其他功能。
我假设这些表的默认引擎为 InnoDB ,但是我想知道,这些表是使用 MyISAM 引擎创建的,该引擎不支持事务。
我通过使用下面的属性here
解决了该问题spring.jpa.database-platform=org.hibernate.dialect.MySQL5InnoDBDialect
代替
spring.jpa.properties.hibernate.dialect=org.hibernate.dialect.MySQL5Dialect
这是唯一需要的更改。谢谢!
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。