From b77bdcbcf4224e9c11cdb83c39c377bd69457fb1 Mon Sep 17 00:00:00 2001
From: Thomas Gelf <thomas@gelf.net>
Date: Wed, 4 Jul 2018 15:18:43 +0200
Subject: [PATCH] ImportRunBasedPurgeStrategy: fetch chunked rows

refs #1556
---
 .../PurgeStrategy/ImportRunBasedPurgeStrategy.php      | 10 ++++++----
 1 file changed, 6 insertions(+), 4 deletions(-)

diff --git a/library/Director/Import/PurgeStrategy/ImportRunBasedPurgeStrategy.php b/library/Director/Import/PurgeStrategy/ImportRunBasedPurgeStrategy.php
index 16f2a8cc..e8a7ae15 100644
--- a/library/Director/Import/PurgeStrategy/ImportRunBasedPurgeStrategy.php
+++ b/library/Director/Import/PurgeStrategy/ImportRunBasedPurgeStrategy.php
@@ -72,10 +72,12 @@ class ImportRunBasedPurgeStrategy extends PurgeStrategy
                 SyncUtils::extractVariableNames($pattern)
             );
 
-            $rows = $runA->fetchRows($columns, null, $result);
-            $result = array();
-            foreach ($rows as $row) {
-                $result[] = SyncUtils::fillVariables($pattern, $row);
+            foreach (array_chunk($result, 1000) as $keys) {
+                $rows = $runA->fetchRows($columns, null, $keys);
+                $result = array();
+                foreach ($rows as $row) {
+                    $result[] = SyncUtils::fillVariables($pattern, $row);
+                }
             }
         }