0
1つ以上のクエリが失敗した場合、トランザクションロールバックを達成しようとしています。私のサービス実装クラスに@Transactionalと注釈を付けました。私は意図的に間違ったデータ型amountpaid1（この場合String、Doubleは正しいデータ型です）を送信しました。Spring Jpa @ Transactional not working
今、私の最初の更新クエリとchallanへの挿入が正常に完了しました。
2番目のクエリ、つまりクエリ1が間違ったデータ型を受け取ったときに更新できないため、トランザクション全体がロールバックされることが予想されます。
リポジトリ
@Repository
public class UpdatePaymentImpl implements UpdatePayment {
@PersistenceContext
EntityManager em;
public PaymentResponse getFcgoApiResponse(FcgoUpdateParam updateParam){
PaymentResponse paymentResponse = new PaymentResponse();
try {
final String uri = "http://a.b.c.d:xxxx/FcgoApi/api/savePayment";
RestTemplate restTemplate = new RestTemplate();
paymentResponse = restTemplate.postForObject(uri, updateParam,
PaymentResponse.class);
if (paymentResponse.getVoucherNo() != null) {
int status = updatePayment(updateParam,
paymentResponse.getVoucherNo());
if (status == 0) {
vc.setVoucherNo(paymentResponse.getVoucherNo());
}
}
}catch (Exception ex){
ex.printStackTrace();
logger.info(ex.getMessage());
}
return paymentResponse;
}
@Transactional
public int updatePayment(FcgoUpdateParam updateParam, String voucherno){
try{
String amountPaid1 = updateParam.getAmountPaid();
Double amountPaid=Double.parseDouble(updateParam.getAmountPaid());
String masterId= updateParam.getMasterId();
String advCode=updateParam.getAdvCode();
long uuid = getUniqueID();
logger.info("generated uuid "+uuid);
DateFormat dateFormat =new SimpleDateFormat("dd-MMM-yy h.mm.ss.000000000 a");
SimpleDateFormat dms = new SimpleDateFormat("dd-MM-yyyy");
String cdate = updateParam.getChallanDate();
Date ddate= dms.parse(cdate);
String challandate = dateFormat.format(ddate);
String office = updateParam.getOffice();
String username = updateParam.getUsername();
Long id = getIdOnChallanTable()+1L;
String challanid = String.valueOf(uuid);
ChallanEntity challanEntity = new ChallanEntity();
challanEntity.setAdvtcode(updateParam.getAdvCode());
challanEntity.setAmount(amountPaid);
challanEntity.setName(updateParam.getName());
challanEntity.setOffice(office);
challanEntity.setUsername(username);
challanEntity.setStatus(updateParam.getStatus());
challanEntity.setChallandate(challandate);
challanEntity.setChallanid(uuid);
challanEntity.setChallantime("null");
challanEntity.setVoucherno(voucher no);
Query query= em.createQuery("update
CandidateappearagainstadvtcodeEntity cd set
cd.paymentstatus='Completed',cd.amountpaid=:depoFee,cd.challanid=:challanid
where cd.studentmasterid=:masterid and cd.advertisementcode=:advCode");
logger.info("update parameter advt code: "+updateParam.getAdvCode());
query.setParameter("depoFee",updateParam.getAmountPaid());
query.setParameter("challanid",challanid);
query.setParameter("masterid",masterId);
query.setParameter("advCode",advCode)
.executeUpdate();
Query query1 =em.createQuery(" update CandidateappeartoadvtnumberEntity
cnd set cnd.paymentstatus='Completed', cnd.depositedfee=:depofee where
cnd.studentmasterid=:masterid and cnd.advertisementcode=:advcode");
String masterId1= updateParam.getMasterId();
String advCode1=updateParam.getAdvCode();
query1.setParameter("depofee",amountPaid1);
query1.setParameter("masterid",masterId1);
query1.setParameter("advcode",advCode1)
.executeUpdate();
em.persist(challanEntity);
em.flush();
}
catch (Exception e){
logger.info("update error " +e);
logger.info(e.getMessage());
return 0;
}
return 1 ;
}
}
サービスクラス
@Service
public class UpdatePaymentServiceImpl implements UpdatePaymentService {
@Autowired
UpdatePayment updatePayment;
@Transactional
public PaymentResponse getFcgoApiResponse(FcgoUpdateParam updateParam) {
return updatePayment.getFcgoApiResponse(updateParam);
}
}
applicationContext.xmlを
<bean id="entityManagerFactory" class="org.springframework.
orm.jpa.LocalContainerEntityManagerFactoryBean">
<property name="dataSource" ref="dataSource" />
<property name="packagesToScan" value="com.psc" />
<property name="jpaVendorAdapter">
<bean class="org.springframework.orm.jpa.vendor.
HibernateJpaVendorAdapter" />
</property>
<property name="jpaProperties">
<props>
<prop key="hibernate.hbm2ddl.auto">update</prop>
<prop key="hibernate.dialect">
org.hibernate.dialect.Oracle10gDialect</prop>
<prop key="hibernate.show_sql">true</prop>
</props>
</property>
</bean>
<bean id="transactionManager"
class="org.springframework.orm.jpa.JpaTransactionManager">
<property name="entityManagerFactory"
ref="entityManagerFactory" />
</bean>