@@ 221-223 (lines=3) @@ | ||
218 | $logOffset = $totalRecords >= 500 ? 100 : 50; |
|
219 | $processedRecords = 0; |
|
220 | foreach ($records as $record) { |
|
221 | if (($processedRecords % $logOffset) === 0) { |
|
222 | $this->logger->info(sprintf('%d/%s records processed for module %s', $processedRecords, $totalRecords, $dao->getPluralModuleName())); |
|
223 | } |
|
224 | ++$processedRecords; |
|
225 | $data = []; |
|
226 | $types = []; |
|
@@ 282-284 (lines=3) @@ | ||
279 | $processedRecords = 0; |
|
280 | $logOffset = $totalRecordsDeleted >= 500 ? 100 : 50; |
|
281 | foreach ($deletedRecords as $deletedRecord) { |
|
282 | if (($processedRecords % $logOffset) === 0) { |
|
283 | $this->logger->info(sprintf('%d/%d records processed for module %s', $processedRecords, $totalRecordsDeleted, $dao->getPluralModuleName())); |
|
284 | } |
|
285 | ++$processedRecords; |
|
286 | $this->logger->debug(sprintf('Deleting record with ID \'%s\' in table %s...', $deletedRecord->getEntityId(), $tableName)); |
|
287 | $uid = $this->connection->fetchColumn($sqlStatementUid, ['id' => $deletedRecord->getEntityId()]); |