대량 데이터 처리와 배치

-- 느림: 애플리케이션에서 10만 번 반복
--   for (Order o : orders) { insert(o); }

-- 빠름: 한 문장으로 집합 처리
INSERT INTO order_summary (customer_id, order_cnt, total_amount, base_dt)
SELECT customer_id,
       COUNT(*),
       SUM(amount),
       TRUNC(SYSDATE)
FROM   orders
WHERE  order_dt >= TRUNC(SYSDATE) - 1
AND    order_dt <  TRUNC(SYSDATE)
GROUP BY customer_id;

DECLARE
  TYPE t_ids IS TABLE OF orders.order_id%TYPE;
  v_ids t_ids;

  CURSOR c IS
    SELECT order_id FROM orders
    WHERE  status_cd = 'READY' AND order_dt < SYSDATE - 30;
BEGIN
  OPEN c;
  LOOP
    FETCH c BULK COLLECT INTO v_ids LIMIT 5000;   -- 5000건씩 묶어서
    EXIT WHEN v_ids.COUNT = 0;

    FORALL i IN 1 .. v_ids.COUNT                  -- 한 번에 전달
      UPDATE orders SET status_cd = 'EXPIRED'
      WHERE  order_id = v_ids(i);

    COMMIT;
  END LOOP;
  CLOSE c;
END;
/

LIMIT 없이 BULK COLLECT 하면 전체를 메모리에 올려 PGA가 터질 수 있습니다. 수천 건 단위로 끊는 것이 기본입니다. 단순 조건이면 이런 반복 없이 UPDATE 한 문장이 더 낫습니다.

INSERT /*+ APPEND */ INTO order_archive
SELECT * FROM orders WHERE order_dt < ADD_MONTHS(SYSDATE, -12);

COMMIT;   -- 커밋해야 다른 세션과 자기 세션 모두 조회 가능

커밋 전에 같은 테이블을 조회하면 ORA-12838 이 납니다. 오류가 아니라 정상 동작이니 적재 후 커밋하고 진행합니다.

-- 1) 남길 데이터만 새 테이블로
CREATE TABLE orders_new AS
SELECT * FROM orders WHERE order_dt >= ADD_MONTHS(SYSDATE, -12);

-- 2) 인덱스와 제약조건을 새 테이블에 동일하게 생성
--    (기존 정의를 미리 스크립트로 뽑아 둡니다)

-- 3) 이름 교체
ALTER TABLE orders     RENAME TO orders_old;
ALTER TABLE orders_new RENAME TO orders;

-- 4) 확인 후 정리
DROP TABLE orders_old PURGE;

3번 단계에서 잠깐 테이블이 없는 순간이 있습니다. 무중단이 필요하면 이 방식은 맞지 않습니다. 또 기존 인덱스·제약·권한·트리거를 빠짐없이 옮겼는지 확인해야 합니다. 절차가 많아 실수하기 쉬우므로 사전에 스크립트로 준비합니다.

CREATE TABLE orders_part (
  order_id    NUMBER,
  customer_id NUMBER,
  order_dt    DATE NOT NULL,
  amount      NUMBER(12, 2)
)
PARTITION BY RANGE (order_dt)
INTERVAL (NUMTOYMINTERVAL(1, 'MONTH'))   -- 월별 자동 생성
(
  PARTITION p_init VALUES LESS THAN (DATE '2026-01-01')
);

-- 12개월 지난 데이터를 파티션째 제거 (초 단위로 끝납니다)
ALTER TABLE orders_part DROP PARTITION FOR (DATE '2025-01-15');

INTERVAL 을 쓰면 새 기간의 데이터가 들어올 때 파티션이 자동으로 만들어집니다. 매달 파티션을 미리 추가하는 운영 작업이 사라집니다.

-- 1) 건수
SELECT (SELECT COUNT(*) FROM orders_old) AS old_cnt,
       (SELECT COUNT(*) FROM orders_new) AS new_cnt
FROM DUAL;

-- 2) 합계
SELECT (SELECT SUM(amount) FROM orders_old) AS old_sum,
       (SELECT SUM(amount) FROM orders_new) AS new_sum
FROM DUAL;

-- 3) NULL 건수 (빈 문자열 문제 확인)
SELECT COUNT(*) - COUNT(status_cd) AS null_status_old FROM orders_old;
SELECT COUNT(*) - COUNT(status_cd) AS null_status_new FROM orders_new;

-- 4) 값 대사 (양방향 모두 0건이어야 함)
SELECT COUNT(*) FROM (
  SELECT order_id, status_cd, amount FROM orders_old
  MINUS
  SELECT order_id, status_cd, amount FROM orders_new
);