gggeek / db-3v4l

app/src/Command/DatabaseDrop.php

Spacing +2 added lines, -2 removed lines

@@ -56,7 +56,7 @@ 
         }
 
         $dbToDropSpecs = [];
-        foreach($instanceList as $instanceName => $instanceSpecs) {
+        foreach ($instanceList as $instanceName => $instanceSpecs) {
             $dbToDropSpecs[$instanceName] = [
                 'dbname' => $dbName
             ];
@@ -74,6 +74,6 @@ 
 
         $this->writeResults($results, $time);
 
-        return (int)$results['failed'];
+        return (int) $results['failed'];
     }
 }

app/src/Command/DatabaseCreate.php

Spacing +2 added lines, -2 removed lines

@@ -74,7 +74,7 @@ 
         }
 
         $newDbSpecs = [];
-        foreach($instanceList as $instanceName => $instanceSpecs) {
+        foreach ($instanceList as $instanceName => $instanceSpecs) {
             $newDbSpecs[$instanceName] = [
                 'dbname' => $dbName
             ];
@@ -93,6 +93,6 @@ 
 
         $this->writeResults($results, $time);
 
-        return (int)$results['failed'];
+        return (int) $results['failed'];
     }
 }

app/src/Command/UserList.php

Spacing +2 added lines, -2 removed lines

@@ -47,7 +47,7 @@ 
 
         $this->writeResults($results, $time);
 
-        return (int)$results['failed'];
+        return (int) $results['failed'];
     }
 
     /**
@@ -60,7 +60,7 @@ 
         return $this->executeSqlAction(
             $instanceList,
             'Listing of users',
-            function ($schemaManager, $instanceName) {
+            function($schemaManager, $instanceName) {
                 /** @var DatabaseSchemaManager $schemaManager */
                 return $schemaManager->getListUsersSqlAction();
             }

app/src/Command/SqlExecute.php

Spacing +12 added lines, -12 removed lines

@@ -81,13 +81,13 @@ 
 
             /// @todo inject more randomness in the username, by allowing more chars than bin2hex produces
 
-            $userName = 'db3v4l_' . substr(bin2hex(random_bytes(5)), 0, 9); // some mysql versions have a limitation of 16 chars for usernames
+            $userName = 'db3v4l_'.substr(bin2hex(random_bytes(5)), 0, 9); // some mysql versions have a limitation of 16 chars for usernames
             $password = bin2hex(random_bytes(16));
             //$dbName = bin2hex(random_bytes(31));
             $dbName = $userName; // $userName will be used as db name
 
             $tempDbSpecs = [];
-            foreach($instanceList as $instanceName => $instanceSpecs) {
+            foreach ($instanceList as $instanceName => $instanceSpecs) {
                 $tempDbSpecs[$instanceName] = [
                     'dbname' => $dbName,
                     'user' => $userName,
@@ -96,7 +96,7 @@ 
             }
 
             if (($charset = $input->getOption('charset')) != '') {
-                foreach($instanceList as $instanceName) {
+                foreach ($instanceList as $instanceName) {
                     $tempDbSpecs[$instanceName]['charset'] = $charset;
                 }
             }
@@ -118,7 +118,7 @@ 
             ];
 
             $dbConnectionSpecs = [];
-            foreach($instanceList as $instanceName => $instanceSpecs) {
+            foreach ($instanceList as $instanceName => $instanceSpecs) {
                 $dbConnectionSpecs[$instanceName] = array_merge($instanceSpecs, $dbConfig);
             }
         }
@@ -133,7 +133,7 @@ 
             if ($createDB) {
                 $results['failed'] += $creationResults['failed'];
 
-                foreach($instanceList as $instanceName  => $instanceSpecs) {
+                foreach ($instanceList as $instanceName  => $instanceSpecs) {
                     if (!isset($dbConnectionSpecs[$instanceName])) {
                         unset($instanceList[$instanceName]);
                     }
@@ -141,14 +141,14 @@ 
                 $this->dropDatabases($instanceList, $dbConnectionSpecs, true);
             }
         } else {
-            $results = ['succeeded' => 0,  'failed' => 0, 'data' => null];
+            $results = ['succeeded' => 0, 'failed' => 0, 'data' => null];
         }
 
         $time = microtime(true) - $start;
 
         $this->writeResults($results, $time);
 
-        return (int)$results['failed'];
+        return (int) $results['failed'];
     }
 
     /**
@@ -166,11 +166,11 @@ 
         return $this->executeSqlAction(
             $dbConnectionSpecs,
             'Execution of SQL',
-            function ($schemaManager, $instanceName) use ($sql, $filename) {
+            function($schemaManager, $instanceName) use ($sql, $filename) {
                 if ($sql != null) {
                     return new Command(
                         $sql,
-                        function ($output, $executor) {
+                        function($output, $executor) {
                             /** @var TimedExecutor $executor */
                             return array_merge(['stdout' => $output], $executor->getTimingData());
                         }
@@ -183,7 +183,7 @@ 
                     }
                     return new File(
                         $realFileName,
-                        function ($output, $executor) {
+                        function($output, $executor) {
                             /** @var TimedExecutor $executor */
                             return array_merge(['stdout' => $output], $executor->getTimingData());
                         }
@@ -218,13 +218,13 @@ 
             if (trim($line) !== '') {
                 if ($type === 'err') {
                     $this->writeErrorln(
-                        '[' . $processIndex . '][' . $pid . '] ' . trim($line),
+                        '['.$processIndex.']['.$pid.'] '.trim($line),
                         OutputInterface::VERBOSITY_VERBOSE,
                         OutputInterface::OUTPUT_RAW
                     );
                 } else {
                     $this->writeln(
-                        '[' . $processIndex . '][' . $pid . '] ' . trim($line),
+                        '['.$processIndex.']['.$pid.'] '.trim($line),
                         OutputInterface::VERBOSITY_VERBOSE,
                         OutputInterface::OUTPUT_RAW
                     );

app/src/Command/SQLExecutingCommand.php

Spacing +10 added lines, -10 removed lines

@@ -67,7 +67,7 @@ 
         // On Debian, which we use by default, SF has troubles understanding that php was compiled with --enable-sigchild
         // We thus force it, but give end users an option to disable this
         // For more details, see comment 12 at https://bugs.launchpad.net/ubuntu/+source/php5/+bug/516061
-        if (! $input->getOption('dont-force-enabled-sigchild')) {
+        if (!$input->getOption('dont-force-enabled-sigchild')) {
             Process::forceSigchildEnabled(true);
         }
 
@@ -111,7 +111,7 @@ 
                     $sql = null;
                 } else {
                     // this is a coding error, not a sql execution error
-                    throw new \Exception("Unsupported action type: " . get_class($sqlAction));
+                    throw new \Exception("Unsupported action type: ".get_class($sqlAction));
                 }
                 $filterCallable = $sqlAction->getResultsFilterCallable();
 
@@ -126,7 +126,7 @@ 
 
                     if ($filename === null) {
                         if (!$sqlAction->isSingleStatement()) {
-                            $tempSQLFileName = tempnam(sys_get_temp_dir(), 'db3v4l_') . '.sql';
+                            $tempSQLFileName = tempnam(sys_get_temp_dir(), 'db3v4l_').'.sql';
                             file_put_contents($tempSQLFileName, $sql);
                             $tempSQLFileNames[] = $tempSQLFileName;
 
@@ -139,7 +139,7 @@ 
                     }
 
                     if ($this->outputFormat === 'text') {
-                        $this->writeln('Command line: ' . $process->getCommandLine(), OutputInterface::VERBOSITY_VERY_VERBOSE);
+                        $this->writeln('Command line: '.$process->getCommandLine(), OutputInterface::VERBOSITY_VERY_VERBOSE);
                     }
 
                     $process->setTimeout($this->processTimeout);
@@ -158,7 +158,7 @@ 
                     $succeeded++;
                 } catch (\Throwable $t) {
                     $failed++;
-                    $this->writeErrorln("\n<error>$actionName in instance '$instanceName' failed! Reason: " . $t->getMessage() . "</error>\n", OutputInterface::VERBOSITY_NORMAL);
+                    $this->writeErrorln("\n<error>$actionName in instance '$instanceName' failed! Reason: ".$t->getMessage()."</error>\n", OutputInterface::VERBOSITY_NORMAL);
                 }
             }
 
@@ -180,7 +180,7 @@ 
                                 //$result = null;
                                 $failed++;
                                 $succeeded--;
-                                $this->writeErrorln("\n<error>$actionName in instance '$instanceName' failed! Reason: " . $t->getMessage() . "</error>\n", OutputInterface::VERBOSITY_NORMAL);
+                                $this->writeErrorln("\n<error>$actionName in instance '$instanceName' failed! Reason: ".$t->getMessage()."</error>\n", OutputInterface::VERBOSITY_NORMAL);
                             }
                         }
                         $results[$instanceName] = $output;
@@ -191,14 +191,14 @@ 
                             'exitcode' => $process->getExitCode()
                         ];
                         $failed++;
-                        $this->writeErrorln("\n<error>$actionName in instance '$instanceName' failed! Reason: " . $process->getErrorOutput() . "</error>\n", OutputInterface::VERBOSITY_NORMAL);
+                        $this->writeErrorln("\n<error>$actionName in instance '$instanceName' failed! Reason: ".$process->getErrorOutput()."</error>\n", OutputInterface::VERBOSITY_NORMAL);
                     }
                 }
             }
 
         } finally {
             // make sure that we clean up temp files, as they might contain sensitive data
-            foreach($tempSQLFileNames as $tempSQLFileName) {
+            foreach ($tempSQLFileNames as $tempSQLFileName) {
                 unlink($tempSQLFileName);
             }
         }
@@ -243,10 +243,10 @@ 
      */
     protected function writeResults(array $results, $time = null)
     {
-        $this->writeln($this->formatResults($results), OutputInterface::VERBOSITY_QUIET,  OutputInterface::OUTPUT_RAW);
+        $this->writeln($this->formatResults($results), OutputInterface::VERBOSITY_QUIET, OutputInterface::OUTPUT_RAW);
 
         if ($this->outputFormat === 'text') {
-            $this->writeln($results['succeeded'] . ' succeeded, ' . $results['failed'] . ' failed');
+            $this->writeln($results['succeeded'].' succeeded, '.$results['failed'].' failed');
 
             if ($time !== null) {
                 $this->writeln("<info>Time taken: ".sprintf('%.2f', $time)." secs</info>");

app/src/Command/CollationList.php

Spacing +2 added lines, -2 removed lines

@@ -47,7 +47,7 @@ 
 
         $this->writeResults($results, $time);
 
-        return (int)$results['failed'];
+        return (int) $results['failed'];
     }
 
     /**
@@ -60,7 +60,7 @@ 
         return $this->executeSqlAction(
             $instanceList,
             'Listing of collations',
-            function ($schemaManager, $instanceName) {
+            function($schemaManager, $instanceName) {
                 /** @var DatabaseSchemaManager $schemaManager */
                 return $schemaManager->getListCollationsSqlAction();
             }

app/src/Command/DatabaseShell.php

Spacing +1 added lines, -1 removed lines

@@ -47,7 +47,7 @@
         $dbConnectionSpec = $this->dbConfigurationManager->getInstanceConfiguration($instanceName);
         $executor = $this->executorFactory->createForkedExecutor($dbConnectionSpec, 'NativeClient', false);
 
-        if (! $executor instanceof ShellExecutor) {
+        if (!$executor instanceof ShellExecutor) {
             throw new \Exception("Can not start an interactive shell for databases of type '{$dbConnectionSpec['vendor']}'");
         }
 

app/src/Command/DatabaseList.php

Spacing +2 added lines, -2 removed lines

@@ -47,7 +47,7 @@ 
 
         $this->writeResults($results, $time);
 
-        return (int)$results['failed'];
+        return (int) $results['failed'];
     }
 
     /**
@@ -60,7 +60,7 @@ 
         return $this->executeSqlAction(
             $instanceList,
             'Listing of databases',
-            function ($schemaManager, $instanceName) {
+            function($schemaManager, $instanceName) {
                 /** @var DatabaseSchemaManager $schemaManager */
                 return $schemaManager->getListDatabasesSqlAction();
             }

app/src/Command/UserDrop.php

Spacing +3 added lines, -3 removed lines

@@ -50,7 +50,7 @@ 
         }
 
         $userToDropSpecs = [];
-        foreach($instanceList as $instanceName => $instanceSpecs) {
+        foreach ($instanceList as $instanceName => $instanceSpecs) {
             $userToDropSpecs[$instanceName] = [
                 'user' => $userName
             ];
@@ -64,7 +64,7 @@ 
 
         $this->writeResults($results, $time);
 
-        return (int)$results['failed'];
+        return (int) $results['failed'];
     }
 
     /**
@@ -79,7 +79,7 @@ 
         return $this->executeSqlAction(
             $instanceList,
             'Dropping of user',
-            function ($schemaManager, $instanceName) use ($userToDropSpecs, $ifExists) {
+            function($schemaManager, $instanceName) use ($userToDropSpecs, $ifExists) {
                 $dbConnectionSpec = $userToDropSpecs[$instanceName];
                 /** @var DatabaseSchemaManager $schemaManager */
                 return $schemaManager->getDropUserSqlAction(