<?php
/**
 * Cấu hình kết nối Cơ sở dữ liệu MySQL dùng chung cho các bài tập trong thư mục document
 * Bạn có thể sửa trực tiếp các hằng số bên dưới hoặc cấu hình ngay trên giao diện trang chủ index.php
 */

$credFile = __DIR__ . '/db_credentials.json';
$savedCreds = [];
if (file_exists($credFile)) {
    $decoded = json_decode(file_get_contents($credFile), true);
    if (is_array($decoded)) {
        $savedCreds = $decoded;
    }
}

if (!defined('DB_HOST')) define('DB_HOST', $savedCreds['host'] ?? (getenv('DB_HOST') ?: '127.0.0.1'));
if (!defined('DB_PORT')) define('DB_PORT', $savedCreds['port'] ?? (getenv('DB_PORT') ?: '3306'));
if (!defined('DB_NAME')) define('DB_NAME', $savedCreds['dbname'] ?? (getenv('DB_NAME') ?: 'labdb'));
if (!defined('DB_USER')) define('DB_USER', $savedCreds['user'] ?? (getenv('DB_USER') ?: 'root'));
if (!defined('DB_PASS')) define('DB_PASS', $savedCreds['pass'] ?? (getenv('DB_PASS') !== false ? getenv('DB_PASS') : ''));
if (!defined('DB_CHARSET')) define('DB_CHARSET', 'utf8mb4');

/**
 * Hàm hỗ trợ tạo kết nối PDO tới MySQL và tự động khởi tạo database `labdb` nếu chưa tồn tại.
 */
function getPdoConnection(bool $selectDb = true): PDO {
    $passwordsToTry = array_values(array_unique([DB_PASS, '', 'root', '123456', '1234', 'admin', 'mysql', '12345678']));
    $lastException = null;

    foreach ($passwordsToTry as $pass) {
        try {
            $dsnNoDb = sprintf('mysql:host=%s;port=%s;charset=%s', DB_HOST, DB_PORT, DB_CHARSET);
            $options = [
                PDO::ATTR_ERRMODE            => PDO::ERRMODE_EXCEPTION,
                PDO::ATTR_DEFAULT_FETCH_MODE => PDO::FETCH_ASSOC,
                PDO::ATTR_EMULATE_PREPARES   => false,
            ];
            $pdo = new PDO($dsnNoDb, DB_USER, $pass, $options);
            if ($selectDb) {
                $pdo->exec("CREATE DATABASE IF NOT EXISTS `" . DB_NAME . "` CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci");
                $pdo->exec("USE `" . DB_NAME . "`");
            }
            return $pdo;
        } catch (PDOException $e) {
            $lastException = $e;
            if ($e->getCode() != 1045) {
                break;
            }
        }
    }

    throw $lastException ?: new PDOException("Không thể kết nối tới MySQL.");
}