트리거¶

1. 트리거 개념¶

트리거는 특정 이벤트(INSERT, UPDATE, DELETE)가 발생할 때 자동으로 실행되는 함수입니다.

┌─────────────┐     ┌─────────────┐     ┌─────────────┐
│   INSERT    │ ──▶ │   TRIGGER   │ ──▶ │  자동 실행  │
│   UPDATE    │     │   (감시)    │     │  (트리거    │
│   DELETE    │     │             │     │   함수)     │
└─────────────┘     └─────────────┘     └─────────────┘

2. 트리거 구성요소¶

트리거 함수: 실행할 로직
트리거: 언제, 어떤 테이블에서 함수를 실행할지 정의

트리거 함수 생성¶

CREATE FUNCTION trigger_function_name()
RETURNS TRIGGER
AS $$
BEGIN
    -- 로직
    RETURN NEW;  -- 또는 RETURN OLD; 또는 RETURN NULL;
END;
$$ LANGUAGE plpgsql;

트리거 생성¶

CREATE TRIGGER trigger_name
{BEFORE | AFTER | INSTEAD OF} {INSERT | UPDATE | DELETE}
ON table_name
[FOR EACH ROW | FOR EACH STATEMENT]
EXECUTE FUNCTION trigger_function_name();

3. BEFORE vs AFTER¶

BEFORE 트리거¶

이벤트 발생 전에 실행됩니다. 데이터를 검증하거나 수정할 수 있습니다.

-- 가격이 0 이하면 오류 발생
CREATE FUNCTION check_price()
RETURNS TRIGGER AS $$
BEGIN
    IF NEW.price <= 0 THEN
        RAISE EXCEPTION '가격은 0보다 커야 합니다.';
    END IF;
    RETURN NEW;
END;
$$ LANGUAGE plpgsql;

CREATE TRIGGER before_insert_product
BEFORE INSERT ON products
FOR EACH ROW
EXECUTE FUNCTION check_price();

AFTER 트리거¶

이벤트 발생 후에 실행됩니다. 감사 로그, 알림 등에 사용합니다.

-- 주문 생성 후 재고 차감
CREATE FUNCTION update_stock()
RETURNS TRIGGER AS $$
BEGIN
    UPDATE products
    SET stock = stock - NEW.quantity
    WHERE id = NEW.product_id;
    RETURN NEW;
END;
$$ LANGUAGE plpgsql;

CREATE TRIGGER after_insert_order_item
AFTER INSERT ON order_items
FOR EACH ROW
EXECUTE FUNCTION update_stock();

4. NEW vs OLD¶

변수	INSERT	UPDATE	DELETE
`NEW`	새 행	새 행	없음
`OLD`	없음	기존 행	삭제될 행

-- UPDATE 시 변경 전후 값 비교
CREATE FUNCTION log_price_change()
RETURNS TRIGGER AS $$
BEGIN
    IF OLD.price <> NEW.price THEN
        INSERT INTO price_history (product_id, old_price, new_price)
        VALUES (NEW.id, OLD.price, NEW.price);
    END IF;
    RETURN NEW;
END;
$$ LANGUAGE plpgsql;

CREATE TRIGGER after_update_price
AFTER UPDATE OF price ON products
FOR EACH ROW
EXECUTE FUNCTION log_price_change();

5. FOR EACH ROW vs FOR EACH STATEMENT¶

FOR EACH ROW¶

각 행마다 트리거가 실행됩니다.

-- 각 행에 대해 실행
CREATE TRIGGER row_trigger
AFTER INSERT ON products
FOR EACH ROW
EXECUTE FUNCTION my_function();

-- INSERT INTO products VALUES (...), (...), (...);
-- → 3번 실행

FOR EACH STATEMENT¶

문장당 한 번만 실행됩니다.

-- 문장당 한 번만 실행
CREATE TRIGGER statement_trigger
AFTER INSERT ON products
FOR EACH STATEMENT
EXECUTE FUNCTION my_function();

-- INSERT INTO products VALUES (...), (...), (...);
-- → 1번 실행

6. 조건부 트리거 (WHEN)¶

-- 가격이 100만원 이상일 때만 실행
CREATE TRIGGER high_price_alert
AFTER INSERT ON products
FOR EACH ROW
WHEN (NEW.price >= 1000000)
EXECUTE FUNCTION send_alert();

7. 실습 예제¶

실습 1: 자동 타임스탬프¶

-- updated_at 자동 갱신
CREATE FUNCTION update_timestamp()
RETURNS TRIGGER AS $$
BEGIN
    NEW.updated_at = NOW();
    RETURN NEW;
END;
$$ LANGUAGE plpgsql;

-- 테이블에 적용
CREATE TABLE articles (
    id SERIAL PRIMARY KEY,
    title VARCHAR(200),
    content TEXT,
    created_at TIMESTAMP DEFAULT NOW(),
    updated_at TIMESTAMP DEFAULT NOW()
);

CREATE TRIGGER set_updated_at
BEFORE UPDATE ON articles
FOR EACH ROW
EXECUTE FUNCTION update_timestamp();

-- 테스트
INSERT INTO articles (title, content) VALUES ('제목', '내용');
SELECT * FROM articles;

UPDATE articles SET content = '수정된 내용' WHERE id = 1;
SELECT * FROM articles;  -- updated_at 자동 갱신됨

실습 2: 감사 로그¶

-- 감사 로그 테이블
CREATE TABLE audit_log (
    id SERIAL PRIMARY KEY,
    table_name VARCHAR(50),
    operation VARCHAR(10),
    old_data JSONB,
    new_data JSONB,
    changed_by VARCHAR(100),
    changed_at TIMESTAMP DEFAULT NOW()
);

-- 감사 트리거 함수
CREATE FUNCTION audit_trigger()
RETURNS TRIGGER AS $$
BEGIN
    IF TG_OP = 'INSERT' THEN
        INSERT INTO audit_log (table_name, operation, new_data, changed_by)
        VALUES (TG_TABLE_NAME, 'INSERT', row_to_json(NEW)::JSONB, current_user);
        RETURN NEW;

    ELSIF TG_OP = 'UPDATE' THEN
        INSERT INTO audit_log (table_name, operation, old_data, new_data, changed_by)
        VALUES (TG_TABLE_NAME, 'UPDATE', row_to_json(OLD)::JSONB, row_to_json(NEW)::JSONB, current_user);
        RETURN NEW;

    ELSIF TG_OP = 'DELETE' THEN
        INSERT INTO audit_log (table_name, operation, old_data, changed_by)
        VALUES (TG_TABLE_NAME, 'DELETE', row_to_json(OLD)::JSONB, current_user);
        RETURN OLD;
    END IF;
END;
$$ LANGUAGE plpgsql;

-- 트리거 적용
CREATE TRIGGER users_audit
AFTER INSERT OR UPDATE OR DELETE ON users
FOR EACH ROW
EXECUTE FUNCTION audit_trigger();

-- 테스트
INSERT INTO users (name, email) VALUES ('감사테스트', 'audit@test.com');
UPDATE users SET name = '감사수정' WHERE email = 'audit@test.com';
DELETE FROM users WHERE email = 'audit@test.com';

SELECT * FROM audit_log;

실습 3: 재고 관리¶

-- 재고 테이블
CREATE TABLE inventory (
    product_id INTEGER PRIMARY KEY,
    quantity INTEGER DEFAULT 0,
    reserved INTEGER DEFAULT 0
);

-- 주문 시 재고 예약
CREATE FUNCTION reserve_stock()
RETURNS TRIGGER AS $$
DECLARE
    available INTEGER;
BEGIN
    SELECT quantity - reserved INTO available
    FROM inventory
    WHERE product_id = NEW.product_id;

    IF available < NEW.quantity THEN
        RAISE EXCEPTION '재고 부족: 가용 재고 %, 요청 %', available, NEW.quantity;
    END IF;

    UPDATE inventory
    SET reserved = reserved + NEW.quantity
    WHERE product_id = NEW.product_id;

    RETURN NEW;
END;
$$ LANGUAGE plpgsql;

CREATE TRIGGER before_order_item
BEFORE INSERT ON order_items
FOR EACH ROW
EXECUTE FUNCTION reserve_stock();

-- 주문 완료 시 실제 재고 차감
CREATE FUNCTION complete_stock()
RETURNS TRIGGER AS $$
BEGIN
    IF NEW.status = 'completed' AND OLD.status <> 'completed' THEN
        UPDATE inventory
        SET quantity = quantity - oi.quantity,
            reserved = reserved - oi.quantity
        FROM order_items oi
        WHERE oi.order_id = NEW.id
          AND inventory.product_id = oi.product_id;
    END IF;
    RETURN NEW;
END;
$$ LANGUAGE plpgsql;

CREATE TRIGGER after_order_complete
AFTER UPDATE ON orders
FOR EACH ROW
EXECUTE FUNCTION complete_stock();

실습 4: 데이터 유효성 검사¶

-- 이메일 중복 검사 (대소문자 무시)
CREATE FUNCTION check_email_unique()
RETURNS TRIGGER AS $$
BEGIN
    IF EXISTS (
        SELECT 1 FROM users
        WHERE LOWER(email) = LOWER(NEW.email)
          AND id <> COALESCE(NEW.id, -1)
    ) THEN
        RAISE EXCEPTION '이메일이 이미 존재합니다: %', NEW.email;
    END IF;
    RETURN NEW;
END;
$$ LANGUAGE plpgsql;

CREATE TRIGGER before_user_email
BEFORE INSERT OR UPDATE OF email ON users
FOR EACH ROW
EXECUTE FUNCTION check_email_unique();

8. 트리거 관리¶

트리거 목록 확인¶

-- 테이블의 트리거 확인
SELECT tgname, tgtype, proname
FROM pg_trigger t
JOIN pg_proc p ON t.tgfoid = p.oid
WHERE tgrelid = 'users'::regclass;

-- 또는
\dS users

트리거 비활성화/활성화¶

-- 특정 트리거 비활성화
ALTER TABLE users DISABLE TRIGGER users_audit;

-- 모든 트리거 비활성화
ALTER TABLE users DISABLE TRIGGER ALL;

-- 활성화
ALTER TABLE users ENABLE TRIGGER users_audit;
ALTER TABLE users ENABLE TRIGGER ALL;

트리거 삭제¶

DROP TRIGGER trigger_name ON table_name;
DROP TRIGGER IF EXISTS trigger_name ON table_name;

9. 트리거 TG_ 변수¶

변수	설명
`TG_NAME`	트리거 이름
`TG_TABLE_NAME`	테이블 이름
`TG_TABLE_SCHEMA`	스키마 이름
`TG_OP`	작업 (INSERT, UPDATE, DELETE)
`TG_WHEN`	BEFORE 또는 AFTER
`TG_LEVEL`	ROW 또는 STATEMENT

CREATE FUNCTION debug_trigger()
RETURNS TRIGGER AS $$
BEGIN
    RAISE NOTICE 'Trigger: %, Table: %, Op: %, When: %',
        TG_NAME, TG_TABLE_NAME, TG_OP, TG_WHEN;
    RETURN NEW;
END;
$$ LANGUAGE plpgsql;

10. 주의사항¶

무한 루프 방지¶

-- 나쁜 예: 트리거가 자신을 다시 호출
CREATE FUNCTION bad_trigger()
RETURNS TRIGGER AS $$
BEGIN
    UPDATE same_table SET ...;  -- 같은 테이블 UPDATE → 무한 루프!
    RETURN NEW;
END;
$$ LANGUAGE plpgsql;

성능 고려¶

-- 트리거는 모든 작업에 오버헤드 추가
-- 대량 데이터 처리 시 트리거 비활성화 고려

ALTER TABLE users DISABLE TRIGGER ALL;
-- 대량 INSERT/UPDATE
ALTER TABLE users ENABLE TRIGGER ALL;

디버깅¶

-- RAISE NOTICE로 디버깅
CREATE FUNCTION debug_function()
RETURNS TRIGGER AS $$
BEGIN
    RAISE NOTICE 'OLD: %, NEW: %', OLD, NEW;
    RETURN NEW;
END;
$$ LANGUAGE plpgsql;

다음 단계¶

13_Backup_and_Operations.md에서 백업과 운영을 배워봅시다!