*/ class ImportRepository extends ServiceEntityRepository { public function __construct(ManagerRegistry $registry) { parent::__construct($registry, Import::class); } public function incrementProcessedBatches(Import $import): int { $this->getEntityManager()->getConnection()->executeStatement( 'UPDATE import SET processed_batches = processed_batches + 1 WHERE id = :id', ['id' => $import->getId()] ); return (int) $this->getEntityManager()->getConnection()->fetchOne( 'SELECT processed_batches FROM import WHERE id = :id', ['id' => $import->getId()] ); } public function incrementFailedFilms(Import $import): void { $this->getEntityManager()->getConnection()->executeStatement( 'UPDATE import SET failed_films = failed_films + 1 WHERE id = :id', ['id' => $import->getId()] ); } }