dbConnection = $dbConnection; } protected function configure() { $this ->setDescription('Calculate and store the number of warnings for every job step execution') ->addOption('bulk-size', null, InputOption::VALUE_REQUIRED, 'Bulk size', self::BULK_SIZE) ; } protected function execute(InputInterface $input, OutputInterface $output): int { if (!$this->migrationCanBeStarted()) { $output->writeln('The migration has already been performed or is in progress.'); return 0; } $output->writeln('Start migration...'); $this->persistMigrationStart(); $lastId = 0; $bulkSize = intval($input->getOption('bulk-size')); while ($idBulk = $this->getNextStepExecutionIdBulk($lastId, $bulkSize)) { $lastId = intval($idBulk['last_id']); $this->updateStepExecutionWarningCount(intval($idBulk['first_id']), $lastId); } $this->persistMigrationDone(); $output->writeln('Migration done.'); return 0; } private function persistMigrationStart(): void { $query = <<dbConnection->executeQuery($query, ['code' => self::$defaultName]); } private function persistMigrationDone(): void { $query = <<dbConnection->executeQuery($query, ['code' => self::$defaultName]); } private function migrationCanBeStarted(): bool { $query = <<dbConnection->executeQuery($query, ['code' => self::$defaultName])->fetchOne()); } private function getNextStepExecutionIdBulk(int $lastId, int $bulkSize): ?array { /* * Because of purges, the ids of the step execution are not in a successive order. * So we have to use a range of ids. */ $query = << :lastId LIMIT :bulkSize ) executions_bulk; SQL; $bulkResult = $this->dbConnection->executeQuery( $query, [ 'lastId' => $lastId, 'bulkSize' => $bulkSize, ], [ 'lastId' => \PDO::PARAM_INT, 'bulkSize' => \PDO::PARAM_INT, ] )->fetchAssociative(); return isset($bulkResult['first_id']) && isset($bulkResult['last_id']) ? $bulkResult : null; } private function updateStepExecutionWarningCount(int $firstId, int $lastId): void { $countWarningsQuery = <<dbConnection->executeQuery( $countWarningsQuery, [ 'firstId' => $firstId, 'lastId' => $lastId, ], [ 'firstId' => \PDO::PARAM_INT, 'lastId' => \PDO::PARAM_INT, ] ); while ($row = $stmt->fetchAssociative()) { $this->dbConnection->executeQuery( $updateStepExecutionQuery, [ 'id' => $row['step_execution_id'], 'warningCount' => $row['warning_count'] ], [ 'id' => \PDO::PARAM_INT, 'warningCount' => \PDO::PARAM_INT, ] ); } } }