getMissingProductUuidCount(); } public function shouldBeExecuted(): bool { $sql = <<connection->fetchOne($sql); } public function addMissing(Context $context): bool { $logContext = $context->logContext; $processedItems = 0; while ($this->shouldContinue($context) > 0) { $logContext->addContext('substep', 'missing_product_uuid_batch'); if (!$context->dryRun()) { $this->fillMissingProductUuids(); $processedItems += self::BATCH_SIZE; $this->logger->notice( \sprintf('Processed rows: %d', $processedItems), $logContext->toArray(['processed_uuids_counter' => $processedItems]) ); } else { $this->logger->notice("Option --dry-run is set, will continue to next step.", $logContext->toArray()); break; } } return true; } private function shouldContinue(Context $context): bool { if ($context->withStats()) { return $this->getMissingProductUuidCount() > 0; } return $this->shouldBeExecuted(); } private function getMissingProductUuidCount(): int { return $this->getNullUuidCount('uuid'); } private function getNullUuidCount(string $uuidColumnName): int { $sql = <<connection->fetchOne(\strtr($sql, ['{uuid_column_name}' => $uuidColumnName])); } private function fillMissingProductUuids(): void { $rows = []; for ($rowNumber = 1; $rowNumber <= self::BATCH_SIZE; $rowNumber++) { $rows[] = \sprintf("ROW(%d, '%s')", $rowNumber, Uuid::uuid4()->toString()); } $sql = << \implode(',', $rows), '{batch_size}' => self::BATCH_SIZE, ]); $this->connection->executeQuery($sql); } }