@@ 294-296 (lines=3) @@ | ||
291 | $logOffset = $totalRecords >= 500 ? 100 : 50; |
|
292 | $processedRecords = 0; |
|
293 | foreach ($records as $record) { |
|
294 | if (($processedRecords % $logOffset) === 0) { |
|
295 | $this->logger->info(sprintf('%d/%s records processed for module %s', $processedRecords, $totalRecords, $dao->getPluralModuleName())); |
|
296 | } |
|
297 | ++$processedRecords; |
|
298 | $data = []; |
|
299 | $types = []; |
|
@@ 355-357 (lines=3) @@ | ||
352 | $processedRecords = 0; |
|
353 | $logOffset = $totalRecordsDeleted >= 500 ? 100 : 50; |
|
354 | foreach ($deletedRecords as $deletedRecord) { |
|
355 | if (($processedRecords % $logOffset) === 0) { |
|
356 | $this->logger->info(sprintf('%d/%d records processed for module %s', $processedRecords, $totalRecordsDeleted, $dao->getPluralModuleName())); |
|
357 | } |
|
358 | ++$processedRecords; |
|
359 | $this->logger->debug(sprintf('Deleting record with ID \'%s\' in table %s...', $deletedRecord->getEntityId(), $tableName)); |
|
360 | $uid = $this->connection->fetchColumn($sqlStatementUid, ['id' => $deletedRecord->getEntityId()]); |