테이블과 뷰

-- ✅ 관리형 테이블 (권장) — LOCATION 절 없음
CREATE TABLE catalog.schema.orders (
    order_id    BIGINT       COMMENT '주문 고유 ID',
    customer_id BIGINT       COMMENT '고객 ID',
    order_date  DATE         COMMENT '주문일',
    amount      DECIMAL(10,2) COMMENT '주문 금액',
    status      STRING       COMMENT '주문 상태'
) USING DELTA
COMMENT '주문 관리 테이블';

-- 외부 테이블 — LOCATION 지정 필수
CREATE TABLE catalog.schema.external_orders (
    order_id    BIGINT,
    customer_id BIGINT,
    order_date  DATE,
    amount      DECIMAL(10,2),
    status      STRING
) USING DELTA
LOCATION 's3://my-bucket/external/orders/'
COMMENT '외부 스토리지에 저장된 주문 테이블';

-- 테이블의 변경 이력 확인
DESCRIBE HISTORY catalog.schema.orders;

-- 타임 트래블: 과거 특정 버전의 데이터 조회
SELECT * FROM catalog.schema.orders VERSION AS OF 3;

-- 타임 트래블: 특정 시점의 데이터 조회
SELECT * FROM catalog.schema.orders TIMESTAMP AS OF '2025-01-15 10:00:00';

-- 활성 고객만 보여주는 뷰
CREATE VIEW catalog.schema.v_active_customers AS
SELECT
    customer_id,
    name,
    email,
    signup_date
FROM catalog.schema.customers
WHERE status = 'ACTIVE';

-- 뷰를 일반 테이블처럼 조회
SELECT * FROM catalog.schema.v_active_customers WHERE signup_date >= '2025-01-01';

-- 현재 세션에서만 유효한 임시 뷰
CREATE TEMPORARY VIEW temp_high_value_orders AS
SELECT * FROM catalog.schema.orders WHERE amount >= 10000;

-- 임시 뷰 조회
SELECT COUNT(*) FROM temp_high_value_orders;
-- 세션 종료 시 자동 삭제됩니다

-- 일별 매출 집계를 미리 계산하여 저장
CREATE MATERIALIZED VIEW catalog.schema.mv_daily_revenue AS
SELECT
    DATE(order_date) AS day,
    COUNT(*)         AS order_count,
    SUM(amount)      AS total_revenue,
    AVG(amount)      AS avg_order_value
FROM catalog.schema.orders
GROUP BY DATE(order_date);

-- 구체화된 뷰를 조회하면 미리 계산된 결과를 즉시 반환합니다
SELECT * FROM catalog.schema.mv_daily_revenue WHERE day >= '2025-01-01';

-- 수동으로 새로고침
REFRESH MATERIALIZED VIEW catalog.schema.mv_daily_revenue;

-- 클라우드 스토리지에서 데이터를 증분 수집하는 스트리밍 테이블
CREATE STREAMING TABLE catalog.schema.st_raw_events AS
SELECT * FROM STREAM READ_FILES('s3://my-bucket/raw-events/', format => 'json');

-- 다른 스트리밍 테이블을 소스로 하는 스트리밍 테이블
CREATE STREAMING TABLE catalog.schema.st_clean_events AS
SELECT
    event_id,
    event_type,
    user_id,
    CAST(timestamp AS TIMESTAMP) AS event_time
FROM STREAM catalog.schema.st_raw_events
WHERE event_type IS NOT NULL;

-- 전통적 파티셔닝 (Hive-style) — 신규 테이블에는 권장하지 않습니다
CREATE TABLE catalog.schema.events_partitioned (
    event_id   BIGINT,
    event_type STRING,
    event_date DATE,
    payload    STRING
) USING DELTA
PARTITIONED BY (event_date);

-- ✅ Liquid Clustering (권장) — 파티셔닝 대신 사용
CREATE TABLE catalog.schema.events_clustered (
    event_id   BIGINT,
    event_type STRING,
    event_date DATE,
    user_id    BIGINT,
    payload    STRING
) USING DELTA
CLUSTER BY (event_date, event_type);

-- 기존 테이블에 Liquid Clustering 적용
ALTER TABLE catalog.schema.events_old
CLUSTER BY (event_date, event_type);

-- Liquid Clustering 제거
ALTER TABLE catalog.schema.events_clustered
CLUSTER BY NONE;

-- 테이블 생성 시 속성 지정
CREATE TABLE catalog.schema.audit_logs (
    log_id     BIGINT,
    action     STRING,
    created_at TIMESTAMP
) USING DELTA
TBLPROPERTIES (
    'delta.autoOptimize.optimizeWrite' = 'true',     -- 쓰기 시 파일 크기 자동 최적화
    'delta.autoOptimize.autoCompact'   = 'true',     -- 소규모 파일 자동 병합
    'delta.logRetentionDuration'       = '90 days',  -- 트랜잭션 로그 보존 기간
    'delta.deletedFileRetentionDuration' = '30 days' -- 삭제 파일 보존 (타임 트래블)
);

-- 기존 테이블의 속성 변경
ALTER TABLE catalog.schema.audit_logs
SET TBLPROPERTIES ('delta.logRetentionDuration' = '180 days');

-- 테이블 속성 확인
SHOW TBLPROPERTIES catalog.schema.audit_logs;

-- 1️⃣ 생성
CREATE TABLE catalog.schema.products (
    product_id   BIGINT GENERATED ALWAYS AS IDENTITY,
    product_name STRING NOT NULL,
    category     STRING,
    price        DECIMAL(10,2),
    created_at   TIMESTAMP DEFAULT CURRENT_TIMESTAMP()
) USING DELTA
CLUSTER BY (category);

-- 2️⃣ 스키마 수정 (컬럼 추가)
ALTER TABLE catalog.schema.products ADD COLUMN discount_pct DECIMAL(5,2);

-- 컬럼 이름 변경 (Column Mapping 필요)
ALTER TABLE catalog.schema.products
SET TBLPROPERTIES ('delta.columnMapping.mode' = 'name');
ALTER TABLE catalog.schema.products RENAME COLUMN discount_pct TO discount_rate;

-- 3️⃣ 데이터 최적화
OPTIMIZE catalog.schema.products;

-- 오래된 파일 정리 (기본 7일 이전)
VACUUM catalog.schema.products;

-- 보존 기간 지정 (주의: 타임 트래블 범위가 줄어듭니다)
VACUUM catalog.schema.products RETAIN 72 HOURS;

-- 4️⃣ 테이블 삭제
DROP TABLE IF EXISTS catalog.schema.products;

-- 외부 테이블의 경우 데이터는 수동 삭제 필요
-- DROP TABLE은 메타데이터만 삭제합니다