container = $container; } public function up(Schema $schema): void { $jobInstancesToMigrate = $this->getJobInstancesToMigrate(); if (empty($jobInstancesToMigrate)) { $this->write('No remaining job instance to migrate'); return; } foreach ($jobInstancesToMigrate as $jobInstance) { $rawParameters = unserialize($jobInstance['raw_parameters']); $migratedRawParameters = $this->migrateRawParameters($rawParameters); $this->updateJobInstance($jobInstance['id'], serialize($migratedRawParameters)); } } public function down(Schema $schema): void { $this->throwIrreversibleMigrationException(); } private function getJobInstancesToMigrate(): array { $connection = $this->container->get('database_connection'); $sql = <<executeQuery($sql); $jobInstances = $stmt->fetchAll(\PDO::FETCH_ASSOC); return array_filter($jobInstances, function (array $jobInstance) { $rawParameters = unserialize($jobInstance['raw_parameters']); return array_key_exists('user_to_notify', $rawParameters); }); } private function migrateRawParameters(array $rawParameters): array { $rawParameters['users_to_notify'] = null !== $rawParameters['user_to_notify'] ? [$rawParameters['user_to_notify']] : []; unset($rawParameters['user_to_notify']); return $rawParameters; } private function updateJobInstance(string $jobInstanceId, string $serializedRawParameters) { $sql = <<addSql($sql, ['job_instance_id' => $jobInstanceId, 'raw_parameters' => $serializedRawParameters]); } }