OLAP vs OLTP

-- OLTP: 짧은 트랜잭션, 행 하나씩
BEGIN;
INSERT INTO sales (id, sold_on, region, product, amount)
VALUES (7, '2024-10-04', 'KR', 'A', 120);
UPDATE stock SET quantity = quantity - 1 WHERE product = 'A';
COMMIT;

SELECT * FROM sales WHERE id = 7;                    -- 기본 키 인덱스를 써서 행 하나를 찾을 수 있다

-- OLAP: 많은 행을 훑어 집계
SELECT region, date_trunc('month', sold_on) AS month, SUM(amount) AS total
FROM sales
WHERE sold_on >= '2022-01-01'
GROUP BY region, month
ORDER BY region, month;                              -- 지난 몇 해의 지역별 월 매출

rows = [(1, '10-01', 'KR', 'A', 100), (2, '10-01', 'US', 'B', 150), (3, '10-02', 'KR', 'A', 200),
        (4, '10-02', 'JP', 'C', 80), (5, '10-03', 'US', 'B', 300), (6, '10-03', 'KR', 'A', 50)]
names = ('id', 'date', 'region', 'product', 'amount')

cols = {n: [r[i] for r in rows] for i, n in enumerate(names)}   # 컬럼 지향: 열마다 모아 저장

need = ('region', 'amount')                                      # 집계 쿼리가 필요한 열
row_cells = len(rows) * len(names)                               # 행 지향: 행 전체를 읽음
col_cells = len(rows) * len(need)                                # 컬럼 지향: 필요한 열만 읽음
print('읽는 셀:', row_cells, col_cells)

total = {}
for region, amount in zip(cols['region'], cols['amount']):
    total[region] = total.get(region, 0) + amount
print('집계:', total)

print('행 하나(id=3) 읽기:', rows[2])                            # 행 지향: 한 번에 연속으로
print('컬럼 지향으로 id=3 읽기:', [cols[n][2] for n in names], '열 5곳을 읽음')
# 읽는 셀: 30 12
# 집계: {'KR': 350, 'US': 450, 'JP': 80}
# 행 하나(id=3) 읽기: (3, '10-02', 'KR', 'A', 200)
# 컬럼 지향으로 id=3 읽기: [3, '10-02', 'KR', 'A', 200] 열 5곳을 읽음

record Sale(int id, String date, String region, String product, int amount) {}

List<Sale> rows = List.of(
    new Sale(1, "10-01", "KR", "A", 100), new Sale(2, "10-01", "US", "B", 150),
    new Sale(3, "10-02", "KR", "A", 200), new Sale(4, "10-02", "JP", "C", 80),
    new Sale(5, "10-03", "US", "B", 300), new Sale(6, "10-03", "KR", "A", 50));

Map<String, Integer> byRegion = rows.stream()
    .collect(Collectors.groupingBy(Sale::region, TreeMap::new, Collectors.summingInt(Sale::amount)));
System.out.println("집계: " + byRegion);                           // 집계: {JP=80, KR=350, US=450}

int[] amount = rows.stream().mapToInt(Sale::amount).toArray();      // 컬럼 지향: amount 열만 모은 배열
System.out.println("amount 열: " + Arrays.toString(amount) + " 합계 " + Arrays.stream(amount).sum());
// amount 열: [100, 150, 200, 80, 300, 50] 합계 880