Day 7: Pillar 3 - Event Triggers & Audit Logging Mechanics (กลไกการทำงานของ Triggers และ Trigger Functions, โครงสร้างพิเศษ OLD / NEW, ความแตกต่างระหว่าง BEFORE vs AFTER และการสร้าง Real-Time Automatic Audit Logging Engine)

-- ❌ หายนะทางสถาปัตยกรรม: ใช้ BEFORE Trigger ทำ Audit Log
-- แล้วส่งคืนค่า RETURN NULL;
CREATE OR REPLACE FUNCTION fn_trg_audit_flawed() 
RETURNS TRIGGER 
LANGUAGE plpgsql 
AS $$
BEGIN
    -- บันทึกลงตาราง Log
    INSERT INTO audit_logs(table_name, old_data) 
    VALUES (TG_TABLE_NAME, OLD.status);

    -- 🚨 พังพินาศทันที! การส่ง RETURN NULL ใน BEFORE Trigger
    -- จะสั่งให้ PostgreSQL ยกเลิกคำสั่ง UPDATE หลักทิ้งทันที!
    RETURN NULL; 
END $$;

CREATE TRIGGER trg_audit_bad
BEFORE UPDATE ON customers
FOR EACH ROW
EXECUTE FUNCTION fn_trg_audit_flawed();
-- ลูกค้ากดอัปเดตข้อมูล แต่ข้อมูลในตารางไม่เคยเปลี่ยนเลย!

-- [Statement 1] สร้างตาราง Audit Log กลางสำหรับรองรับประวัติทุกตารางในระบบ
CREATE TABLE IF NOT EXISTS audit_logs (
    audit_id     BIGSERIAL PRIMARY KEY,
    table_name   VARCHAR(100) NOT NULL,
    operation    VARCHAR(10)  NOT NULL, -- 'INSERT', 'UPDATE', 'DELETE'
    old_data     JSONB,                -- บันทึกโครงสร้างเก่าเป็น JSONB
    new_data     JSONB,                -- บันทึกโครงสร้างใหม่เป็น JSONB
    changed_by   VARCHAR(100) DEFAULT CURRENT_USER,
    changed_at   TIMESTAMPTZ  DEFAULT CURRENT_TIMESTAMP
);

-- [Statement 2] สร้าง Generic Trigger Function แปลงเรกคอร์ดเป็น JSONB
CREATE OR REPLACE FUNCTION fn_trg_generic_audit_engine()
RETURNS TRIGGER
LANGUAGE plpgsql
AS $$
DECLARE
    -- [บรรทัดที่ 1-2] ประกาศตัวแปรเก็บโครงสร้าง JSONB ค่าเดิมและค่าใหม่
    v_old_jsonb JSONB := NULL;
    v_new_jsonb JSONB := NULL;
BEGIN
    -- [บรรทัดที่ 3-7] ตรวจสอบเหตุการณ์ TG_OP เพื่อแปลงเรกคอร์ดเป็น JSONB
    IF (TG_OP = 'UPDATE') THEN
        v_old_jsonb := to_jsonb(OLD); -- แปลงเรกคอร์ด OLD เป็น JSONB
        v_new_jsonb := to_jsonb(NEW); -- แปลงเรกคอร์ด NEW เป็น JSONB
    ELSIF (TG_OP = 'DELETE') THEN
        v_old_jsonb := to_jsonb(OLD);
    ELSIF (TG_OP = 'INSERT') THEN
        v_new_jsonb := to_jsonb(NEW);
    END IF;

    -- [บรรทัดที่ 8-16] บันทึกลงตาราง audit_logs กลาง
    INSERT INTO audit_logs (
        table_name,
        operation,
        old_data,
        new_data
    ) VALUES (
        TG_TABLE_NAME, -- ชื่อนามตารางอัตโนมัติ
        TG_OP,         -- ชนิดการทำงาน ('INSERT'/'UPDATE'/'DELETE')
        v_old_jsonb,
        v_new_jsonb
    );

    -- 🎯 [บรรทัดที่ 17] สำหรับ AFTER Trigger คืนค่า NULL ได้ ปลอดภัย ไม่กระทบคำสั่งหลัก!
    RETURN NULL;
END $$;

-- [Statement 3] ผูก Trigger เข้ากับตารางสำคัญแบบ AFTER FOR EACH ROW
CREATE TRIGGER trg_audit_customers_change
AFTER INSERT OR UPDATE OR DELETE ON customers
FOR EACH ROW
EXECUTE FUNCTION fn_trg_generic_audit_engine();