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