FoolCode / SphinxQL-Query-Builder

src/Drivers/Pdo/ResultSet.php

Doc Comments +1 added lines, -1 removed lines

@@ -197,7 +197,7 @@
     /**
      * Get the result object returned by PHP's MySQLi
      *
-     * @return \Pdostatement
+     * @return \mysqli_result
      *
      * @codeCoverageIgnore
      */

src/Drivers/ConnectionBase.php

Braces +1 added lines, -1 removed lines

@@ -142,7 +142,7 @@
         } elseif (is_float($value)) {
             // Convert to non-locale aware float to prevent possible commas
             return sprintf('%F', $value);
-        }  elseif (is_array($value)) {
+        } elseif (is_array($value)) {
             // Supports MVA attributes
             return '('.implode(',', $this->quoteArr($value)).')';
         }

src/Drivers/MultiResultSetBase.php

Spacing +1 added lines, -1 removed lines

@@ -110,7 +110,7 @@
      */
     public function key()
     {
-        return (int)$this->cursor;
+        return (int) $this->cursor;
     }
 
     /**

src/Drivers/Pdo/Connection.php

Spacing +13 added lines, -13 removed lines

@@ -47,11 +47,11 @@ 
 
         $stm = $this->connection->prepare($query);
 
-        try{
+        try {
             $stm->execute();
         }
-        catch(\PDOException $exception){
-            throw new DatabaseException($exception->getMessage() . ' [' . $query . ']');
+        catch (\PDOException $exception) {
+            throw new DatabaseException($exception->getMessage().' ['.$query.']');
         }
 
         return new ResultSet($stm);
@@ -67,20 +67,20 @@ 
 
         $dsn = 'mysql:';
         if (isset($params['host']) && $params['host'] != '') {
-            $dsn .= 'host=' . $params['host'] . ';';
+            $dsn .= 'host='.$params['host'].';';
         }
         if (isset($params['port'])) {
-            $dsn .= 'port=' . $params['port'] . ';';
+            $dsn .= 'port='.$params['port'].';';
         }
         if (isset($params['charset'])) {
-            $dsn .= 'charset=' . $params['charset'] . ';';
+            $dsn .= 'charset='.$params['charset'].';';
         }
 
         if (isset($params['socket']) && $params['socket'] != '') {
-            $dsn .= 'unix_socket=' . $params['socket'] . ';';
+            $dsn .= 'unix_socket='.$params['socket'].';';
         }
 
-        if (!$suppress_error && ! $this->silence_connection_warning) {
+        if (!$suppress_error && !$this->silence_connection_warning) {
             try {
                 $con = new \Pdo($dsn);
             } catch (\PDOException $exception) {
@@ -93,7 +93,7 @@ 
                 throw new ConnectionException($exception->getMessage());
             }
         }
-        if(!isset($con))
+        if (!isset($con))
         {
             throw new ConnectionException('connection error');
         }
@@ -131,24 +131,24 @@ 
         $result = array();
         $count = 0;
 
-        if(version_compare(PHP_VERSION, '5.4.0', '>='))
+        if (version_compare(PHP_VERSION, '5.4.0', '>='))
         {
             try {
                 $statement = $this->connection->query(implode(';', $queue));
             } catch (\PDOException $exception) {
-                throw new DatabaseException($exception->getMessage() .' [ '.implode(';', $queue).']');
+                throw new DatabaseException($exception->getMessage().' [ '.implode(';', $queue).']');
             }
 
             return new MultiResultSet($statement);
         }
         else
         {
-            foreach($queue as $sql)
+            foreach ($queue as $sql)
             {
                 try {
                     $statement = $this->connection->query($sql);
                 } catch (\PDOException $exception) {
-                    throw new DatabaseException($exception->getMessage() .' [ '.implode(';', $queue).']');
+                    throw new DatabaseException($exception->getMessage().' [ '.implode(';', $queue).']');
                 }
                 if ($statement->columnCount()) {
                     $set = new ResultSet($statement);

Braces +2 added lines, -4 removed lines

@@ -49,8 +49,7 @@ 
 
         try{
             $stm->execute();
-        }
-        catch(\PDOException $exception){
+        } catch(\PDOException $exception){
             throw new DatabaseException($exception->getMessage() . ' [' . $query . ']');
         }
 
@@ -140,8 +139,7 @@ 
             }
 
             return new MultiResultSet($statement);
-        }
-        else
+        } else
         {
             foreach($queue as $sql)
             {

Doc Comments +2 added lines, -2 removed lines

@@ -39,7 +39,7 @@ 
      * @param string $query The query string
      *
      * @throws DatabaseException
-     * @return array|int The result array or number of rows affected
+     * @return ResultSet The result array or number of rows affected
      */
     public function query($query)
     {
@@ -116,7 +116,7 @@ 
 
     /**
      * @param array $queue
-     * @return array
+     * @return MultiResultSet
      * @throws DatabaseException
      * @throws SphinxQLException
      */

src/Drivers/Mysqli/Connection.php

Spacing +1 added lines, -1 removed lines

@@ -63,7 +63,7 @@
             }
         }
 
-        if (!$suppress_error && ! $this->silence_connection_warning) {
+        if (!$suppress_error && !$this->silence_connection_warning) {
             $conn->real_connect($data['host'], null, null, null, (int) $data['port'], $data['socket']);
         } else {
             @ $conn->real_connect($data['host'], null, null, null, (int) $data['port'], $data['socket']);

src/Drivers/ResultSetBase.php

Spacing +2 added lines, -2 removed lines

@@ -37,7 +37,7 @@ 
     public function hasNextRow()
     {
         return $this->current_row === null
-            ? (boolean)$this->num_rows
+            ? (boolean) $this->num_rows
             : $this->current_row + 1 < $this->num_rows;
     }
 
@@ -163,7 +163,7 @@ 
      */
     public function key()
     {
-        return (int)$this->current_row;
+        return (int) $this->current_row;
     }
 
     /**

src/SphinxQL.php

Spacing +1 added lines, -1 removed lines

@@ -623,7 +623,7 @@
                 } elseif (is_array($option['value'])) {
                     array_walk(
                         $option['value'],
-                        function (&$val, $key) {
+                        function(&$val, $key) {
                             $val = $key.'='.$val;
                         }
                     );

src/Helper.php

Spacing +2 added lines, -2 removed lines

@@ -157,7 +157,7 @@ 
         }
 
         // user variables must always be processed as arrays
-        if ($user_var && ! is_array($value)) {
+        if ($user_var && !is_array($value)) {
             $query .= '= ('.$this->getConnection()->quote($value).')';
         } elseif (is_array($value)) {
             $query .= '= ('.implode(', ', $this->getConnection()->quoteArr($value)).')';
@@ -261,7 +261,7 @@ 
     public function attachIndex($disk_index, $rt_index)
     {
         return $this->query('ATTACH INDEX '.$this->getConnection()->quoteIdentifier($disk_index).
-            ' TO RTINDEX '. $this->getConnection()->quoteIdentifier($rt_index));
+            ' TO RTINDEX '.$this->getConnection()->quoteIdentifier($rt_index));
     }
 
     /**

src/Drivers/SimpleConnection.php

Spacing +1 added lines, -1 removed lines

@@ -63,7 +63,7 @@
             }
         }
 
-        if (!$suppress_error && ! $this->silence_connection_warning) {
+        if (!$suppress_error && !$this->silence_connection_warning) {
             $conn->real_connect($data['host'], null, null, null, (int) $data['port'], $data['socket']);
         } else {
             @ $conn->real_connect($data['host'], null, null, null, (int) $data['port'], $data['socket']);