PDO::ERRMODE_EXCEPTION, PDO::ATTR_DEFAULT_FETCH_MODE => PDO::FETCH_ASSOC, ]); } return $pdo; } function run_migrations() { $pdo = db(); // Create migrations table if it doesn't exist $pdo->exec("CREATE TABLE IF NOT EXISTS migrations ( id INT AUTO_INCREMENT PRIMARY KEY, migration VARCHAR(255) NOT NULL UNIQUE, created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP )"); // Get all run migrations $run_migrations_stmt = $pdo->query("SELECT migration FROM migrations"); $run_migrations = $run_migrations_stmt->fetchAll(PDO::FETCH_COLUMN); // Get all migration files $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]); } } } // Run migrations on every request for simplicity in this context. // For production, this should be a separate script. run_migrations();