[MyBatis/Oracle] Sequence를 포함한 Bulk Insert(다중 행 삽입)

처음에는 아래와 같은 방법으로 다중 행 삽입을 구현했었다.

오라클의 INSERT ALL과 MyBatis의 foreach를 혼합 사용하여 INSERT ALL 이후의 INTO ~ VALUES를 반복하는 것이다.

 

이 테이블은 REPORT_MEMBER 시퀀스 값을 가져와 PK로 사용하는데,

이처럼 INSERT 시 시퀀스를 사용하는 경우에는 일반적인 BULK INSERT를 사용할 수 없다.

(하나의 행으로 인식하여 시퀀스를 한 번만 호출함. 무결성 오류 발생)

### Error updating database.  Cause: java.sql.SQLIntegrityConstraintViolationException: ORA-00001: 무결성 제약 조건(INTERN_TASK.PK_REPORT_MEMBER)에 위배됩니다

 

 

INSERT ALL 이후에 INTO VALUES만 반복시켜서 그런가 하고

INSERT INTO VALUES로 단일행을 여러 번 실행해보기도 했는데

 

### Error updating database.  Cause: java.sql.SQLSyntaxErrorException: ORA-00933: SQL 명령어가 올바르게 종료되지 않았습니다

 

오라클에서는 한 번에 여러 개의 INSERT 실행이 불가하다고 함 ...

여러 개의 INSERT INTO VALUES를 하나의 쿼리로 인식해서 잘못된 쿼리 오류가 나는 상황

 

처음엔 구분자 오류인줄 알고 콤마도 붙여보고 공백도 띄워보고 세미콜론도 붙여보고 위치도 옮겨보고 난리를 쳤는데 아니더라

 

때문에 아래와 같이 UNION ALL을 사용하는 방식으로 변경하였고, 쿼리 동작까지 확인하였다.

 

<!-- 내부 SELECT에서 foreach 사용 → 각 memberId를 UNION ALL로 병합
         각 UNION ALL 결과에 대해 개별적으로 REPORT_MEMBER_SEQ.NEXTVAL 호출 (Sequence값 PK) -->

    <insert id="saveReportMember">
        INSERT INTO INTERN_TASK.REPORT_MEMBER (ID, REPORT_ID, MEMBER_ID, CREATED_AT, CREATED_BY)
        SELECT REPORT_MEMBER_SEQ.NEXTVAL, reportId, memberId, SYSDATE, createdBy
        FROM (
        <foreach collection="reportMembers" item="member" open="(" separator=" UNION ALL " close=")">
            SELECT #{member.reportId} AS reportId, #{member.memberId} AS memberId, #{member.createdBy}
            AS createdBy FROM DUAL
        </foreach>
        )
    </insert>

 

INSERT ALL을 사용하는 것보다 속도 측면에서도 빠르다는 벤치마킹 자료를 봤는데, 회사 업무에서 하나의 SQL 쿼리가 길어지면 운영 환경에서의 모니터링이 힘들다고 ... 단일 행을 여러 번 호출하는 구조로 변경하라고 지시 받음

 

나 저거 해결방법 찾느라 거의 이틀 삽질했는데 또 삽질을 해

 

결국 비즈니스 로직에서 단일 INSERT문 여러 번 호출하는 방법으로 바꾸기로 함

 

// 2. REPORT_MEMBER
if (reportMemberReqDTO.getMemberIds() != null && !reportMemberReqDTO.getMemberIds().isEmpty()) {
    List<ReportMember> reportMemberList = reportMemberReqDTO.toDomains(reportId, createMemberId);

    for (ReportMember reportMember : reportMemberList) {
        reportCommandOutPort.saveReportMember(reportMember); // 개별 Insert 실행
    }
}

<insert id="saveReportMember">
    INSERT INTO INTERN_TASK.REPORT_MEMBER (ID, REPORT_ID, MEMBER_ID, CREATED_AT, CREATED_BY)
    VALUES (REPORT_MEMBER_SEQ.NEXTVAL, #{reportId}, #{memberId}, SYSDATE, #{createdBy})
</insert>