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