connection = $connection; } public function getByJobExecutionId(int $jobExecutionId): ?BatchStatus { $sql = <<connection->executeQuery( $sql, ['job_execution_id' => $jobExecutionId], ['job_execution_id' => \PDO::PARAM_INT] )->fetchAssociative(); if (false === $result) { return null; } return new BatchStatus((int) $result['status']); } }