148 lines
7.5 KiB
PHP
148 lines
7.5 KiB
PHP
<?php
|
|
/**
|
|
* MariaDB PDO Databaseverbinding & Automatische Migratie
|
|
*/
|
|
|
|
require_once __DIR__ . '/config.php';
|
|
|
|
function get_db_connection(): PDO {
|
|
static $pdo = null;
|
|
|
|
if ($pdo !== null) {
|
|
return $pdo;
|
|
}
|
|
|
|
// 1. Controleer of de PDO MySQL/MariaDB driver aanwezig is in PHP
|
|
$availableDrivers = PDO::getAvailableDrivers();
|
|
if (!in_array('mysql', $availableDrivers)) {
|
|
$driversList = !empty($availableDrivers) ? implode(', ', $availableDrivers) : 'geen';
|
|
die("
|
|
<div style='font-family: -apple-system, BlinkMacSystemFont, Segoe UI, Roboto, sans-serif; background: #090d16; color: #f1f5f9; min-height: 100vh; display: flex; align-items: center; justify-content: center; padding: 20px;'>
|
|
<div style='max-width: 580px; background: #111827; border: 1px solid #ef4444; border-radius: 16px; padding: 30px; box-shadow: 0 20px 25px -5px rgba(0,0,0,0.5);'>
|
|
<h2 style='color: #ef4444; margin-top: 0;'>⚠️ PHP MySQL Driver Ontbreekt (pdo_mysql)</h2>
|
|
<p style='color: #94a3b8; font-size: 14px;'>De extensie <strong>pdo_mysql</strong> is niet actief in deze PHP-omgeving.</p>
|
|
</div>
|
|
</div>
|
|
");
|
|
}
|
|
|
|
$options = [
|
|
PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION,
|
|
PDO::ATTR_DEFAULT_FETCH_MODE => PDO::FETCH_ASSOC,
|
|
PDO::ATTR_EMULATE_PREPARES => false,
|
|
PDO::ATTR_TIMEOUT => 5,
|
|
];
|
|
if (defined('PDO::MYSQL_ATTR_MULTI_STATEMENTS')) {
|
|
$options[PDO::MYSQL_ATTR_MULTI_STATEMENTS] = true;
|
|
}
|
|
|
|
$dsnWithDb = sprintf(
|
|
'mysql:host=%s;port=%s;dbname=%s;charset=%s',
|
|
DB_HOST,
|
|
DB_PORT,
|
|
DB_NAME,
|
|
DB_CHARSET
|
|
);
|
|
|
|
// 2. CHECK: Bestaat de database al?
|
|
// We proberen eerst direct verbinding te maken met de database.
|
|
// Als de database al bestaat, lukt dit direct zonder database-aanmaakrechten te vereisen!
|
|
try {
|
|
$pdo = new PDO($dsnWithDb, DB_USER, DB_PASS, $options);
|
|
|
|
// De database bestaat al! Controleer enkel of de tabellen al aanwezig zijn
|
|
ensure_tables_exist($pdo);
|
|
return $pdo;
|
|
|
|
} catch (PDOException $e) {
|
|
// Foutcode 1049 betekent: Database 'DB_NAME' bestaat nog NIET op de MariaDB server
|
|
if ($e->getCode() == 1049 || str_contains($e->getMessage(), 'Unknown database')) {
|
|
// Probeer de database eenmalig aan te maken indien de gebruiker CREATE rechten heeft
|
|
try {
|
|
$serverDsn = sprintf('mysql:host=%s;port=%s;charset=%s', DB_HOST, DB_PORT, DB_CHARSET);
|
|
$serverPdo = new PDO($serverDsn, DB_USER, DB_PASS, $options);
|
|
$serverPdo->exec(sprintf(
|
|
'CREATE DATABASE IF NOT EXISTS `%s` CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci',
|
|
DB_NAME
|
|
));
|
|
|
|
// Nu opnieuw verbinden met de nieuw aangemaakte database
|
|
$pdo = new PDO($dsnWithDb, DB_USER, DB_PASS, $options);
|
|
ensure_tables_exist($pdo);
|
|
return $pdo;
|
|
|
|
} catch (PDOException $createEx) {
|
|
die("
|
|
<div style='font-family: sans-serif; background: #090d16; color: #fff; padding: 40px; text-align: center; min-height: 100vh; display: flex; align-items: center; justify-content: center;'>
|
|
<div style='max-width: 500px; background: #111827; border: 1px solid #f59e0b; border-radius: 16px; padding: 30px; text-align: left;'>
|
|
<h2 style='color: #f59e0b; margin-top: 0;'>⚠️ Database '" . htmlspecialchars(DB_NAME) . "' bestaat nog niet</h2>
|
|
<p style='color: #94a3b8; font-size: 14px; line-height: 1.6;'>
|
|
De database <strong>" . htmlspecialchars(DB_NAME) . "</strong> bestaat nog niet op MariaDB server <strong>" . htmlspecialchars(DB_HOST) . "</strong> en de gebruiker <em>" . htmlspecialchars(DB_USER) . "</em> heeft geen rechten om automatisch databases aan te maken.
|
|
</p>
|
|
<p style='color: #cbd5e1; font-size: 13px;'>
|
|
Maak de database <code>" . htmlspecialchars(DB_NAME) . "</code> eenmalig aan via phpMyAdmin, HeidiSQL of de MariaDB CLI:
|
|
</p>
|
|
<code style='display: block; background: #000; color: #4ade80; padding: 10px; border-radius: 8px; font-size: 12px; margin: 10px 0;'>
|
|
CREATE DATABASE IF NOT EXISTS `" . htmlspecialchars(DB_NAME) . "` CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci;
|
|
</code>
|
|
</div>
|
|
</div>
|
|
");
|
|
}
|
|
}
|
|
|
|
// Andere verbindingsfout (bijv. verkeerd wachtwoord, poort of host onbereikbaar)
|
|
die("
|
|
<div style='font-family: sans-serif; background: #090d16; color: #fff; padding: 40px; text-align: center; min-height: 100vh; display: flex; align-items: center; justify-content: center;'>
|
|
<div style='max-width: 520px; background: #111827; border: 1px solid #ef4444; border-radius: 16px; padding: 30px; text-align: left;'>
|
|
<h2 style='color: #ef4444; margin-top: 0;'>MariaDB Verbindingsfout (" . htmlspecialchars((string)$e->getCode()) . ")</h2>
|
|
<p style='color: #cbd5e1; font-size: 14px;'>" . htmlspecialchars($e->getMessage()) . "</p>
|
|
<div style='background: #0b0f17; border: 1px solid #1f2937; padding: 15px; border-radius: 10px; font-size: 13px; margin-top: 15px;'>
|
|
Host: <strong>" . htmlspecialchars(DB_HOST) . "</strong><br>
|
|
Poort: <strong>" . htmlspecialchars(DB_PORT) . "</strong><br>
|
|
Database: <strong>" . htmlspecialchars(DB_NAME) . "</strong><br>
|
|
Gebruiker: <strong>" . htmlspecialchars(DB_USER) . "</strong>
|
|
</div>
|
|
</div>
|
|
</div>
|
|
");
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Zorgt ervoor dat alle benodigde tabellen uit schema.sql aanwezig zijn in MariaDB
|
|
* Voert niets uit als de tabellen al bestaan!
|
|
*/
|
|
function ensure_tables_exist(PDO $pdo): void {
|
|
try {
|
|
// Controleer of de hoofdtabel 'users' al bestaat
|
|
$result = $pdo->query("SHOW TABLES LIKE 'users'");
|
|
if ($result && $result->rowCount() > 0) {
|
|
// Tabellen bestaan al. Voer eventuele niet-destructieve kolom-upgrades uit indien nodig
|
|
try {
|
|
$pdo->exec("ALTER TABLE tasks MODIFY external_id VARCHAR(255) NULL");
|
|
} catch (Throwable $t) {
|
|
// Kolom bestaat wellicht al of heeft al de juiste lengte
|
|
}
|
|
return;
|
|
}
|
|
|
|
// Tabellen ontbreken nog: voer schema.sql uit statement voor statement
|
|
$schemaFile = file_exists(__DIR__ . '/schema.sql') ? (__DIR__ . '/schema.sql') : (__DIR__ . '/../schema.sql');
|
|
if (file_exists($schemaFile)) {
|
|
$sql = file_get_contents($schemaFile);
|
|
$statements = array_filter(array_map('trim', explode(';', $sql)));
|
|
foreach ($statements as $stmt) {
|
|
// Verwijder eventuele SQL commentaren aan het begin
|
|
$stmtClean = preg_replace('/^--.*$/m', '', $stmt);
|
|
$stmtClean = trim($stmtClean);
|
|
if (!empty($stmtClean)) {
|
|
$pdo->exec($stmtClean);
|
|
}
|
|
}
|
|
}
|
|
} catch (Exception $e) {
|
|
error_log("Fout bij aanmaken tabellen: " . $e->getMessage());
|
|
}
|
|
}
|