$query =
$this->connection->
createQueryBuilder();
$escaped = EntityDefinitionQueryHelper::
escape($definition->
getEntityName());
$column = EntityDefinitionQueryHelper::
escape($column);
$query->
from($escaped);
$query->
select('id', 'parent_id'
);
$query->
andWhere($column . ' IN (:ids)'
);
$query->
setParameter('ids',
$ids, ArrayParameterType::STRING
);
$this->
makeQueryVersionAware($definition, Uuid::
fromHexToBytes($context->
getVersionId()),
$query);
$fetchedIds =
[];
foreach ($query->
executeQuery()->
fetchAllAssociative() as $entity) { $bag->
addEntity($entity['id'
],
$entity);
$fetchedIds[$entity['id'
]] =
$entity['id'
];
} return $fetchedIds;
} /**
* @param array<string> $updateIds
*/
private function updateLevelRecursively(array
$updateIds, EntityDefinition
$definition, Context
$context, TreeUpdaterBag
$bag): void
{