인덱싱 및 성능

CREATE TAGDATA TABLE sensors (
    sensor_id VARCHAR(20) PRIMARY KEY,
    time DATETIME BASETIME,
    temperature DOUBLE SUMMARIZED
);

-- 내부적으로 Machbase가 생성:
-- 1. sensor_id에 대한 인덱스 (태그 이름)
-- 2. 시간 기반 파티션
-- 3. 각 파티션 내 temperature에 대한 인덱스

-- 빠름: sensor_id 인덱스 + 시간 파티션 + 값 인덱스 사용
SELECT * FROM sensors
WHERE sensor_id = 'sensor01'
  AND time BETWEEN '2025-10-10 00:00:00' AND '2025-10-10 23:59:59'
  AND temperature > 25.0;

-- sensor_id + 시간 파티션 사용
SELECT * FROM sensors
WHERE sensor_id = 'sensor01'
DURATION 1 HOUR;

-- 모든 센서 스캔 (sensor_id 필터 없음)
SELECT * FROM sensors
WHERE temperature > 30.0;

-- Rollup 쿼리 (매우 빠름, 사전 집계된 데이터)
SELECT * FROM sensors
WHERE sensor_id = 'sensor01'
  AND rollup = hour
DURATION 7 DAY;

-- 사용 가능한 Rollup 레벨: sec, min, hour

-- Log 테이블 생성
CREATE TABLE app_logs (
    level VARCHAR(10),
    component VARCHAR(50),
    message VARCHAR(2000)
);

-- 자주 쿼리되는 컬럼에 LSM 인덱스 생성
CREATE INDEX idx_level ON app_logs(level);
CREATE INDEX idx_component ON app_logs(component);

-- 인덱스 상태 확인
SHOW INDEXES;

-- 인덱스 구축 진행 상황 확인
SHOW INDEXGAP;

-- 인덱스는 백그라운드에서 구축 (블로킹 없음)

-- 빠름: idx_level 사용
SELECT * FROM app_logs
WHERE level = 'ERROR'
DURATION 1 HOUR;

-- 느림: 전체 스캔, 하지만 여전히 시간 파티셔닝 사용
SELECT * FROM app_logs
WHERE message SEARCH 'timeout'
DURATION 1 HOUR;

CREATE VOLATILE TABLE device_status (
    device_id INTEGER PRIMARY KEY,  -- 자동 인덱싱
    status VARCHAR(20),
    last_updated DATETIME
);

-- PRIMARY KEY 인덱스 사용
SELECT * FROM device_status WHERE device_id = 101;
UPDATE device_status SET status = 'RUNNING' WHERE device_id = 101;
DELETE FROM device_status WHERE device_id = 101;

-- 전체 스캔 (status에 인덱스 없음)
SELECT * FROM device_status WHERE status = 'ERROR';

CREATE LOOKUP TABLE devices (
    device_id INTEGER,
    device_name VARCHAR(100),
    location VARCHAR(200)
);

-- 자주 쿼리되는 컬럼에 인덱스 생성
CREATE INDEX idx_device_id ON devices(device_id);
CREATE INDEX idx_location ON devices(location);

SELECT * FROM logs DURATION 1 DAY;

SELECT * FROM logs DURATION 30 DAY;

SELECT * FROM logs;  -- 시간 필터 없음!

SELECT * FROM sensors WHERE sensor_id = 'sensor01';

SELECT * FROM sensors
WHERE sensor_id = 'sensor01'
DURATION 1 HOUR;

SELECT * FROM logs DURATION 1 HOUR;

SELECT * FROM logs
WHERE _arrival_time >= NOW - INTERVAL '1' HOUR;

SELECT * FROM sensors
WHERE sensor_id = 'sensor01'
  AND rollup = hour
DURATION 7 DAY;

SELECT sensor_id, AVG(temperature)
FROM sensors
WHERE sensor_id = 'sensor01'
DURATION 7 DAY
GROUP BY sensor_id;

SELECT * FROM logs DURATION 1 HOUR LIMIT 1000;

SELECT * FROM logs;  -- 수백만 행 반환!

-- level: ERROR, WARN, INFO (낮은 카디널리티 - 좋음!)
CREATE INDEX idx_level ON logs(level);

-- message: 수백만 개의 고유 값 (인덱스 생성 금지!)
CREATE INDEX idx_message ON logs(message);  -- 이렇게 하지 마세요!

-- 테이블 정보 보기
SHOW TABLE sensors;

-- 스토리지 사용량 보기
SHOW STORAGE;

-- 테이블스페이스 정보 보기
SHOW TABLESPACES;

-- 활성 쿼리 보기
SHOW STATEMENTS;

-- 느린 쿼리 확인
-- (장시간 실행 쿼리가 여기에 표시됨)

-- 인덱스 확인
SHOW INDEXES;

-- 인덱스 구축 진행 상황 보기
SHOW INDEXGAP;

# 메모리 설정
BUFFER_POOL_SIZE = 2G          # 공유 버퍼 캐시
VOLATILE_TABLESPACE_SIZE = 1G  # Volatile 테이블 메모리

# 쓰기 성능
CHECKPOINT_INTERVAL_SEC = 600  # 체크포인트 주기
LOG_BUFFER_SIZE = 64M          # 쓰기 버퍼 크기

# 쿼리 성능
MAX_QPX_MEM = 512M             # 쿼리당 메모리 제한
QUERY_TIMEOUT = 60             # 쿼리 타임아웃 (초)

// 대량 삽입에 APPEND 프로토콜 사용
SQLAppendOpen(stmt, "sensors");
for (int i = 0; i < 10000; i++) {
    SQLAppendDataV(stmt, sensor_id, time, value);
}
SQLAppendClose(stmt);  // 배치 커밋

-- UI 쿼리의 경우 항상 결과 제한
SELECT * FROM logs DURATION 1 HOUR LIMIT 100;

SELECT * FROM sensors WHERE sensor_id = 'sensor01';
-- 느림: 모든 파티션 스캔

SELECT * FROM sensors
WHERE sensor_id = 'sensor01'
DURATION 1 HOUR;  -- 빠름: 1개 파티션 스캔

SELECT AVG(temperature) FROM sensors DURATION 7 DAY;
-- 느림: 수백만 행 집계

SELECT AVG(avg_temperature) FROM sensors
WHERE rollup = hour
DURATION 7 DAY;  -- 빠름: 사전 계산된 데이터 집계

-- 인덱스 없이 느림
SELECT * FROM logs WHERE level = 'ERROR' DURATION 1 DAY;

CREATE INDEX idx_level ON logs(level);
-- 이제 빠름!

SELECT * FROM logs DURATION 30 DAY;
-- 수백만 행 반환!

-- 대신 집계
SELECT level, COUNT(*) FROM logs
DURATION 30 DAY
GROUP BY level;

-- 또는 결과 제한
SELECT * FROM logs DURATION 30 DAY LIMIT 1000;