트랜잭션

// 트랜잭션 관리 예제 - Node.js + PostgreSQL
const { Pool } = require('pg');

class TransactionManager {
    constructor(connectionString) {
        this.pool = new Pool({ connectionString });
    }

    /**
     * 트랜잭션 래퍼 - 자동 커밋/롤백
     * @param {Function} callback - 트랜잭션 내에서 실행할 함수
     */
    async withTransaction(callback) {
        const client = await this.pool.connect();

        try {
            await client.query('BEGIN');
            const result = await callback(client);
            await client.query('COMMIT');
            console.log('✅ 트랜잭션 커밋됨');
            return result;

        } catch (error) {
            await client.query('ROLLBACK');
            console.error(`❌ 트랜잭션 롤백됨: ${error.message}`);
            throw error;

        } finally {
            client.release();
        }
    }
}

class OrderService {
    constructor(txManager) {
        this.txManager = txManager;
    }

    /**
     * 주문 생성 - 트랜잭션으로 여러 작업 묶기
     */
    async createOrder(userId, items) {
        return await this.txManager.withTransaction(async (client) => {
            // 1. 재고 확인 및 차감
            for (const item of items) {
                const { rows } = await client.query(
                    'SELECT stock FROM products WHERE id = $1 FOR UPDATE',
                    [item.productId]
                );

                if (rows.length === 0 || rows[0].stock < item.quantity) {
                    throw new Error(`재고 부족: 상품 ${item.productId}`);
                }

                await client.query(
                    'UPDATE products SET stock = stock - $1 WHERE id = $2',
                    [item.quantity, item.productId]
                );
            }

            // 2. 주문 생성
            const totalAmount = items.reduce(
                (sum, item) => sum + item.price * item.quantity, 0
            );

            const orderResult = await client.query(
                `INSERT INTO orders (user_id, total_amount, status, created_at)
                 VALUES ($1, $2, 'pending', NOW())
                 RETURNING id`,
                [userId, totalAmount]
            );
            const orderId = orderResult.rows[0].id;

            // 3. 주문 상세 생성
            for (const item of items) {
                await client.query(
                    `INSERT INTO order_items (order_id, product_id, quantity, price)
                     VALUES ($1, $2, $3, $4)`,
                    [orderId, item.productId, item.quantity, item.price]
                );
            }

            // 4. 포인트 적립
            const points = Math.floor(totalAmount * 0.01);
            await client.query(
                'UPDATE users SET points = points + $1 WHERE id = $2',
                [points, userId]
            );

            return orderId;
        });
    }
}

// Savepoint 활용
async function withSavepoint(client, name, callback) {
    await client.query(`SAVEPOINT ${name}`);

    try {
        return await callback();
    } catch (error) {
        await client.query(`ROLLBACK TO SAVEPOINT ${name}`);
        console.warn(`⚠️ Savepoint ${name}로 롤백됨`);
        throw error;
    }
}

// 재시도 로직이 포함된 트랜잭션
async function executeWithRetry(txManager, operation, maxRetries = 3) {
    let lastError;

    for (let attempt = 1; attempt <= maxRetries; attempt++) {
        try {
            return await txManager.withTransaction(operation);
        } catch (error) {
            lastError = error;

            // 직렬화 실패 또는 데드락인 경우만 재시도
            if (error.code === '40001' || error.code === '40P01') {
                console.log(`재시도 ${attempt}/${maxRetries}...`);
                await new Promise(r => setTimeout(r, 100 * attempt));
            } else {
                throw error;
            }
        }
    }

    throw lastError;
}

// 사용 예시
const txManager = new TransactionManager('postgresql://localhost/shop');
const orderService = new OrderService(txManager);

const items = [
    { productId: 1, quantity: 2, price: 15000 },
    { productId: 2, quantity: 1, price: 25000 }
];

orderService.createOrder(123, items)
    .then(orderId => console.log(`주문 완료: #${orderId}`))
    .catch(error => console.error(`주문 실패: ${error.message}`));

-- 트랜잭션 기본 사용법 (PostgreSQL/MySQL)

-- ============================================
-- 1. 기본 트랜잭션
-- ============================================
BEGIN;  -- 트랜잭션 시작 (START TRANSACTION도 가능)

-- 여러 작업 수행
UPDATE accounts SET balance = balance - 50000 WHERE id = 1;
UPDATE accounts SET balance = balance + 50000 WHERE id = 2;
INSERT INTO transfer_log (from_id, to_id, amount) VALUES (1, 2, 50000);

-- 모든 작업 성공 시 확정
COMMIT;

-- 또는 문제 발생 시 취소
-- ROLLBACK;


-- ============================================
-- 2. 자동 커밋 설정
-- ============================================
-- 자동 커밋 확인
SHOW autocommit;

-- 자동 커밋 끄기 (명시적 트랜잭션 필요)
SET autocommit = 0;

-- 작업 수행
INSERT INTO logs (message) VALUES ('테스트');

-- 명시적으로 커밋해야 저장됨
COMMIT;


-- ============================================
-- 3. Savepoint (부분 롤백)
-- ============================================
BEGIN;

INSERT INTO orders (user_id, total) VALUES (1, 10000);
-- 여기까지는 확실히 성공

SAVEPOINT before_items;

INSERT INTO order_items (order_id, product_id) VALUES (1, 100);
INSERT INTO order_items (order_id, product_id) VALUES (1, 999);  -- 실패 가정

-- 주문 상세만 롤백하고 주문은 유지
ROLLBACK TO SAVEPOINT before_items;

-- 대체 작업 수행
INSERT INTO order_items (order_id, product_id) VALUES (1, 101);

COMMIT;  -- 주문 + 대체 상세만 저장됨


-- ============================================
-- 4. 읽기 전용 트랜잭션
-- ============================================
-- 리포트 조회 시 유용 (일관된 스냅샷 보장)
BEGIN READ ONLY;

SELECT SUM(balance) FROM accounts;
SELECT COUNT(*) FROM transactions WHERE date = CURRENT_DATE;

COMMIT;


-- ============================================
-- 5. 트랜잭션 격리 수준 설정
-- ============================================
-- 현재 격리 수준 확인
SHOW TRANSACTION ISOLATION LEVEL;

-- 트랜잭션 시작 시 격리 수준 지정
BEGIN ISOLATION LEVEL SERIALIZABLE;
-- 작업 수행
COMMIT;

-- 세션 전체 격리 수준 변경
SET SESSION CHARACTERISTICS AS TRANSACTION ISOLATION LEVEL READ COMMITTED;


-- ============================================
-- 6. 락을 이용한 동시성 제어
-- ============================================
BEGIN;

-- 행 레벨 배타적 락 (수정 예정)
SELECT * FROM products WHERE id = 1 FOR UPDATE;

-- 이 시점에 다른 트랜잭션은 이 행 수정 대기

UPDATE products SET stock = stock - 1 WHERE id = 1;

COMMIT;  -- 락 해제


-- 공유 락 (읽기만, 다른 트랜잭션도 읽기 가능)
SELECT * FROM products WHERE id = 1 FOR SHARE;


-- ============================================
-- 7. 트랜잭션 상태 확인 (PostgreSQL)
-- ============================================
-- 현재 실행 중인 트랜잭션 조회
SELECT pid, state, query, xact_start, query_start
FROM pg_stat_activity
WHERE state != 'idle'
ORDER BY xact_start;

-- 락 대기 상태 확인
SELECT blocked.pid AS blocked_pid,
       blocking.pid AS blocking_pid,
       blocked.query AS blocked_query
FROM pg_stat_activity blocked
JOIN pg_stat_activity blocking
  ON blocking.pid = ANY(pg_blocking_pids(blocked.pid))
WHERE blocked.pid != blocking.pid;