ltbxd-actorle/src/Repository/ImportRepository.php

<?php

declare(strict_types=1);

namespace App\Repository;

use App\Entity\Import;
use Doctrine\Bundle\DoctrineBundle\Repository\ServiceEntityRepository;
use Doctrine\Persistence\ManagerRegistry;

/**
 * @extends ServiceEntityRepository<Import>
 */
class ImportRepository extends ServiceEntityRepository
{
    public function __construct(ManagerRegistry $registry)
    {
        parent::__construct($registry, Import::class);
    }

    public function incrementProcessedBatches(Import $import): int
    {
        return (int) $this->getEntityManager()->getConnection()->fetchOne(
            'UPDATE import SET processed_batches = processed_batches + 1 WHERE id = :id RETURNING processed_batches',
            ['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()]
        );
    }
}