nextcloud / server

core/Command/Db/AddMissingIndices.php

Indentation +100 added lines, -100 removed lines

@@ -26,104 +26,104 @@
  * @package OC\Core\Command\Db
  */
 class AddMissingIndices extends Command {
-	public function __construct(
-		private Connection $connection,
-		private IEventDispatcher $dispatcher,
-	) {
-		parent::__construct();
-	}
-
-	protected function configure() {
-		$this
-			->setName('db:add-missing-indices')
-			->setDescription('Add missing indices to the database tables')
-			->addOption('dry-run', null, InputOption::VALUE_NONE, 'Output the SQL queries instead of running them.');
-	}
-
-	protected function execute(InputInterface $input, OutputInterface $output): int {
-		$dryRun = $input->getOption('dry-run');
-
-		// Dispatch event so apps can also update indexes if needed
-		$event = new AddMissingIndicesEvent();
-		$this->dispatcher->dispatchTyped($event);
-
-		$missingIndices = $event->getMissingIndices();
-		$toReplaceIndices = $event->getIndicesToReplace();
-
-		if ($missingIndices !== [] || $toReplaceIndices !== []) {
-			$schema = new SchemaWrapper($this->connection);
-
-			foreach ($missingIndices as $missingIndex) {
-				if ($schema->hasTable($missingIndex['tableName'])) {
-					$table = $schema->getTable($missingIndex['tableName']);
-					if (!$table->hasIndex($missingIndex['indexName'])) {
-						$output->writeln('<info>Adding additional ' . $missingIndex['indexName'] . ' index to the ' . $table->getName() . ' table, this can take some time...</info>');
-
-						if ($missingIndex['dropUnnamedIndex']) {
-							foreach ($table->getIndexes() as $index) {
-								$columns = $index->getColumns();
-								if ($columns === $missingIndex['columns']) {
-									$table->dropIndex($index->getName());
-								}
-							}
-						}
-
-						if ($missingIndex['uniqueIndex']) {
-							$table->addUniqueIndex($missingIndex['columns'], $missingIndex['indexName'], $missingIndex['options']);
-						} else {
-							$table->addIndex($missingIndex['columns'], $missingIndex['indexName'], [], $missingIndex['options']);
-						}
-
-						if (!$dryRun) {
-							$this->connection->migrateToSchema($schema->getWrappedSchema());
-						}
-						$output->writeln('<info>' . $table->getName() . ' table updated successfully.</info>');
-					}
-				}
-			}
-
-			foreach ($toReplaceIndices as $toReplaceIndex) {
-				if ($schema->hasTable($toReplaceIndex['tableName'])) {
-					$table = $schema->getTable($toReplaceIndex['tableName']);
-
-					if ($table->hasIndex($toReplaceIndex['newIndexName'])) {
-						continue;
-					}
-
-					$output->writeln('<info>Adding additional ' . $toReplaceIndex['newIndexName'] . ' index to the ' . $table->getName() . ' table, this can take some time...</info>');
-
-					if ($toReplaceIndex['uniqueIndex']) {
-						$table->addUniqueIndex($toReplaceIndex['columns'], $toReplaceIndex['newIndexName'], $toReplaceIndex['options']);
-					} else {
-						$table->addIndex($toReplaceIndex['columns'], $toReplaceIndex['newIndexName'], [], $toReplaceIndex['options']);
-					}
-
-					if (!$dryRun) {
-						$this->connection->migrateToSchema($schema->getWrappedSchema());
-					}
-
-					foreach ($toReplaceIndex['oldIndexNames'] as $oldIndexName) {
-						if ($table->hasIndex($oldIndexName)) {
-							$output->writeln('<info>Removing ' . $oldIndexName . ' index from the ' . $table->getName() . ' table</info>');
-							$table->dropIndex($oldIndexName);
-						}
-					}
-
-					if (!$dryRun) {
-						$this->connection->migrateToSchema($schema->getWrappedSchema());
-					}
-					$output->writeln('<info>' . $table->getName() . ' table updated successfully.</info>');
-				}
-			}
-
-			if ($dryRun) {
-				$sqlQueries = $this->connection->migrateToSchema($schema->getWrappedSchema(), $dryRun);
-				if ($sqlQueries !== null) {
-					$output->writeln($sqlQueries);
-				}
-			}
-		}
-
-		return 0;
-	}
+    public function __construct(
+        private Connection $connection,
+        private IEventDispatcher $dispatcher,
+    ) {
+        parent::__construct();
+    }
+
+    protected function configure() {
+        $this
+            ->setName('db:add-missing-indices')
+            ->setDescription('Add missing indices to the database tables')
+            ->addOption('dry-run', null, InputOption::VALUE_NONE, 'Output the SQL queries instead of running them.');
+    }
+
+    protected function execute(InputInterface $input, OutputInterface $output): int {
+        $dryRun = $input->getOption('dry-run');
+
+        // Dispatch event so apps can also update indexes if needed
+        $event = new AddMissingIndicesEvent();
+        $this->dispatcher->dispatchTyped($event);
+
+        $missingIndices = $event->getMissingIndices();
+        $toReplaceIndices = $event->getIndicesToReplace();
+
+        if ($missingIndices !== [] || $toReplaceIndices !== []) {
+            $schema = new SchemaWrapper($this->connection);
+
+            foreach ($missingIndices as $missingIndex) {
+                if ($schema->hasTable($missingIndex['tableName'])) {
+                    $table = $schema->getTable($missingIndex['tableName']);
+                    if (!$table->hasIndex($missingIndex['indexName'])) {
+                        $output->writeln('<info>Adding additional ' . $missingIndex['indexName'] . ' index to the ' . $table->getName() . ' table, this can take some time...</info>');
+
+                        if ($missingIndex['dropUnnamedIndex']) {
+                            foreach ($table->getIndexes() as $index) {
+                                $columns = $index->getColumns();
+                                if ($columns === $missingIndex['columns']) {
+                                    $table->dropIndex($index->getName());
+                                }
+                            }
+                        }
+
+                        if ($missingIndex['uniqueIndex']) {
+                            $table->addUniqueIndex($missingIndex['columns'], $missingIndex['indexName'], $missingIndex['options']);
+                        } else {
+                            $table->addIndex($missingIndex['columns'], $missingIndex['indexName'], [], $missingIndex['options']);
+                        }
+
+                        if (!$dryRun) {
+                            $this->connection->migrateToSchema($schema->getWrappedSchema());
+                        }
+                        $output->writeln('<info>' . $table->getName() . ' table updated successfully.</info>');
+                    }
+                }
+            }
+
+            foreach ($toReplaceIndices as $toReplaceIndex) {
+                if ($schema->hasTable($toReplaceIndex['tableName'])) {
+                    $table = $schema->getTable($toReplaceIndex['tableName']);
+
+                    if ($table->hasIndex($toReplaceIndex['newIndexName'])) {
+                        continue;
+                    }
+
+                    $output->writeln('<info>Adding additional ' . $toReplaceIndex['newIndexName'] . ' index to the ' . $table->getName() . ' table, this can take some time...</info>');
+
+                    if ($toReplaceIndex['uniqueIndex']) {
+                        $table->addUniqueIndex($toReplaceIndex['columns'], $toReplaceIndex['newIndexName'], $toReplaceIndex['options']);
+                    } else {
+                        $table->addIndex($toReplaceIndex['columns'], $toReplaceIndex['newIndexName'], [], $toReplaceIndex['options']);
+                    }
+
+                    if (!$dryRun) {
+                        $this->connection->migrateToSchema($schema->getWrappedSchema());
+                    }
+
+                    foreach ($toReplaceIndex['oldIndexNames'] as $oldIndexName) {
+                        if ($table->hasIndex($oldIndexName)) {
+                            $output->writeln('<info>Removing ' . $oldIndexName . ' index from the ' . $table->getName() . ' table</info>');
+                            $table->dropIndex($oldIndexName);
+                        }
+                    }
+
+                    if (!$dryRun) {
+                        $this->connection->migrateToSchema($schema->getWrappedSchema());
+                    }
+                    $output->writeln('<info>' . $table->getName() . ' table updated successfully.</info>');
+                }
+            }
+
+            if ($dryRun) {
+                $sqlQueries = $this->connection->migrateToSchema($schema->getWrappedSchema(), $dryRun);
+                if ($sqlQueries !== null) {
+                    $output->writeln($sqlQueries);
+                }
+            }
+        }
+
+        return 0;
+    }
 }

Spacing +5 added lines, -5 removed lines

@@ -57,7 +57,7 @@ 
 				if ($schema->hasTable($missingIndex['tableName'])) {
 					$table = $schema->getTable($missingIndex['tableName']);
 					if (!$table->hasIndex($missingIndex['indexName'])) {
-						$output->writeln('<info>Adding additional ' . $missingIndex['indexName'] . ' index to the ' . $table->getName() . ' table, this can take some time...</info>');
+						$output->writeln('<info>Adding additional '.$missingIndex['indexName'].' index to the '.$table->getName().' table, this can take some time...</info>');
 
 						if ($missingIndex['dropUnnamedIndex']) {
 							foreach ($table->getIndexes() as $index) {
@@ -77,7 +77,7 @@ 
 						if (!$dryRun) {
 							$this->connection->migrateToSchema($schema->getWrappedSchema());
 						}
-						$output->writeln('<info>' . $table->getName() . ' table updated successfully.</info>');
+						$output->writeln('<info>'.$table->getName().' table updated successfully.</info>');
 					}
 				}
 			}
@@ -90,7 +90,7 @@ 
 						continue;
 					}
 
-					$output->writeln('<info>Adding additional ' . $toReplaceIndex['newIndexName'] . ' index to the ' . $table->getName() . ' table, this can take some time...</info>');
+					$output->writeln('<info>Adding additional '.$toReplaceIndex['newIndexName'].' index to the '.$table->getName().' table, this can take some time...</info>');
 
 					if ($toReplaceIndex['uniqueIndex']) {
 						$table->addUniqueIndex($toReplaceIndex['columns'], $toReplaceIndex['newIndexName'], $toReplaceIndex['options']);
@@ -104,7 +104,7 @@ 
 
 					foreach ($toReplaceIndex['oldIndexNames'] as $oldIndexName) {
 						if ($table->hasIndex($oldIndexName)) {
-							$output->writeln('<info>Removing ' . $oldIndexName . ' index from the ' . $table->getName() . ' table</info>');
+							$output->writeln('<info>Removing '.$oldIndexName.' index from the '.$table->getName().' table</info>');
 							$table->dropIndex($oldIndexName);
 						}
 					}
@@ -112,7 +112,7 @@ 
 					if (!$dryRun) {
 						$this->connection->migrateToSchema($schema->getWrappedSchema());
 					}
-					$output->writeln('<info>' . $table->getName() . ' table updated successfully.</info>');
+					$output->writeln('<info>'.$table->getName().' table updated successfully.</info>');
 				}
 			}