Day 3: Transaction Lock Contention & Concurrency Control (การจัดการการเข้าถึงข้อมูลพร้อมกันด้วย Row-level Locks, FOR UPDATE, SKIP LOCKED, NOWAIT และการป้องกัน Deadlock)

DO $$
DECLARE
    -- [1] ประกาศตัวแปรโดยใช้ %TYPE เชื่อมโยงกับตาราง accounts
    v_from_acc   accounts.account_id%TYPE := 101;
    v_to_acc     accounts.account_id%TYPE := 102;
    v_amount     accounts.balance%TYPE    := 500.00;
    v_from_bal   accounts.balance%TYPE;
BEGIN
    -- [2] ล็อกแถวบัญชีต้นทางล่วงหน้าด้วย FOR UPDATE เพื่ออ่านยอดเงินล่าสุด
    -- ป้องกันไม่ให้ Transaction อื่นเข้ามาตัดเงินหรือแก้ไขยอดแทรกกลางคัน
    SELECT balance INTO v_from_bal
    FROM accounts
    WHERE account_id = v_from_acc
    FOR UPDATE; -- ล็อก Row นี้ทันทีจนกว่าจะจบ Block

    -- [3] ตรวจสอบยอดเงินคงเหลือ
    IF v_from_bal >= v_amount THEN
        -- หักเงินบัญชีต้นทาง
        UPDATE accounts SET balance = balance - v_amount WHERE account_id = v_from_acc;
        -- เพิ่มเงินบัญชีปลายทาง
        UPDATE accounts SET balance = balance + v_amount WHERE account_id = v_to_acc;

        RAISE NOTICE 'โอนเงินสำเร็จจำนวน % บาท (ยอดคงเหลือใหม่: %)', v_amount, (v_from_bal - v_amount);
    ELSE
        RAISE NOTICE 'ยอดเงินไม่เพียงพอ (ยอดคงเหลือปัจจุบัน: %)', v_from_bal;
    END IF;
END $$;

-- 📤 ผลลัพธ์ใน Log:
-- NOTICE: โอนเงินสำเร็จจำนวน 500.00 บาท (ยอดคงเหลือใหม่: 4500.00)

DO $$
DECLARE
    v_seat_id seats.seat_id%TYPE := 55;
    v_status  seats.status%TYPE;
BEGIN
    -- [1] ตั้งค่าระยะเวลารอคิวล็อกสูงสุดไม่เกิน 2 วินาที ป้องกันการค้างยาว
    SET LOCAL lock_timeout = '2s';

    -- [2] พยายามจองและล็อกที่นั่ง หากมีคนอื่นกำลังล็อกอยู่ ให้พ่น Error ทันทีด้วย NOWAIT
    SELECT status INTO v_status
    FROM seats
    WHERE seat_id = v_seat_id AND status = 'AVAILABLE'
    FOR UPDATE NOWAIT;

    -- [3] หากดึงผ่าน แสดงว่าจองสำเร็จ ทำการอัปเดตสถานะ
    UPDATE seats SET status = 'RESERVED', reserved_at = CURRENT_TIMESTAMP WHERE seat_id = v_seat_id;
    RAISE NOTICE 'จองที่นั่งหมายเลข % สำเร็จ!', v_seat_id;

EXCEPTION
    -- [4] ดักจับ Exception เมื่อติดล็อกและเกิด NOWAIT/lock_timeout (รหัส Error 55P03)
    WHEN lock_not_available OR 55P03 THEN
        RAISE NOTICE 'ที่นั่งหมายเลข % กำลังมีผู้อื่นทำการจอง กรุณาลองใหม่อีกครั้ง (Fail-Fast สำเร็จ)', v_seat_id;
    WHEN NO_DATA_FOUND THEN
        RAISE NOTICE 'ที่นั่งหมายเลข % ไม่ว่างหรือไม่มีในระบบ', v_seat_id;
END $$;