PostgreSQL 03000 오류 원인과 해결 방법 완벽 가이드

DO $$
DECLARE
    cur CURSOR FOR SELECT id, name FROM users WHERE active = true;
    rec RECORD;
BEGIN
    OPEN cur;
    FETCH cur INTO rec;
    -- 작업 중 조기 탈출 또는 커서를 닫지 않음
    IF rec.id = 1 THEN
        RETURN; -- 커서가 열린 채로 종료됨
    END IF;
    -- CLOSE cur; 누락
END;
$$;

DO $$
DECLARE
    cur CURSOR FOR SELECT id, name FROM users WHERE active = true;
    rec RECORD;
BEGIN
    OPEN cur;

    LOOP
        FETCH cur INTO rec;
        EXIT WHEN NOT FOUND;

        -- 실제 작업 수행
        RAISE NOTICE 'Processing user: %', rec.name;

        -- 조기 종료가 필요할 경우에도 CLOSE 후 탈출
        IF rec.id = 999 THEN
            CLOSE cur;
            RETURN;
        END IF;
    END LOOP;

    CLOSE cur; -- 반드시 명시적 종료

EXCEPTION
    WHEN OTHERS THEN
        -- 예외 발생 시에도 커서 닫기
        IF cur IS NOT NULL THEN
            CLOSE cur;
        END IF;
        RAISE;
END;
$$;

CREATE OR REPLACE FUNCTION get_table_count(p_table_name TEXT)
RETURNS INTEGER AS $$
DECLARE
    v_sql TEXT;
    v_count INTEGER;
BEGIN
    -- 위험: 입력값 검증 없이 직접 문자열 연결
    v_sql := 'SELECT COUNT(*) FROM ' || p_table_name;
    -- 만약 p_table_name이 NULL이거나 비어있으면 불완전한 SQL 생성
    EXECUTE v_sql INTO v_count;
    RETURN v_count;
END;
$$ LANGUAGE plpgsql;

CREATE OR REPLACE FUNCTION get_table_count(p_schema TEXT, p_table_name TEXT)
RETURNS INTEGER AS $$
DECLARE
    v_sql TEXT;
    v_count INTEGER;
BEGIN
    -- 입력값 NULL 검증
    IF p_table_name IS NULL OR trim(p_table_name) = '' THEN
        RAISE EXCEPTION 'Table name cannot be NULL or empty';
    END IF;

    -- format() 함수로 안전하게 식별자 처리 (%I = identifier quoting)
    v_sql := format(
        'SELECT COUNT(*) FROM %I.%I',
        COALESCE(p_schema, 'public'),
        p_table_name
    );

    -- 디버깅용 로그 (운영 환경에서는 DEBUG 레벨로 조정)
    RAISE DEBUG 'Executing SQL: %', v_sql;

    EXECUTE v_sql INTO v_count;
    RETURN v_count;

EXCEPTION
    WHEN OTHERS THEN
        RAISE EXCEPTION 'Failed to execute dynamic SQL [%]: %', v_sql, SQLERRM;
END;
$$ LANGUAGE plpgsql;

-- 호출 예시
SELECT get_table_count('public', 'users');
SELECT get_table_count(NULL, 'orders');

-- 올바른 트랜잭션 블록 처리 예시
DO $$
BEGIN
    -- 1단계: 임시 테이블 생성 (완전히 완료 후 다음 단계로)
    CREATE TEMP TABLE IF NOT EXISTS temp_processing (
        id SERIAL PRIMARY KEY,
        data TEXT,
        processed_at TIMESTAMPTZ DEFAULT NOW()
    );

    -- 2단계: 데이터 삽입
    INSERT INTO temp_processing (data)
    SELECT name FROM users WHERE created_at > NOW() - INTERVAL '1 day';

    -- 3단계: 결과 확인 후 처리 (각 단계가 완료된 후 실행)
    UPDATE temp_processing
    SET data = upper(data)
    WHERE data IS NOT NULL;

    RAISE NOTICE 'Processing complete. Rows affected: %', (SELECT COUNT(*) FROM temp_processing);

EXCEPTION
    WHEN OTHERS THEN
        RAISE EXCEPTION 'Transaction failed: %', SQLERRM;
END;
$$;

-- 팀 공용 커서 처리 표준 템플릿
CREATE OR REPLACE FUNCTION safe_cursor_template()
RETURNS VOID AS $$
DECLARE
    cur REFCURSOR;
    rec RECORD;
BEGIN
    OPEN cur FOR SELECT * FROM target_table;

    LOOP
        FETCH cur INTO rec;
        EXIT WHEN NOT FOUND;
        -- 비즈니스 로직
    END LOOP;

    CLOSE cur;
EXCEPTION
    WHEN OTHERS THEN
        IF cur IS NOT NULL THEN
            CLOSE cur;
        END IF;
        RAISE;
END;
$$ LANGUAGE plpgsql;

-- 미완료 트랜잭션 세션 모니터링 쿼리
SELECT
    pid,
    usename,
    application_name,
    state,
    query,
    now() - xact_start AS transaction_duration
FROM pg_stat_activity
WHERE state IN ('idle in transaction', 'active')
  AND xact_start IS NOT NULL
  AND now() - xact_start > INTERVAL '5 minutes'
ORDER BY transaction_duration DESC;