PDO: بديل للوصول إلى قاعدة البيانات

<?php
$host = 'localhost';
$dbname = 'my_database';
$username = 'root';
$password = '';

try {
    // إنشاء مثيل PDO
    $pdo = new PDO(
        "mysql:host=$host;dbname=$dbname;charset=utf8mb4",
        $username,
        $password,
        [
            PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION,
            PDO::ATTR_DEFAULT_FETCH_MODE => PDO::FETCH_ASSOC,
            PDO::ATTR_EMULATE_PREPARES => false
        ]
    );

    echo "تم الاتصال بنجاح";
} catch (PDOException $e) {
    die("فشل الاتصال: " . $e->getMessage());
}
?>

<?php
class Database {
    private $host = 'localhost';
    private $dbname = 'my_database';
    private $username = 'root';
    private $password = '';
    private $pdo;

    public function __construct() {
        $dsn = "mysql:host={$this->host};dbname={$this->dbname};charset=utf8mb4";

        $options = [
            PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION,
            PDO::ATTR_DEFAULT_FETCH_MODE => PDO::FETCH_ASSOC,
            PDO::ATTR_EMULATE_PREPARES => false,
            PDO::ATTR_PERSISTENT => false
        ];

        try {
            $this->pdo = new PDO($dsn, $this->username, $this->password, $options);
        } catch (PDOException $e) {
            throw new PDOException($e->getMessage(), (int)$e->getCode());
        }
    }

    public function getConnection() {
        return $this->pdo;
    }
}

// الاستخدام
$db = new Database();
$pdo = $db->getConnection();
?>

<?php
// تحضير العبارة
$stmt = $pdo->prepare("SELECT * FROM users WHERE username = ? AND email = ?");

// التنفيذ مع مصفوفة المعلمات
$stmt->execute(['johndoe', 'john@example.com']);

// جلب النتائج
$user = $stmt->fetch();

if ($user) {
    echo "تم العثور على المستخدم: " . $user['username'];
} else {
    echo "لم يتم العثور على المستخدم";
}
?>

<?php
// تحضير العبارة مع المعلمات المسماة
$stmt = $pdo->prepare("SELECT * FROM users WHERE username = :username AND email = :email");

// التنفيذ مع مصفوفة ترابطية
$stmt->execute([
    ':username' => 'johndoe',
    ':email' => 'john@example.com'
]);

$user = $stmt->fetch();
?>

<?php
// مع المعلمات المسماة
$stmt = $pdo->prepare("
    INSERT INTO users (username, email, password, full_name)
    VALUES (:username, :email, :password, :full_name)
");

$stmt->execute([
    ':username' => 'johndoe',
    ':email' => 'john@example.com',
    ':password' => password_hash('password123', PASSWORD_DEFAULT),
    ':full_name' => 'John Doe'
]);

// الحصول على آخر معرف إدراج
$user_id = $pdo->lastInsertId();
echo "معرف المستخدم الجديد: $user_id";
?>

<?php
$stmt = $pdo->prepare("
    UPDATE users
    SET email = :email, full_name = :full_name
    WHERE id = :id
");

$stmt->execute([
    ':email' => 'newemail@example.com',
    ':full_name' => 'John Smith',
    ':id' => 42
]);

// الحصول على عدد الصفوف المتأثرة
$affected = $stmt->rowCount();
echo "الصفوف المحدثة: $affected";
?>

<?php
$stmt = $pdo->prepare("DELETE FROM users WHERE id = :id");
$stmt->execute([':id' => 42]);

echo "الصفوف المحذوفة: " . $stmt->rowCount();
?>

<?php
$stmt = $pdo->query("SELECT * FROM users");

// 1. جلب كمصفوفة ترابطية (افتراضي إذا تم تعيينه في المنشئ)
$row = $stmt->fetch(PDO::FETCH_ASSOC);
// الاستخدام: $row['username']

// 2. جلب كمصفوفة رقمية
$row = $stmt->fetch(PDO::FETCH_NUM);
// الاستخدام: $row[0], $row[1]

// 3. جلب كمصفوفة ترابطية ورقمية معًا
$row = $stmt->fetch(PDO::FETCH_BOTH);
// الاستخدام: $row['username'] أو $row[0]

// 4. جلب ككائن (stdClass)
$row = $stmt->fetch(PDO::FETCH_OBJ);
// الاستخدام: $row->username

// 5. جلب جميع الصفوف دفعة واحدة
$rows = $stmt->fetchAll(PDO::FETCH_ASSOC);

// 6. جلب عمود واحد
$stmt = $pdo->query("SELECT username FROM users");
$usernames = $stmt->fetchAll(PDO::FETCH_COLUMN);
// يُرجع: ['user1', 'user2', 'user3']

// 7. جلب أزواج المفتاح والقيمة
$stmt = $pdo->query("SELECT id, username FROM users");
$users = $stmt->fetchAll(PDO::FETCH_KEY_PAIR);
// يُرجع: [1 => 'user1', 2 => 'user2']
?>

<?php
class User {
    public $id;
    public $username;
    public $email;
    public $full_name;

    public function greet() {
        return "مرحبًا، اسمي {$this->full_name}";
    }
}

// جلب إلى فئة مخصصة
$stmt = $pdo->query("SELECT * FROM users WHERE id = 1");
$user = $stmt->fetchObject('User');

echo $user->greet(); // "مرحبًا، اسمي John Doe"

// جلب الكل إلى فئة مخصصة
$stmt = $pdo->query("SELECT * FROM users");
$users = $stmt->fetchAll(PDO::FETCH_CLASS, 'User');

foreach ($users as $user) {
    echo $user->greet() . "<br>";
}
?>

<?php
try {
    // بدء المعاملة
    $pdo->beginTransaction();

    // عمليات متعددة
    $stmt1 = $pdo->prepare("INSERT INTO users (username, email) VALUES (?, ?)");
    $stmt1->execute(['user1', 'user1@example.com']);

    $stmt2 = $pdo->prepare("INSERT INTO profiles (user_id, bio) VALUES (?, ?)");
    $stmt2->execute([$pdo->lastInsertId(), 'سيرتي الذاتية']);

    $stmt3 = $pdo->prepare("UPDATE stats SET user_count = user_count + 1");
    $stmt3->execute();

    // تأكيد إذا نجحت جميعها
    $pdo->commit();
    echo "تمت جميع العمليات بنجاح";

} catch (Exception $e) {
    // التراجع إذا فشل أي منها
    $pdo->rollBack();
    echo "فشلت المعاملة: " . $e->getMessage();
}
?>

<?php
class UserRepository {
    private $pdo;

    public function __construct(PDO $pdo) {
        $this->pdo = $pdo;
    }

    // CREATE
    public function create($data) {
        $stmt = $this->pdo->prepare("
            INSERT INTO users (username, email, password, full_name)
            VALUES (:username, :email, :password, :full_name)
        ");

        $stmt->execute([
            ':username' => $data['username'],
            ':email' => $data['email'],
            ':password' => password_hash($data['password'], PASSWORD_DEFAULT),
            ':full_name' => $data['full_name']
        ]);

        return $this->pdo->lastInsertId();
    }

    // READ - الحصول على واحد
    public function findById($id) {
        $stmt = $this->pdo->prepare("SELECT * FROM users WHERE id = :id");
        $stmt->execute([':id' => $id]);
        return $stmt->fetch();
    }

    // READ - الحصول على الكل
    public function findAll() {
        $stmt = $this->pdo->query("SELECT * FROM users ORDER BY created_at DESC");
        return $stmt->fetchAll();
    }

    // UPDATE
    public function update($id, $data) {
        $stmt = $this->pdo->prepare("
            UPDATE users
            SET username = :username, email = :email, full_name = :full_name
            WHERE id = :id
        ");

        return $stmt->execute([
            ':username' => $data['username'],
            ':email' => $data['email'],
            ':full_name' => $data['full_name'],
            ':id' => $id
        ]);
    }

    // DELETE
    public function delete($id) {
        $stmt = $this->pdo->prepare("DELETE FROM users WHERE id = :id");
        return $stmt->execute([':id' => $id]);
    }

    // AUTHENTICATE
    public function authenticate($username, $password) {
        $stmt = $this->pdo->prepare("SELECT * FROM users WHERE username = :username");
        $stmt->execute([':username' => $username]);
        $user = $stmt->fetch();

        if ($user && password_verify($password, $user['password'])) {
            unset($user['password']);
            return $user;
        }

        return false;
    }
}
?>