createJobExecution($jobInstanceCode); $this->assertTrue($this->jobInstanceExists($jobInstanceCode)); $this->assertTrue($this->jobExecutionExists($jobExecutionId)); $this->getJobInstanceRepository()->remove($jobInstanceCode); $this->assertFalse($this->jobInstanceExists($jobInstanceCode)); $this->assertFalse($this->jobExecutionExists($jobExecutionId)); } private function createJobExecution(string $jobInstanceCode): int { $jobInstance = $this->getJobInstanceRepository()->findOneByIdentifier($jobInstanceCode); $job = $this->get('akeneo_batch.job.job_registry')->get($jobInstanceCode); $jobParameters = new JobParameters([]); $jobExecution = $this->getDoctrineJobRepository()->createJobExecution($job, $jobInstance, $jobParameters); return $jobExecution->getId(); } private function jobInstanceExists(string $jobInstanceCode): bool { $sql = <<getConnection()->executeQuery($sql, ['code' => $jobInstanceCode]); $count = $stmt->fetchOne(); return 0 < $count; } private function jobExecutionExists(int $jobExecutionId): bool { $sql = <<getConnection()->executeQuery($sql, ['id' => $jobExecutionId]); $count = $stmt->fetchOne(); return 0 < $count; } private function getDoctrineJobRepository(): DoctrineJobRepository { return $this->get('akeneo_batch.job_repository'); } private function getJobInstanceRepository(): JobInstanceRepository { return $this->get('akeneo_batch.job.job_instance_repository'); } private function getConnection(): Connection { return $this->get('database_connection'); } protected function getConfiguration(): Configuration { return $this->catalog->useTechnicalCatalog(); } }