การใช้ PDO กับ Database Abstraction Layer

การใช้ PDO กับ Database Abstraction Layer

ในบทที่แล้ว เราได้เรียนรู้เกี่ยวกับการใช้ PDO เพื่อเชื่อมต่อและใช้งานฐานข้อมูลหลายแห่งพร้อมกัน ซึ่งเป็นประโยชน์อย่างมากเมื่อแอปพลิเคชันของคุณต้องการเข้าถึงข้อมูลจากแหล่งที่แตกต่างกัน แต่การจัดการการเชื่อมต่อและ query โดยตรงกับฐานข้อมูลแต่ละแห่งอาจทำให้โค้ดของคุณซับซ้อนและยากต่อการบำรุงรักษาได้ ในบทนี้ เราจะมาเรียนรู้เกี่ยวกับ Database Abstraction Layer (DAL) ซึ่งเป็นเทคนิคที่ช่วยให้เราจัดการฐานข้อมูลได้ง่ายขึ้นและเป็นระบบมากขึ้น

Database Abstraction Layer คืออะไร?

Database Abstraction Layer (DAL) คือชั้นของโค้ดที่ทำหน้าที่เป็นตัวกลางระหว่างแอปพลิเคชันของคุณกับฐานข้อมูลจริง DAL ช่วยให้คุณสามารถ:

• ซ่อนความซับซ้อนของการเชื่อมต่อและ query ฐานข้อมูล: คุณไม่ต้องเขียนโค้ดที่ซับซ้อนเพื่อเชื่อมต่อกับฐานข้อมูล, สร้าง query, หรือจัดการ result set โดยตรง DAL จะจัดการสิ่งเหล่านี้ให้คุณ
• เปลี่ยนฐานข้อมูลได้ง่ายขึ้น: หากคุณต้องการเปลี่ยนจาก MySQL เป็น PostgreSQL หรือฐานข้อมูลอื่น ๆ คุณเพียงแค่แก้ไข DAL แทนที่จะต้องแก้ไขโค้ดในทุกส่วนของแอปพลิเคชัน
• ปรับปรุงความปลอดภัย: DAL สามารถช่วยป้องกัน SQL Injection และช่องโหว่อื่น ๆ ได้
• เพิ่มความสามารถในการทดสอบ: คุณสามารถทดสอบโค้ดที่ใช้ DAL ได้ง่ายขึ้นโดยไม่ต้องเชื่อมต่อกับฐานข้อมูลจริง

กล่าวโดยสรุป DAL คือการสร้าง API ที่ช่วยให้คุณทำงานกับฐานข้อมูลได้ในระดับที่สูงขึ้น โดยไม่ต้องกังวลเกี่ยวกับรายละเอียดทางเทคนิคของการจัดการฐานข้อมูลโดยตรง

ตัวอย่างการใช้งาน Database Abstraction Layer อย่างง่าย

เพื่อแสดงให้เห็นถึงแนวคิดของ DAL เราจะสร้างตัวอย่าง DAL อย่างง่ายสำหรับจัดการข้อมูลผู้ใช้ในฐานข้อมูล MySQL โดยใช้ PDO

1. สร้างไฟล์ Database.php

ไฟล์นี้จะทำหน้าที่เป็น DAL ของเรา โดยจะประกอบด้วยคลาส Database ที่มีเมธอดสำหรับการเชื่อมต่อฐานข้อมูลและการ execute query

<?php

class Database {
  private $pdo;
  private $host = 'localhost';
  private $db   = 'mydatabase';
  private $user = 'root';
  private $pass = '';
  private $charset = 'utf8mb4';

  public function __construct() {
    $dsn = "mysql:host=$this->host;dbname=$this->db;charset=$this->charset";
    $options = [
      PDO::ATTR_ERRMODE            => PDO::ERRMODE_EXCEPTION,
      PDO::ATTR_DEFAULT_FETCH_MODE => PDO::FETCH_ASSOC,
      PDO::ATTR_EMULATE_PREPARES   => false,
    ];
    try {
      $this->pdo = new PDO($dsn, $this->user, $this->pass, $options);
    } catch (\PDOException $e) {
      throw new \PDOException($e->getMessage(), (int)$e->getCode());
    }
  }

  public function query(string $sql, array $params = []): PDOStatement {
    $stmt = $this->pdo->prepare($sql);
    $stmt->execute($params);
    return $stmt;
  }

  public function fetch(string $sql, array $params = []): mixed {
    $stmt = $this->query($sql, $params);
    return $stmt->fetch();
  }

  public function fetchAll(string $sql, array $params = []): array {
    $stmt = $this->query($sql, $params);
    return $stmt->fetchAll();
  }
}

คำอธิบายโค้ด:

• __construct(): Constructor ของคลาส ทำหน้าที่สร้างการเชื่อมต่อ PDO กับฐานข้อมูล
• query(string $sql, array $params = []): เตรียม prepared statement และ execute query โดยรับ SQL query และ parameters เป็น input
• fetch(string $sql, array $params = []): Execute query และ return ผลลัพธ์แถวแรก
• fetchAll(string $sql, array $params = []): Execute query และ return ผลลัพธ์ทั้งหมดเป็น array

2. สร้างไฟล์ User.php

ไฟล์นี้จะแสดงตัวอย่างการใช้ DAL (คลาส Database) เพื่อจัดการข้อมูลผู้ใช้

<?php

require_once 'Database.php';

class User {
  private $db;

  public function __construct() {
    $this->db = new Database();
  }

  public function createUser(string $username, string $password, string $email): bool {
    $sql = "INSERT INTO users (username, password, email) VALUES (:username, :password, :email)";
    $params = [
      ':username' => $username,
      ':password' => password_hash($password, PASSWORD_DEFAULT),
      ':email' => $email,
    ];

    try {
        $this->db->query($sql, $params);
        return true;
    } catch (PDOException $e) {
        // Handle error (e.g., log the error)
        error_log("Error creating user: " . $e->getMessage());
        return false;
    }
  }

  public function getUserById(int $id): ?array {
    $sql = "SELECT * FROM users WHERE id = :id";
    $params = [':id' => $id];
    return $this->db->fetch($sql, $params);
  }

  public function getAllUsers(): array {
    $sql = "SELECT * FROM users";
    return $this->db->fetchAll($sql);
  }

  public function updateUserEmail(int $id, string $newEmail): bool {
    $sql = "UPDATE users SET email = :email WHERE id = :id";
    $params = [
      ':email' => $newEmail,
      ':id' => $id,
    ];
    try {
        $this->db->query($sql, $params);
        return true;
    } catch (PDOException $e) {
        // Handle error (e.g., log the error)
        error_log("Error updating user email: " . $e->getMessage());
        return false;
    }
  }

  public function deleteUser(int $id): bool {
    $sql = "DELETE FROM users WHERE id = :id";
    $params = [':id' => $id];

    try {
        $this->db->query($sql, $params);
        return true;
    } catch (PDOException $e) {
        // Handle error (e.g., log the error)
        error_log("Error deleting user: " . $e->getMessage());
        return false;
    }
  }
}

คำอธิบายโค้ด:

• __construct(): Constructor ของคลาส ทำหน้าที่สร้าง instance ของคลาส Database
• createUser(string $username, string $password, string $email): สร้างผู้ใช้ใหม่ในฐานข้อมูล
• getUserById(int $id): ดึงข้อมูลผู้ใช้จากฐานข้อมูลโดยใช้ ID
• getAllUsers(): ดึงข้อมูลผู้ใช้ทั้งหมดจากฐานข้อมูล
• updateUserEmail(int $id, string $newEmail): อัปเดตอีเมลของผู้ใช้ในฐานข้อมูล
• deleteUser(int $id): ลบผู้ใช้จากฐานข้อมูล

3. ตัวอย่างการใช้งาน User.php

<?php

require_once 'User.php';

$user = new User();

// สร้างผู้ใช้ใหม่
if ($user->createUser('john_doe', 'password123', 'john.doe@example.com')) {
  echo "User created successfully!\n";
} else {
  echo "Failed to create user.\n";
}

// ดึงข้อมูลผู้ใช้โดยใช้ ID
$userData = $user->getUserById(1);
if ($userData) {
  echo "User data: " . print_r($userData, true) . "\n";
} else {
  echo "User not found.\n";
}

// ดึงข้อมูลผู้ใช้ทั้งหมด
$allUsers = $user->getAllUsers();
echo "All users: " . print_r($allUsers, true) . "\n";

// อัปเดตอีเมลของผู้ใช้
if ($user->updateUserEmail(1, 'john.new@example.com')) {
  echo "User email updated successfully!\n";
} else {
  echo "Failed to update user email.\n";
}

// ลบผู้ใช้
if ($user->deleteUser(1)) {
  echo "User deleted successfully!\n";
} else {
  echo "Failed to delete user.\n";
}

ตัวอย่างนี้แสดงให้เห็นว่าเราสามารถใช้คลาส User เพื่อจัดการข้อมูลผู้ใช้ได้โดยไม่ต้องเขียน SQL query โดยตรง

ข้อดีและข้อเสียของ Database Abstraction Layer

ข้อดี:

• Reusability: DAL ช่วยให้โค้ดของคุณสามารถนำกลับมาใช้ใหม่ได้ง่ายขึ้น
• Maintainability: การเปลี่ยนแปลงฐานข้อมูลจะส่งผลกระทบน้อยต่อโค้ดส่วนอื่น ๆ ของแอปพลิเคชัน
• Testability: คุณสามารถสร้าง mock object สำหรับ DAL เพื่อทดสอบโค้ดของคุณได้โดยไม่ต้องพึ่งพาฐานข้อมูลจริง
• Security: DAL สามารถช่วยป้องกัน SQL Injection ได้โดยการใช้ Prepared Statements อย่างถูกต้อง

ข้อเสีย:

• Overhead: การใช้ DAL อาจเพิ่ม overhead เล็กน้อยเนื่องจากมีการเรียกใช้ฟังก์ชันเพิ่มเติม
• Complexity: การสร้าง DAL ที่ดีอาจต้องใช้เวลาและความพยายาม
• Abstraction Leakage: บางครั้งคุณอาจต้องเจอกับปัญหาที่ DAL ไม่สามารถจัดการได้ ทำให้คุณต้องเขียนโค้ดที่เฉพาะเจาะจงสำหรับฐานข้อมูลนั้น ๆ

สรุป

Database Abstraction Layer เป็นเทคนิคที่มีประโยชน์อย่างมากในการจัดการฐานข้อมูลใน PHP โดยเฉพาะอย่างยิ่งเมื่อแอปพลิเคชันของคุณมีความซับซ้อนและต้องการรองรับฐานข้อมูลหลายประเภท การสร้าง DAL ที่ดีจะช่วยให้โค้ดของคุณมีความยืดหยุ่น, บำรุงรักษาง่าย, และปลอดภัยมากขึ้น ในบทต่อไป เราจะพูดถึงการใช้ PDO กับ ORM (Object-Relational Mapping) ซึ่งเป็นอีกหนึ่งเทคนิคที่ช่วยให้เราทำงานกับฐานข้อมูลได้ง่ายขึ้น