PDO::ERRMODE_EXCEPTION, PDO::ATTR_DEFAULT_FETCH_MODE => PDO::FETCH_ASSOC, ]); } return $pdo; } function run_migrations() { $pdo = db(); $pdo->exec("CREATE TABLE IF NOT EXISTS `migrations` (`migration` VARCHAR(255) PRIMARY KEY, `created_at` TIMESTAMP DEFAULT CURRENT_TIMESTAMP)"); $stmt = $pdo->query("SELECT `migration` FROM `migrations`"); $run_migrations = $stmt->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]); } } } run_migrations();