PDO::ERRMODE_EXCEPTION, PDO::ATTR_DEFAULT_FETCH_MODE => PDO::FETCH_ASSOC, ]); } return $pdo; } function run_migrations() { $pdo = db(); try { $pdo->query("CREATE TABLE IF NOT EXISTS migrations (migration VARCHAR(255) PRIMARY KEY, created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP)"); $result = $pdo->query("SELECT migration FROM migrations"); $run_migrations = $result->fetchAll(PDO::FETCH_COLUMN); $migration_files = glob(__DIR__ . '/migrations/*.sql'); foreach ($migration_files as $file) { $migration_name = basename($file); if (!in_array($migration_name, $run_migrations)) { $sql = file_get_contents($file); $pdo->exec($sql); $stmt = $pdo->prepare("INSERT INTO migrations (migration) VALUES (?)"); $stmt->execute([$migration_name]); } } } catch (PDOException $e) { error_log('Migration failed: ' . $e->getMessage()); // In a production environment, you might want to die() here. } } run_migrations();