dazzle-php / mysql

src/MySQL/Protocol/ProtocolParser.php

Doc Comments +25 added lines

@@ -84,6 +84,9 @@ 
 
     protected $queue;
 
+    /**
+     * @param \Dazzle\MySQL\Executor $executor
+     */
     public function __construct($stream, $executor)
     {
         $this->stream   = $stream;
@@ -105,6 +108,9 @@ 
         }
     }
 
+    /**
+     * @param string $message
+     */
     public function debug($message)
     {
         if ($this->debug) {
@@ -343,6 +349,9 @@ 
         $this->buffer .= $str;
     }
 
+    /**
+     * @param string $str
+     */
     public function prepend($str)
     {
         $this->buffer = $str . substr($this->buffer, $this->bufferPos);
@@ -363,11 +372,17 @@ 
         return $buffer;
     }
 
+    /**
+     * @param integer $len
+     */
     public function skip($len)
     {
         $this->bufferPos += $len;
     }
 
+    /**
+     * @param double $len
+     */
     public function restBuffer($len)
     {
         if(strlen($this->buffer) === ($this->bufferPos+$len)){
@@ -383,6 +398,9 @@ 
         return strlen($this->buffer) - $this->bufferPos;
     }
 
+    /**
+     * @param string $what
+     */
     public function search($what)
     {
         if (($p = strpos($this->buffer, $what, $this->bufferPos)) !== false) {
@@ -421,6 +439,9 @@ 
         $this->debug('Auth packet sent');
     }
 
+    /**
+     * @param string $scramble
+     */
     public function getAuthToken($scramble, $password = '')
     {
         if ($password === '') {
@@ -434,6 +455,7 @@ 
     /**
      * Builds length-encoded BinarySupport string
      * @param string String
+     * @param string $s
      * @return string Resulting BinarySupport string
      */
     public function buildLenEncodedBinarySupport($s)
@@ -499,6 +521,9 @@ 
         return $this->read($l);
     }
 
+    /**
+     * @param string $packet
+     */
     public function sendPacket($packet)
     {
         return $this->stream->write(BinarySupport::int2bytes(3, strlen($packet), true) . chr($this->seq++) . $packet);

Spacing +6 added lines, -6 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()
@@ -230,7 +230,7 @@ 
                     $this->nextRequest();
                     $this->onResultDone();
                 } else {
-                    ++ $this->rsState;
+                    ++$this->rsState;
                 }
 
             } else { //Data packet
@@ -370,10 +370,10 @@ 
 
     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);
+        } else {
+            $this->buffer = substr($this->buffer, $this->bufferPos + $len);
         }
         $this->bufferPos = 0;
     }

src/MySQL/Protocol/Support/BinarySupport.php

Doc Comments +1 added lines

@@ -382,6 +382,7 @@
 
     /**
      * @see BinarySupport::int2bytes
+     * @param integer $bytes
      */
     public static function i2b($bytes, $int = 0, $l = false)
     {

src/MySQL/Query.php

Doc Comments -1 removed lines

@@ -44,7 +44,6 @@
     /**
      * Binding params for the query, mutiple arguments support.
      *
-     * @param  mixed              $param
      * @return Query
      */
     public function bindParams()

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/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/Database.php

Spacing +15 added lines, -15 removed lines

@@ -108,12 +108,12 @@ 
             throw new Exception('Not Implemented');
         }
 
-        $errorHandler = function ($reason) use ($args) {
+        $errorHandler = function($reason) use ($args) {
             $this->state = self::STATE_AUTH_FAILED;
             $args[0]($reason, $this);
         };
 
-        $connectedHandler = function ($serverOptions) use ($args) {
+        $connectedHandler = function($serverOptions) use ($args) {
             $this->state = self::STATE_AUTH_SUCCEEDED;
             $this->serverOptions = $serverOptions;
             $args[0](null, $this);
@@ -121,11 +121,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);
 
@@ -138,7 +138,7 @@ 
                 //$parser->on('close', $closeHandler);
                 $parser->start();
 
-            }, [ $this, 'handleConnectionError' ]);
+            }, [$this, 'handleConnectionError']);
     }
 
     /**
@@ -151,8 +151,8 @@ 
             ->doCommand(new QuitCommand($this))
             ->on('success', function() {
                 $this->state = self::STATE_STOPPED;
-                $this->emit('end', [ $this ]);
-                $this->emit('close', [ $this ]);
+                $this->emit('end', [$this]);
+                $this->emit('close', [$this]);
             });
         $this->state = self::STATE_CLOSEING;
     }
@@ -191,13 +191,13 @@ 
         $query->bindParamsFromArray($args);
         $this->doCommand($command);
 
-        $command->on('results', function ($rows, $command) use ($callback) {
+        $command->on('results', function($rows, $command) use ($callback) {
             $callback($command, $this);
         });
-        $command->on('error', function ($err, $command) use ($callback) {
+        $command->on('error', function($err, $command) use ($callback) {
             $callback($command, $this);
         });
-        $command->on('success', function ($command) use ($callback) {
+        $command->on('success', function($command) use ($callback) {
             $callback($command, $this);
         });
     }
@@ -209,10 +209,10 @@ 
             throw new InvalidArgumentException('Callback is not a valid callable');
         }
         $this->doCommand(new PingCommand($this))
-            ->on('error', function ($reason) use ($callback) {
+            ->on('error', function($reason) use ($callback) {
                 $callback($reason, $this);
             })
-            ->on('success', function () use ($callback) {
+            ->on('success', function() use ($callback) {
                 $callback(null, $this);
             });
     }
@@ -246,7 +246,7 @@ 
 
     public function handleConnectionError($err)
     {
-        $this->emit('error', [ $err, $this ]);
+        $this->emit('error', [$err, $this]);
     }
 
     public function handleConnectionClosed()
@@ -254,7 +254,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]);
         }
     }