데이터 구조 이해

┌─────────────────┐       ┌─────────────────┐       ┌─────────────────┐
│   src_users     │       │   src_orders    │       │ src_order_items │
├─────────────────┤       ├─────────────────┤       ├─────────────────┤
│ user_id (PK)    │──────▶│ order_id (PK)   │◀──────│ order_id (FK)   │
│ first_name      │       │ user_id (FK)    │       │ product_id (FK) │
│ last_name       │       │ created_at      │       │ sale_price      │
│ email           │       │ status          │       │ returned_at     │
│ gender          │       │ num_of_item     │       │ shipped_at      │
│ age             │       └─────────────────┘       │ delivered_at    │
│ country         │                                 └────────┬────────┘
│ state           │                                          │
│ created_at      │                                          │
└─────────────────┘                                          ▼
                                                   ┌─────────────────┐
┌─────────────────┐                                │  src_products   │
│   src_events    │                                ├─────────────────┤
├─────────────────┤                                │ product_id (PK) │
│ id (PK)         │                                │ category        │
│ user_id (FK)    │                                │ brand           │
│ session_id      │                                │ department      │
│ sequence_number │                                │ name            │
│ created_at      │                                │ retail_price    │
│ ip_address      │                                │ cost            │
└─────────────────┘                                └─────────────────┘

-- 주문과 고객 정보 조인
SELECT
    o.order_id,
    o.created_at,
    u.country,
    u.age
FROM src_orders o
JOIN src_users u ON o.user_id = u.user_id
 
-- 주문 상세와 상품 정보 조인
SELECT
    oi.order_id,
    oi.sale_price,
    p.category,
    p.brand
FROM src_order_items oi
JOIN src_products p ON oi.product_id = p.product_id
 
-- 전체 조인 (주문 → 상품 → 고객)
SELECT
    o.order_id,
    o.created_at,
    u.country,
    p.category,
    oi.sale_price
FROM src_orders o
JOIN src_users u ON o.user_id = u.user_id
JOIN src_order_items oi ON o.order_id = oi.order_id
JOIN src_products p ON oi.product_id = p.product_id

# 데이터 로드
orders = pd.read_csv('src_orders.csv')
users = pd.read_csv('src_users.csv')
order_items = pd.read_csv('src_order_items.csv')
products = pd.read_csv('src_products.csv')
 
# 주문과 고객 정보 조인
orders_with_users = orders.merge(users, on='user_id')
 
# 주문 상세와 상품 정보 조인
items_with_products = order_items.merge(products, on='product_id')
 
# 전체 조인
full_data = (orders
    .merge(users, on='user_id')
    .merge(order_items, on='order_id')
    .merge(products, on='product_id'))