|
@@ 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()]); |