뷰 / 구체화 뷰

CREATE VIEW region_sales AS
SELECT region, SUM(amount) AS total FROM orders GROUP BY region;
SELECT * FROM region_sales;                           -- 조회할 때마다 위 쿼리가 원본에 실행된다

CREATE MATERIALIZED VIEW region_mv AS
SELECT region, SUM(amount) AS total FROM orders GROUP BY region
WITH DATA;                                          -- 만들 때 결과를 채운다 (기본값)

CREATE UNIQUE INDEX ON region_mv (region);               -- CONCURRENTLY 갱신에 필요

REFRESH MATERIALIZED VIEW region_mv;                    -- 갱신 동안 조회가 막힐 수 있다
REFRESH MATERIALIZED VIEW CONCURRENTLY region_mv;      -- 조회를 막지 않고 갱신

SELECT matviewname, ispopulated FROM pg_matviews;     -- 구체화 뷰 목록과 채워졌는지 여부

base = [('KR', 100), ('KR', 200), ('US', 150), ('KR', 50), ('US', 300), ('JP', 80)]
reads = 0

def query():                                  # 지역별 합계 쿼리
    global reads
    reads += len(base)                        # 원본에서 읽은 행 수
    out = {}
    for region, amount in base:
        out[region] = out.get(region, 0) + amount
    return out

def view():                                   # 일반 뷰: 조회할 때마다 쿼리 실행
    return query()

stored = query()                              # 구체화 뷰: 만들 때 한 번 실행해 저장

def mview():
    return stored                             # 조회는 저장된 결과를 읽음

def refresh():
    global stored
    stored = query()                          # REFRESH: 쿼리를 다시 실행해 저장

reads = 0
base.append(('KR', 150))                      # 원본에 새 행
print('뷰', view()['KR'], '읽은 행', reads)
print('구체화 뷰', mview()['KR'], '읽은 행', reads)
refresh()
print('REFRESH 뒤', mview()['KR'], '읽은 행', reads)
# 뷰 500 읽은 행 7
# 구체화 뷰 350 읽은 행 7
# REFRESH 뒤 500 읽은 행 14

static List<Map.Entry<String, Integer>> base = new ArrayList<>(List.of(
    Map.entry("KR", 100), Map.entry("KR", 200), Map.entry("US", 150),
    Map.entry("KR", 50), Map.entry("US", 300), Map.entry("JP", 80)));
static int reads = 0;
static Map<String, Integer> stored;

static Map<String, Integer> query() {
    reads += base.size();
    Map<String, Integer> out = new TreeMap<>();
    for (Map.Entry<String, Integer> e : base) out.merge(e.getKey(), e.getValue(), Integer::sum);
    return out;
}

stored = query();                                  // 구체화 뷰를 만들 때 한 번 실행
reads = 0;
base.add(Map.entry("KR", 150));
System.out.println("뷰 " + query().get("KR") + " 읽은 행 " + reads);      // 뷰 500 읽은 행 7
System.out.println("구체화 뷰 " + stored.get("KR") + " 읽은 행 " + reads);  // 구체화 뷰 350 읽은 행 7
stored = query();                                  // REFRESH
System.out.println("REFRESH 뒤 " + stored.get("KR") + " 읽은 행 " + reads);  // REFRESH 뒤 500 읽은 행 14