Symfony Profiler

<?php declare(strict_types=1);
namespace Shopware\Core\Framework\DataAbstractionLayer\Dbal\Common;
use Shopware\Core\Framework\Context;
use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
use Shopware\Core\Framework\DataAbstractionLayer\Search\EntitySearchResult;
use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\RangeFilter;
use Shopware\Core\Framework\DataAbstractionLayer\Search\Sorting\FieldSorting;
use Shopware\Core\Framework\Feature;
class RepositoryIterator
{
/**
* @var Criteria
*/
private $criteria;
/**
* @var EntityRepositoryInterface
*/
private $repository;
/**
* @var Context
*/
private $context;
private bool $autoIncrement = false;
public function __construct(EntityRepositoryInterface $repository, Context $context, ?Criteria $criteria = null)
{
if ($criteria === null) {
$criteria = new Criteria();
$criteria->setOffset(0);
}
if ($criteria->getLimit() === null || $criteria->getLimit() < 1) {
$criteria->setLimit(50);
}
if ($repository->getDefinition()->hasAutoIncrement()) {
$criteria->addSorting(new FieldSorting('autoIncrement', FieldSorting::ASCENDING));
$criteria->setFilter('increment', new RangeFilter('autoIncrement', [RangeFilter::GTE => 0]));
$this->autoIncrement = true;
}
$this->criteria = $criteria;
$this->repository = $repository;
$this->context = clone $context;
}
public function getTotal(): int
{
$criteria = clone $this->criteria;
$criteria->setOffset(0);
$criteria->setLimit(1);
$criteria->setTotalCountMode(Criteria::TOTAL_COUNT_MODE_EXACT);
$result = $this->repository->searchIds($criteria, $this->context);
return $result->getTotal();
}
public function fetchIds(): ?array
{
$this->criteria->setTotalCountMode(Criteria::TOTAL_COUNT_MODE_NONE);
$ids = $this->repository->searchIds($this->criteria, $this->context);
$values = $ids->getIds();
if (empty($values)) {
return null;
}
if (!$this->autoIncrement) {
$this->criteria->setOffset($this->criteria->getOffset() + $this->criteria->getLimit());
return $values;
}
$last = end($values);
if (!\is_string($last)) {
throw new \RuntimeException('Expected string as last element of ids array');
}
$increment = $ids->getDataFieldOfId($last, Feature::isActive('v6.5.0.0') ? 'autoIncrement' : 'auto_increment');
$this->criteria->setFilter('increment', new RangeFilter('autoIncrement', [RangeFilter::GT => $increment]));
return $values;
}
public function fetch(): ?EntitySearchResult
{
$this->criteria->setTotalCountMode(Criteria::TOTAL_COUNT_MODE_NONE);
$result = $this->repository->search(clone $this->criteria, $this->context);
// increase offset for next iteration
$this->criteria->setOffset($this->criteria->getOffset() + $this->criteria->getLimit());
if (empty($result->getIds())) {
return null;
}
return $result;
}
}

vendor/shopware/core/Framework/DataAbstractionLayer/Dbal/Common/RepositoryIterator.php line 95