gggeek / db-3v4l

app/src/Core/SqlExecutor/Forked/ForkedExecutor.php

Spacing +1 added lines, -1 removed lines

@@ -12,7 +12,7 @@
     public function buildCommandLine($command, array $arguments = array())
     {
         $arguments = array_map('escapeshellarg', $arguments);
-        return escapeshellcmd($command) . ' ' . implode(' ', $arguments);
+        return escapeshellcmd($command).' '.implode(' ', $arguments);
 
         return new Process($commandLine, null, $env);
     }

app/src/Core/SqlExecutor/Forked/PDO.php

Spacing +7 added lines, -7 removed lines

@@ -50,18 +50,18 @@ 
         $options = [
             'bin/dbconsole',
             'sql:execute',
-            '--only-instances=' . $this->instanceName,
+            '--only-instances='.$this->instanceName,
             '--execute-in-process',
-            '--execution-strategy=' . static::EXECUTION_STRATEGY,
+            '--execution-strategy='.static::EXECUTION_STRATEGY,
             '--output-type=json',
         ];
 
         switch ($action) {
             case self::EXECUTE_COMMAND:
-                $options[] = '--sql=' . $sqlOrFilename;
+                $options[] = '--sql='.$sqlOrFilename;
                 break;
             case self::EXECUTE_FILE:
-                $options[] = '--file=' . $sqlOrFilename;
+                $options[] = '--file='.$sqlOrFilename;
                 break;
             default:
                 throw new \OutOfBoundsException('Unsupported action: $action');
@@ -72,13 +72,13 @@ 
         /// @todo add support for charset ?
         if ($instanceConfiguration != $this->databaseConfiguration) {
             if (isset($this->databaseConfiguration['dbname'])) {
-                $options[] = '--database=' . $this->databaseConfiguration['dbname'];
+                $options[] = '--database='.$this->databaseConfiguration['dbname'];
             }
             if (isset($this->databaseConfiguration['user'])) {
-                $options[] = '--user=' . $this->databaseConfiguration['user'];
+                $options[] = '--user='.$this->databaseConfiguration['user'];
             }
             if (isset($this->databaseConfiguration['password'])) {
-                $options[] = '--password=' . $this->databaseConfiguration['password'];
+                $options[] = '--password='.$this->databaseConfiguration['password'];
             }
         }
 

app/src/Command/SqlShell.php

Spacing +1 added lines, -1 removed lines

@@ -53,7 +53,7 @@
         }
         $executor = $this->executorFactory->createForkedExecutor($instanceName, $dbConnectionSpec, NativeClient::EXECUTION_STRATEGY, 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/SqlExecute.php

Spacing +12 added lines, -12 removed lines

@@ -82,13 +82,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,
@@ -97,7 +97,7 @@ 
             }
 
             if (($charset = $input->getOption('charset')) != '') {
-                foreach($instanceList as $instanceName) {
+                foreach ($instanceList as $instanceName) {
                     $tempDbSpecs[$instanceName]['charset'] = $charset;
                 }
             }
@@ -124,7 +124,7 @@ 
             ];
 
             $dbConnectionSpecs = [];
-            foreach($instanceList as $instanceName => $instanceSpecs) {
+            foreach ($instanceList as $instanceName => $instanceSpecs) {
                 $dbConnectionSpecs[$instanceName] = array_merge($instanceSpecs, $dbConfig);
             }
         }
@@ -139,7 +139,7 @@ 
             if ($createDB) {
                 $results['failed'] += $creationResults['failed'];
 
-                foreach($instanceList as $instanceName  => $instanceSpecs) {
+                foreach ($instanceList as $instanceName  => $instanceSpecs) {
                     if (!isset($dbConnectionSpecs[$instanceName])) {
                         unset($instanceList[$instanceName]);
                     }
@@ -151,14 +151,14 @@ 
                 $this->executionStrategy = $previousStrategy;
             }
         } 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'];
     }
 
     /**
@@ -176,11 +176,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());
                         }
@@ -193,7 +193,7 @@ 
                     }
                     return new File(
                         $realFileName,
-                        function ($output, $executor) {
+                        function($output, $executor) {
                             /** @var TimedExecutor $executor */
                             return array_merge(['stdout' => $output], $executor->getTimingData());
                         }
@@ -228,13 +228,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
                     );