JPA 네이티브 쿼리를 이용해 조회한 Entity를 save하는데 DB에 반영이 안됩니다.

Question

첫 JPA 프로젝트 하는데 걸리는 부분이 많네요.거래 실적 테이블을 조회하여 집계 테이블에 insert하는 로직입니다.간략한 소스 구조는 아래와 같습니다.수행해 보면 오류도 나지않고, 조회 결과 log도 잘 나옵니다. GapSate [GapSateId=GapSateId [dealDt=20200303, storeCode=11111, dealSeq=30001, dealCd=02], dealNo=00003, totalAmount=null] 그런데 결정적으로 insert가 발생하지 않아요. save([Entity Object]), saveAndFlush([Entity Object]), save() 후 flush() 등등 다 해봐도 DB에 생성이 안됩니다.원인은 전혀 모르고, 앞뒤로 delete나 update 네이티브는 정상적으로 작동해요. 네이티브로 select한 것은 영속성? 그 비슷한게 끊어져서 save가 안되는지, 아니면 EmbeddedId 가 문제인지 모르겠어요. 혹시 짐작가는 원인이나 대응방안이 있으시면 답변 부탁드립니다.===================TABLE================ CREATE TABLE GAP_SATE ( DEAL_DT VARCHAR2(20) NOT NULL , STORE_CODE VARCHAR2(20) NOT NULL , DEAL_SEQ NUMBER NOT NULL , DEAL_CD VARCHAR2(20) NOT NULL , DEAL_NO NUMBER , TOTAL_AMOUNT NUMBER , CONSTRAINT GAP_SATE_PK PRIMARY KEY ( DEAL_DT , STORE_CODE , DEAL_SEQ , DEAL_CD ));===================Entity================@Entity@Getter@Setter@Builder@AllArgsConstructor@NoArgsConstructor(access = AccessLevel.PROTECTED)@Table(name = "GAP_SATE")public class GapSate { @EmbeddedId private GapSateId gapSateId; @Column(name = "DEAL_NO") private Integer dealNo; @Column(name = "TOTAL_AMOUNT") private Integer totalAmount; } ===================Embeddable ID================ @Embeddable@Getter@Setter@EqualsAndHashCode(callSuper = false)@AllArgsConstructor@NoArgsConstructor(access = AccessLevel.PROTECTED)public class GapSateId implements Serializable{ private static final long serialVersionUID = 1L; @Column(name = "DEAL_DT") private String dealDt; @Column(name = "STORE_CODE") private String storeCode; @Column(name = "DEAL_SEQ") private Long dealSeq; @Column(name = "DEAL_CD") private String dealCd;} ===================Repository================ @Repositorypublic interface GapSateRepository extends JpaRepository { int deleteByGapSateId_DealDtAndGapSateId_DealCdIn(String dealDt, List dealCds); @Query(value = "SELECT DEAL_DT" + " ,STORE_CODE" + " ,DEAL_SEQ " + " ,DEAL_CD" + " ,DEAL_NO" + " ,TOTAL_AMOUNT" + " FROM DEAL_RT_TABLE" + " WHERE DEAL_DT = :dealDt" + " AND DEAL_CD in :dealCds" , nativeQuery = true ) List findAllGapSate(@Param("dealDt") String dealDt, @Param("pntMgntCd") List dealCds);} ===================Service================ @RequiredArgsConstructor@Service@Slf4j@Transactionalpublic class GapAggService{ private final GapSateRepository gapSateRepository; public void generatPntReconGapInfo(List pntMgntParams) throws Exception { List dealCds = Arrays.asList("01","02"); String errMsg = ""; String dealDt = "20200303"; //기존 작업 내용 삭제 gapSateRepository.deleteByGapSateId_DealDtAndGapSateId_DealCdIn(dealDt, dealCds); //신규 집계 내용 생성 List gapSateList = gapSateRepository.findAllGapSate(dealDt, dealCds); for(GapSate gapSate : gapSateList) { log.debug("GapSate>>"+gapSate.toString());// gapSateRepository.saveAndFlush(gapSate); gapSateRepository.save(gapSate); }// gapSateRepository.flush(); }}

만년초보 · Answer

GapSateId nGapSateId &#61; new GapSateId(&#34;20200303&#34; , &#34;11111&#34; , &#34;1&#34; , &#34;02&#34;); GapSate nGapSate &#61; new GapSate(nGapSateId ,3 ,null);gapSateRepository.save(nGapSate ); 만 하면 정상적으로 insert 되고요. 앞에 List<GapSate> gapSateList &#61; gapSateRepository.findAllGapSate(dealDt, dealCds); 같은 네이티브 쿼리를 수행하면ObjectOptimisticLockingFailureException Error during managed flush [Row was updated or deleted by another transaction (or unsaved-value mapping was incorrect) 이런 Exception 이 발생하네요.

만년초보 · Answer

자체 해결 했습니다.서비스 중간에 delete 와 네이티브 select 가 혼재하니 트랜젝션 충돌이 있었나 봅니다.class 단에 있던 @Transactional 을 지우고, delete와 select save를 따로 트랜젝션 돌게하니 해결이 됩니다. 다만 delete의 목적이 배치 수행을 위한 초기화여서 실패하면 롤백하고 싶은데 불가능할 것 같습니다.아니면 delete를 네이티브로 변경해 보는 방법도 고려해야 할 것 같습니다. ===================Repository================@Repositorypublic interface GapSateRepository extends JpaRepository { @Transactional int deleteByGapSateId_DealDtAndGapSateId_DealCdIn(String dealDt, List dealCds); @Query(value = "SELECT DEAL_DT" + " ,STORE_CODE" + " ,DEAL_SEQ " + " ,DEAL_CD" + " ,DEAL_NO" + " ,TOTAL_AMOUNT" + " FROM DEAL_RT_TABLE" + " WHERE DEAL_DT = :dealDt" + " AND DEAL_CD in :dealCds" , nativeQuery = true ) List findAllGapSate(@Param("dealDt") String dealDt, @Param("dealCds") List dealCds);} ===================Service================@RequiredArgsConstructor@Service@Slf4jpublic class GapAggService{ private final GapSateRepository gapSateRepository; public void generatPntReconGapInfo(List pntMgntParams) throws Exception { List dealCds = Arrays.asList("01","02"); String errMsg = ""; String dealDt = "20200303"; //기존 작업 내용 삭제 gapSateRepository.deleteByGapSateId_DealDtAndGapSateId_DealCdIn(dealDt, dealCds); saveGapInfo(dealDt, dealCds); //별도 트랜젝션 함수로 분리 } @Transactional private void saveGapInfo(String dealDt, List dealCds) throws Exception { /* 차이내역 생성 */ List gapSateList = gapSateRepository.findAllGapSate(saleDt, dealCds); gapSateRepository.saveAll(gapSateList); gapSateRepository.flush(); }}

JPA 네이티브 쿼리를 이용해 조회한 Entity를 save하는데 DB에 반영이 안됩니다.

2개의 답변

#save 목록