CollectionByPagesIterator.php 1.6 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849
  1. <?php
  2. /**
  3. * Copyright © Magento, Inc. All rights reserved.
  4. * See COPYING.txt for license details.
  5. */
  6. namespace Magento\ImportExport\Model\ResourceModel;
  7. /**
  8. * Collection by pages iterator
  9. *
  10. * @api
  11. * @since 100.0.2
  12. */
  13. class CollectionByPagesIterator
  14. {
  15. /**
  16. * Load collection page by page and apply callbacks to each collection item
  17. *
  18. * @param \Magento\Framework\Data\Collection\AbstractDb $collection Collection to load page by page
  19. * @param int $pageSize Number of items to fetch from db in one query
  20. * @param array $callbacks Array of callbacks which should be applied to each collection item
  21. * @return void
  22. */
  23. public function iterate(\Magento\Framework\Data\Collection\AbstractDb $collection, $pageSize, array $callbacks)
  24. {
  25. /** @var $paginatedCollection \Magento\Framework\Data\Collection\AbstractDb */
  26. $paginatedCollection = null;
  27. $pageNumber = 1;
  28. do {
  29. $paginatedCollection = clone $collection;
  30. $paginatedCollection->clear();
  31. $paginatedCollection->setPageSize($pageSize)->setCurPage($pageNumber);
  32. if ($paginatedCollection->count() > 0) {
  33. foreach ($paginatedCollection as $item) {
  34. foreach ($callbacks as $callback) {
  35. call_user_func($callback, $item);
  36. }
  37. }
  38. }
  39. $pageNumber++;
  40. } while ($pageNumber <= $paginatedCollection->getLastPageNumber());
  41. $paginatedCollection->clear();
  42. unset($paginatedCollection);
  43. }
  44. }