|
@@ 214-216 (lines=3) @@
|
| 211 |
|
$logOffset = $totalRecords >= 500 ? 100 : 50; |
| 212 |
|
$processedRecords = 0; |
| 213 |
|
foreach ($records as $record) { |
| 214 |
|
if (($processedRecords % $logOffset) === 0) { |
| 215 |
|
$this->logger->info($processedRecords . '/' . $totalRecords . ' records processed'); |
| 216 |
|
} |
| 217 |
|
++$processedRecords; |
| 218 |
|
$data = []; |
| 219 |
|
$types = []; |
|
@@ 275-277 (lines=3) @@
|
| 272 |
|
$sqlStatementUid = 'select uid from ' . $this->connection->quoteIdentifier($tableName) . ' where id = :id'; |
| 273 |
|
$processedRecords = 0; |
| 274 |
|
foreach ($deletedRecords as $deletedRecord) { |
| 275 |
|
if (($processedRecords % $logOffset) === 0) { |
| 276 |
|
$this->logger->info($processedRecords . '/' . $totalRecords . ' records processed'); |
| 277 |
|
} |
| 278 |
|
++$processedRecords; |
| 279 |
|
$this->logger->debug("Deleting record with ID '" . $deletedRecord->getEntityId() . "'..."); |
| 280 |
|
$uid = $this->connection->fetchColumn($sqlStatementUid, ['id' => $deletedRecord->getEntityId()]); |