ImportRunBasedPurgeStrategy: fetch chunked rows

refs #1556
This commit is contained in:
Thomas Gelf 2018-07-04 15:18:43 +02:00
parent 23f0ec32d4
commit b77bdcbcf4

View File

@ -72,12 +72,14 @@ class ImportRunBasedPurgeStrategy extends PurgeStrategy
SyncUtils::extractVariableNames($pattern) SyncUtils::extractVariableNames($pattern)
); );
$rows = $runA->fetchRows($columns, null, $result); foreach (array_chunk($result, 1000) as $keys) {
$rows = $runA->fetchRows($columns, null, $keys);
$result = array(); $result = array();
foreach ($rows as $row) { foreach ($rows as $row) {
$result[] = SyncUtils::fillVariables($pattern, $row); $result[] = SyncUtils::fillVariables($pattern, $row);
} }
} }
}
if (empty($result)) { if (empty($result)) {
return array(); return array();