dazzle-php / mysql

src/MySQL/Command/Concrete/QueryCommand.php

Spacing +1 added lines, -1 removed lines

@@ -24,7 +24,7 @@
 
     public function setQuery($query)
     {
-        if (! $query instanceof Query)
+        if (!$query instanceof Query)
         {
             $query = new Query($query);
         }

src/MySQL/Query.php

Spacing +2 added lines, -2 removed lines

@@ -50,7 +50,7 @@ 
     public function bindParams()
     {
         $this->sqlPrepared = null;
-        $this->params   = func_get_args();
+        $this->params = func_get_args();
 
         return $this;
     }
@@ -58,7 +58,7 @@ 
     public function bindParamsFromArray(array $params)
     {
         $this->sqlPrepared = null;
-        $this->params   = $params;
+        $this->params = $params;
 
         return $this;
     }

src/MySQL/Protocol/ProtocolParser.php

Spacing +5 added lines, -5 removed lines

@@ -94,8 +94,8 @@ 
 
     public function start()
     {
-        $this->stream->on('data', [ $this, 'handleData' ]);
-        $this->stream->on('close', [ $this, 'handleClose' ]);
+        $this->stream->on('data', [$this, 'handleData']);
+        $this->stream->on('close', [$this, 'handleClose']);
     }
 
     public function handleNewCommand()
@@ -256,7 +256,7 @@ 
                 }
                 else
                 {
-                    ++ $this->rsState;
+                    ++$this->rsState;
                 }
             }
             //Data packet
@@ -409,13 +409,13 @@ 
 
     public function restBuffer($len)
     {
-        if(strlen($this->buffer) === ($this->bufferPos+$len))
+        if (strlen($this->buffer) === ($this->bufferPos + $len))
         {
             $this->buffer = '';
         }
         else
         {
-            $this->buffer = substr($this->buffer,$this->bufferPos+$len);
+            $this->buffer = substr($this->buffer, $this->bufferPos + $len);
         }
         $this->bufferPos = 0;
     }

src/MySQL/Database.php

Spacing +15 added lines, -15 removed lines

@@ -105,12 +105,12 @@ 
             $options = $this->config;
             $streamRef = $this->stream;
 
-            $errorHandler = function ($reason) use ($reject) {
+            $errorHandler = function($reason) use ($reject) {
                 $this->state = self::STATE_AUTH_FAILED;
                 return $reject($reason);
             };
 
-            $connectedHandler = function ($serverOptions) use ($resolve) {
+            $connectedHandler = function($serverOptions) use ($resolve) {
                 $this->state = self::STATE_AUTH_SUCCEEDED;
                 $this->serverOptions = $serverOptions;
                 return $resolve($serverOptions);
@@ -118,11 +118,11 @@ 
 
             $this
                 ->connect()
-                ->then(function ($stream) use (&$streamRef, $options, $errorHandler, $connectedHandler) {
+                ->then(function($stream) use (&$streamRef, $options, $errorHandler, $connectedHandler) {
                     $streamRef = $stream;
 
-                    $stream->on('error', [ $this, 'handleConnectionError' ]);
-                    $stream->on('close', [ $this, 'handleConnectionClosed' ]);
+                    $stream->on('error', [$this, 'handleConnectionError']);
+                    $stream->on('close', [$this, 'handleConnectionClosed']);
 
                     $parser = $this->parser = new ProtocolParser($stream, $this->executor);
 
@@ -135,7 +135,7 @@ 
                     //$parser->on('close', $closeHandler);
                     $parser->start();
 
-                }, [ $this, 'handleConnectionError' ]);
+                }, [$this, 'handleConnectionError']);
         });
     }
 
@@ -150,8 +150,8 @@ 
                 ->doCommand(new QuitCommand($this))
                 ->on('success', function() use($resolve) {
                     $this->state = self::STATE_STOPPED;
-                    $this->emit('end', [ $this ]);
-                    $this->emit('close', [ $this ]);
+                    $this->emit('end', [$this]);
+                    $this->emit('close', [$this]);
                     $resolve($this);
                 });
             $this->state = self::STATE_CLOSEING;
@@ -175,15 +175,15 @@ 
         $query->bindParamsFromArray($sqlParams);
         $this->doCommand($command);
 
-        $command->on('results', function ($rows, $command) use ($promise) {
+        $command->on('results', function($rows, $command) use ($promise) {
             return $command->hasError()
                 ? $promise->reject($command->getError())
                 : $promise->resolve($command);
         });
-        $command->on('error', function ($err, $command) use ($promise) {
+        $command->on('error', function($err, $command) use ($promise) {
             return $promise->reject($err);
         });
-        $command->on('success', function ($command) use ($promise) {
+        $command->on('success', function($command) use ($promise) {
             return $command->hasError()
                 ? $promise->reject($command->getError())
                 : $promise->resolve($command);
@@ -197,10 +197,10 @@ 
         $promise = new Promise();
 
         $this->doCommand(new PingCommand($this))
-            ->on('error', function ($reason) use ($promise) {
+            ->on('error', function($reason) use ($promise) {
                 return $promise->reject($reason);
             })
-            ->on('success', function () use ($promise) {
+            ->on('success', function() use ($promise) {
                 return $promise->resolve();
             });
     }
@@ -234,7 +234,7 @@ 
 
     public function handleConnectionError($err)
     {
-        $this->emit('error', [ $err, $this ]);
+        $this->emit('error', [$err, $this]);
     }
 
     public function handleConnectionClosed()
@@ -242,7 +242,7 @@ 
         if ($this->state < self::STATE_CLOSEING)
         {
             $this->state = self::STATE_STOPPED;
-            $this->emit('error', [ new RuntimeException('mysql server has gone away'), $this ]);
+            $this->emit('error', [new RuntimeException('mysql server has gone away'), $this]);
         }
     }