Day 12: Automated Testing with Testcontainers & pgTAP (การทำ Automated Database Unit Testing ด้วย pgTAP, การจำลอง Ephemeral Database Container ด้วย Testcontainers ใน CI/CD Pipeline, และการสร้าง Test Isolation ในระดับ Transaction)

โค้ดฐานข้อมูลเข้า Git แล้ว คำถามถัดไปคือจะรู้ได้อย่างไรว่า Pull Request วันนี้ไม่ทำลาย logic เดิม — วันนี้คือการทดสอบอัตโนมัติบนฐานข้อมูลชั่วคราวที่สร้างขึ้นมาแล้วทิ้ง

โดยรวมวันนี้คือระบบทดสอบที่สร้างฐานข้อมูลชั่วคราวขึ้นมา รัน Flyway migration แล้วยิง pgTAP ตรวจ stored units ทุกตัว ก่อนสั่ง rollback และลบฐานข้อมูลทิ้ง

ช่วยดักบั๊กตั้งแต่ตอนเปิด Pull Request (shift-left testing) การันตีว่าการแก้โค้ดวันนี้จะไม่ไปทำลายการทำงานเดิมที่มีอยู่

หลังจากที่เราได้นำ Stored Units เข้าสู่ Version Control ด้วย Flyway (Day 11) คำถามสำคัญระดับ Enterprise ที่สถาปนิกและหัวหน้าทีมพัฒนามักตั้งคำถามเสมอคือ "เมื่อมีนักพัฒนา 30 คนส่ง Pull Request เข้ามาแก้ไข Stored Procedures และ Triggers เราจะการันตีได้อย่างไรว่าโค้ดใหม่จะไม่ไปทำลาย Business Logic เดิมที่มีอยู่?"

⚖️ การเปรียบเทียบเชิงสถาปัตยกรรม: Manual Staging Testing vs. Automated pgTAP + Testcontainers

การเขียน Database Unit Test ด้วย pgTAP ไม่ต่างจากการเขียน Unit Test ในภาษาอย่าง JUnit, Jest หรือ pytest แต่ทำในภาษา SQL ทั้งหมด โดยมีโครงสร้างหลัก 4 ส่วน: เริ่มด้วย BEGIN;, วางแผนด้วย plan(N);, ตรวจสอบด้วย Assertion Functions (เช่น is(), results_eq()), และจบด้วย ROLLBACK;:

-- 🎯 [ส่วนที่ 1: Transaction Isolation & Extension Setup]
BEGIN;
CREATE EXTENSION IF NOT EXISTS pgtap;

-- 🎯 [ส่วนที่ 2: วางแผนจำนวนการทดสอบที่ต้องรัน]
SELECT plan(3); -- ระบุชัดเจนว่าต้องมี Assertion 3 ข้อ หากรันไม่ครบจะถือว่า Fail ทันที!

-- 🎯 [ส่วนที่ 3: Assertion Functions ตรวจสอบผลลัพธ์]
-- ข้อ 1: ตรวจสอบความถูกต้องของ Schema
SELECT has_table('accounts', 'ตาราง accounts ต้องมีอยู่ในระบบ');

-- ข้อ 2: ตรวจสอบค่าผลลัพธ์ของฟังก์ชัน (Actual vs Expected)
SELECT is(
    fn_calculate_discount(1000.00, 'GOLD'), -- Actual Value ที่ฟังก์ชันคำนวณได้
    150.00,                                 -- Expected Value ที่เราคาดหวัง
    'ส่วนลดระดับ GOLD สำหรับยอด 1,000 บาท ต้องเท่ากับ 150 บาท' -- คำอธิบาย Test Case
);

-- ข้อ 3: ตรวจสอบผลลัพธ์จาก Query ชุดข้อมูล
SELECT results_eq(
    'SELECT status FROM accounts WHERE account_id = 1', -- Actual Query
    'VALUES (''ACTIVE''::varchar)',                      -- Expected Query / Values
    'สถานะของบัญชีหมายเลข 1 ต้องเป็น ACTIVE'
);

-- 🎯 [ส่วนที่ 4: สรุปผลการทดสอบ และล้างข้อมูล 100%]
SELECT * FROM finish();
ROLLBACK; -- 💡 กฎเหล็ก: สั่ง ROLLBACK เสมอเพื่อไม่ให้มีข้อมูลทดสอบตกค้างในฐานข้อมูล!

🏋️‍♂️ แบบฝึกหัดไต่ระดับการเขียนจริง (จากระดับเริ่มต้น ➔ CI/CD Testcontainers Pipeline)

-- test/01_schema_test.sql
-- 🎯 ทดสอบความสมบูรณ์ของโครงสร้างตาราง คอลัมน์ และ Stored Units หลังรัน Flyway Migration
BEGIN;
CREATE EXTENSION IF NOT EXISTS pgtap;

SELECT plan(3);

-- [1] ตรวจสอบว่าตาราง orders ถูกสร้างขึ้นเรียบร้อยแล้วหรือไม่
SELECT has_table('orders', 'ตาราง orders ต้องถูกสร้างขึ้น');

-- [2] ตรวจสอบว่าคอลัมน์ net_amount มีอยู่ในตาราง orders หรือไม่
SELECT has_column('orders', 'net_amount', 'ตาราง orders ต้องมีคอลัมน์ net_amount');

-- [3] ตรวจสอบว่า Stored Procedure pr_transfer_funds_enterprise มีอยู่จริงหรือไม่
SELECT has_function('pr_transfer_funds_enterprise', 'ต้องมี Stored Procedure pr_transfer_funds_enterprise');

SELECT * FROM finish();
ROLLBACK;

-- test/02_business_logic_test.sql
-- 🎯 ทดสอบความถูกต้องของ Business Logic และ Transactional Changes
BEGIN;
CREATE EXTENSION IF NOT EXISTS pgtap;

SELECT plan(2);

-- [1] เตรียมข้อมูลจำลองสำหรับทดสอบ (Dummy Test Data) ใน Transaction
INSERT INTO accounts (account_id, account_no, balance, status)
VALUES (999, 'ACC-TEST-01', 5000.00, 'ACTIVE');

-- [2] Test 1: ทดสอบ Stored Function ดึงยอดเงินด้วย is()
SELECT is(
    fn_get_account_balance(999),
    5000.00,
    'ฟังก์ชัน fn_get_account_balance ต้องคืนค่ายอดเงิน 5000.00 ได้ถูกต้อง'
);

-- [3] Test 2: ทดสอบการทำงานของ Stored Procedure ฝากเงิน แล้วตรวจสอบผลลัพธ์ด้วย results_eq()
CALL pr_deposit_funds(999, 1500.00);

SELECT results_eq(
    'SELECT balance FROM accounts WHERE account_id = 999',
    'VALUES (6500.00::numeric)',
    'ยอดเงินหลังฝากเพิ่ม 1500 ต้องกลายเป็น 6500.00'
);

SELECT * FROM finish();
-- 🎯 [4] สั่ง ROLLBACK: ข้อมูลจำลอง ID 999 และประวัติเงินฝากจะถูกทำลายทิ้งทันที ไร้ Data Pollution!
ROLLBACK;

🔴 Level 3: Refactoring CI/CD Database Testing Pipeline (เปรียบเทียบ Manual Shared DB vs Testcontainers + pgTAP)

เปรียบเทียบกระบวนการเดิมที่รัน Manual Test บน Shared Staging DB กับกระบวนการใหม่ที่ใช้ Testcontainers สปินอัป Ephemeral DB อัตโนมัติบน CI/CD Pipeline:

# ❌ Flawed Process: ใช้ Staging DB ร่วมกันทั้งทีม
# 1. นักพัฒนาต่อ DBeaver เข้า staging-db.internal
# 2. แก้ข้อมูลในตารางทดสอบด้วยมือ ➔ คนอื่นรันเทสต์พังทันที (Data Pollution)
# 3. QA ต้องไล่คลิก Postman ทดสอบทีละ API นาน 3 วัน
# 4. ไม่มีการเช็ค Edge Cases เมื่อนำขึ้น Prod คำนวณเงินติดลบ เสียหาย 5 ล้านบาท!

# คำสั่งเดิมที่ใช้รัน:
psql -h staging-db.internal -U appuser -d staging_db -f test_script.sql
# ผลลัพธ์: ขยะข้อมูลตกค้างสะสมจนกลายเป็น Flaky Database!

# test_runner.py (สคริปต์รันอัตโนมัติบน GitHub Actions / GitLab CI)
# 🎯 สปินอัป Ephemeral PostgreSQL Container ชั่วคราว รัน Flyway แล้วยิง pgTAP
import os
from testcontainers.postgres import PostgresContainer
import psycopg2

# [Statement 1] สปินอัป Ephemeral Database Container สะอาดเอี่ยม 100%
with PostgresContainer("postgres:16-alpine") as postgres:
    db_url = postgres.get_connection_url()

    # [Statement 2] รัน Flyway Migration ปูโครงสร้าง Schema และ Stored Units
    print("🚀 Running Flyway Migrations on Ephemeral Container...")
    os.system(f"flyway -url={db_url} -user={postgres.username} -password={postgres.password} migrate")

    # [Statement 3] เชื่อมต่อและรัน pgTAP Automated Test Suite
    conn = psycopg2.connect(
        dbname=postgres.dbname,
        user=postgres.username,
        password=postgres.password,
        host=postgres.get_container_host_ip(),
        port=postgres.get_exposed_port(5432)
    )
    cur = conn.cursor()

    print("🧪 Executing pgTAP Automated Test Suite...")
    cur.execute(open("test/02_business_logic_test.sql", "r").read())
    results = cur.fetchall()

    for row in results:
        print(row)

    conn.close()
    # 🎯 เมื่อพ้นบล็อก with คอนเทนเนอร์ Docker จะถูกทำลายทิ้งทันที ไร้ขยะตกค้าง 100%!

แบบทดสอบวัดระดับความเข้าใจ Day 12: Automated Testing with Testcontainers & pgTAP (pgTAP Assertions, Ephemeral Database Containers, Transactional Test Isolation, Shift-Left Testing) และข้อสอบสะสมทบทวนครบทั้ง Days 1–11 คลิกเลือกคำตอบ ก, ข, ค, หรือ ง เพื่อดูผลลัพธ์และคำอธิบายอย่างละเอียดทันที

🎉 ยินดีด้วยครับ! คุณได้ก้าวผ่านหมุดหมายสำคัญของ Pillar 03: Automated Quality Gate เรียบร้อยแล้ว

บทเรียน Day 12: Automated Testing with Testcontainers & pgTAP ได้เปลี่ยนผ่านกระบวนการตรวจสอบคุณภาพของ Stored Code จากการ Manual Test บน Shared Staging DB สู่กระบวนการ Shift-Left Automated Quality Gate บน CI/CD Pipeline อย่างสมบูรณ์แบบ การเขียน Unit Test ในภาษา SQL ด้วย pgTAP ร่วมกับการครอบด้วย BEGIN...ROLLBACK และการใช้ Testcontainers ช่วยให้คุณการันตีความถูกต้องของโค้ดฐานข้อมูลระดับล้านธุรกรรมได้อย่างมั่นใจ 100%