gin0115 / pixie-wpdb

src/QueryBuilder/WPDBAdapter.php

Spacing +43 added lines, -43 removed lines

@@ -49,9 +49,9 @@ 
      */
     public function select(array $statements): array
     {
-        if (!array_key_exists('tables', $statements)) {
+        if ( ! array_key_exists('tables', $statements)) {
             throw new Exception('No table specified.', 3);
-        } elseif (!array_key_exists('selects', $statements)) {
+        } elseif ( ! array_key_exists('selects', $statements)) {
             $statements['selects'][] = '*';
         }
 
@@ -66,7 +66,7 @@ 
         // Group bys
         $groupBys = '';
         if (isset($statements['groupBys']) && $groupBys = $this->arrayStr($statements['groupBys'], ', ')) {
-            $groupBys = 'GROUP BY ' . $groupBys;
+            $groupBys = 'GROUP BY '.$groupBys;
         }
 
         // Order bys
@@ -77,17 +77,17 @@ 
                 if ($field instanceof Closure) {
                     continue;
                 }
-                $orderBys .= $field . ' ' . $orderBy['type'] . ', ';
+                $orderBys .= $field.' '.$orderBy['type'].', ';
             }
 
             if ($orderBys = trim($orderBys, ', ')) {
-                $orderBys = 'ORDER BY ' . $orderBys;
+                $orderBys = 'ORDER BY '.$orderBys;
             }
         }
 
         // Limit and offset
-        $limit  = isset($statements['limit']) ? 'LIMIT ' . (int) $statements['limit'] : '';
-        $offset = isset($statements['offset']) ? 'OFFSET ' . (int) $statements['offset'] : '';
+        $limit  = isset($statements['limit']) ? 'LIMIT '.(int) $statements['limit'] : '';
+        $offset = isset($statements['offset']) ? 'OFFSET '.(int) $statements['offset'] : '';
 
         // Having
         list($havingCriteria, $havingBindings) = $this->buildCriteriaWithType($statements, 'havings', 'HAVING');
@@ -97,7 +97,7 @@ 
 
         /** @var string[] */
         $sqlArray = [
-            'SELECT' . (isset($statements['distinct']) ? ' DISTINCT' : ''),
+            'SELECT'.(isset($statements['distinct']) ? ' DISTINCT' : ''),
             $selects,
             'FROM',
             $tables,
@@ -131,7 +131,7 @@ 
     public function criteriaOnly(array $statements, bool $bindValues = true): array
     {
         $sql = $bindings = [];
-        if (!isset($statements['criteria'])) {
+        if ( ! isset($statements['criteria'])) {
             return compact('sql', 'bindings');
         }
 
@@ -153,7 +153,7 @@ 
      */
     private function doInsert(array $statements, array $data, string $type): array
     {
-        if (!isset($statements['tables'])) {
+        if ( ! isset($statements['tables'])) {
             throw new Exception('No table specified', 3);
         }
 
@@ -174,20 +174,20 @@ 
             if ($value instanceof Raw) {
                 $values[] = $this->parseRaw($value);
             } elseif ($isBindings) {
-                $values[]   =  $value->getType();
+                $values[]   = $value->getType();
                 $bindings[] = $value->getValue();
             } else {
-                $values[]   =  $this->inferType($value);
+                $values[]   = $this->inferType($value);
                 $bindings[] = $value;
             }
         }
 
         $sqlArray = [
-        $type . ' INTO',
+        $type.' INTO',
         $this->wrapSanitizer($table),
-        '(' . $this->arrayStr($keys, ',') . ')',
+        '('.$this->arrayStr($keys, ',').')',
         'VALUES',
-        '(' . $this->arrayStr($values, ',') . ')',
+        '('.$this->arrayStr($values, ',').')',
         ];
 
         if (isset($statements['onduplicate'])) {
@@ -195,7 +195,7 @@ 
                 throw new Exception('No data given.', 4);
             }
             list($updateStatement, $updateBindings) = $this->getUpdateStatement($statements['onduplicate']);
-            $sqlArray[]                             = 'ON DUPLICATE KEY UPDATE ' . $updateStatement;
+            $sqlArray[]                             = 'ON DUPLICATE KEY UPDATE '.$updateStatement;
             $bindings                               = array_merge($bindings, $updateBindings);
         }
 
@@ -303,12 +303,12 @@ 
             }
 
             if ($value instanceof Raw) {
-                $statement .= $this->stringifyValue($this->wrapSanitizer($key)) . '=' . $value . ',';
+                $statement .= $this->stringifyValue($this->wrapSanitizer($key)).'='.$value.',';
             } elseif ($isBindings) {
-                $statement .= $this->stringifyValue($this->wrapSanitizer($key)) . sprintf('=%s,', $value->getType());
+                $statement .= $this->stringifyValue($this->wrapSanitizer($key)).sprintf('=%s,', $value->getType());
                 $bindings[] = $value->getValue();
             } else {
-                $statement .= $this->stringifyValue($this->wrapSanitizer($key)) . sprintf('=%s,', $this->inferType($value));
+                $statement .= $this->stringifyValue($this->wrapSanitizer($key)).sprintf('=%s,', $this->inferType($value));
                 $bindings[] = $value;
             }
         }
@@ -330,7 +330,7 @@ 
      */
     public function update($statements, array $data)
     {
-        if (!isset($statements['tables'])) {
+        if ( ! isset($statements['tables'])) {
             throw new Exception('No table specified', 3);
         } elseif (count($data) < 1) {
             throw new Exception('No data given.', 4);
@@ -345,12 +345,12 @@ 
         list($whereCriteria, $whereBindings) = $this->buildCriteriaWithType($statements, 'wheres', 'WHERE');
 
         // Limit
-        $limit = isset($statements['limit']) ? 'LIMIT ' . $statements['limit'] : '';
+        $limit = isset($statements['limit']) ? 'LIMIT '.$statements['limit'] : '';
 
         $sqlArray = [
             'UPDATE',
             $this->wrapSanitizer($table),
-            'SET ' . $updateStatement,
+            'SET '.$updateStatement,
             $whereCriteria,
             $limit,
         ];
@@ -373,7 +373,7 @@ 
      */
     public function delete($statements)
     {
-        if (!isset($statements['tables'])) {
+        if ( ! isset($statements['tables'])) {
             throw new Exception('No table specified', 3);
         }
 
@@ -388,7 +388,7 @@ 
         list($whereCriteria, $whereBindings) = $this->buildCriteriaWithType($statements, 'wheres', 'WHERE');
 
         // Limit
-        $limit = isset($statements['limit']) ? 'LIMIT ' . $statements['limit'] : '';
+        $limit = isset($statements['limit']) ? 'LIMIT '.$statements['limit'] : '';
 
         $sqlArray = ['DELETE FROM', $table, $whereCriteria];
         $sql      = $this->concatenateQuery($sqlArray);
@@ -410,11 +410,11 @@ 
     {
         $str = '';
         foreach ($pieces as $key => $piece) {
-            if (!is_int($key)) {
-                $piece = $key . ' AS ' . $piece;
+            if ( ! is_int($key)) {
+                $piece = $key.' AS '.$piece;
             }
 
-            $str .= $piece . $glue;
+            $str .= $piece.$glue;
         }
 
         return trim($str, $glue);
@@ -431,7 +431,7 @@ 
     {
         $str = '';
         foreach ($pieces as $piece) {
-            $str = trim($str) . ' ' . trim($piece);
+            $str = trim($str).' '.trim($piece);
         }
 
         return trim($str);
@@ -446,7 +446,7 @@ 
     public function getType($value): string
     {
         return $value instanceof Binding && $value->getType() !== null
-            ? $value->getType() : $this->inferType($value) ;
+            ? $value->getType() : $this->inferType($value);
     }
 
     /**
@@ -489,7 +489,7 @@ 
 
 
         $bindings = array_map([$this, 'getValue'], $bindings);
-        $query = $this->connection->getDbInstance()->prepare($query, $bindings) ;
+        $query = $this->connection->getDbInstance()->prepare($query, $bindings);
         return is_string($query) ? $query : '';
     }
 
@@ -530,10 +530,10 @@ 
                 // Merge the bindings we get from nestedCriteria object
                 $bindings = array_merge($bindings, $queryObject->getBindings());
                 // Append the sql we get from the nestedCriteria object
-                $criteria .= $statement['joiner'] . ' (' . $queryObject->getSql() . ') ';
+                $criteria .= $statement['joiner'].' ('.$queryObject->getSql().') ';
             } elseif (is_array($value)) {
                 // where_in or between like query
-                $criteria .= $statement['joiner'] . ' ' . $key . ' ' . $statement['operator'];
+                $criteria .= $statement['joiner'].' '.$key.' '.$statement['operator'];
 
                 switch ($statement['operator']) {
                     case 'BETWEEN':
@@ -549,7 +549,7 @@ 
                         $value[1] = $this->getValue($value[1]);
 
                         // Parse any raws.
-                        $value = array_map(function ($value) {
+                        $value = array_map(function($value) {
                             return $value instanceof Raw
                                 ? $this->parseRaw($value)
                                 : $value;
@@ -573,7 +573,7 @@ 
                         }
 
                         $valuePlaceholder = trim($valuePlaceholder, ', ');
-                        $criteria .= ' (' . $valuePlaceholder . ') ';
+                        $criteria .= ' ('.$valuePlaceholder.') ';
                         break;
                 }
             } elseif ($value instanceof Raw) {
@@ -581,20 +581,20 @@ 
                 $criteria .= "{$statement['joiner']} {$key} {$statement['operator']} $value ";
             } else {
                 // Usual where like criteria
-                if (!$bindValues) {
+                if ( ! $bindValues) {
                     // Specially for joins
                     // We are not binding values, lets sanitize then
                     $value = $this->stringifyValue($this->wrapSanitizer($value)) ?? '';
-                    $criteria .= $statement['joiner'] . ' ' . $key . ' ' . $statement['operator'] . ' ' . $value . ' ';
+                    $criteria .= $statement['joiner'].' '.$key.' '.$statement['operator'].' '.$value.' ';
                 } elseif ($statement['key'] instanceof Raw) {
-                    $criteria .= $statement['joiner'] . ' ' . $key . ' ';
+                    $criteria .= $statement['joiner'].' '.$key.' ';
                     $bindings = array_merge($bindings, $statement['key']->getBindings());
                 } else {
                     // For wheres
                     $bindings[] = $this->getValue($value);
 
-                    $criteria .= $statement['joiner'] . ' ' . $key . ' ' . $statement['operator'] . ' '
-                    . $this->getType($value) . ' ';
+                    $criteria .= $statement['joiner'].' '.$key.' '.$statement['operator'].' '
+                    . $this->getType($value).' ';
                 }
             }
         }
@@ -649,7 +649,7 @@ 
 
         foreach ($valueArr as $key => $subValue) {
             // Don't wrap if we have *, which is not a usual field
-            $valueArr[$key] = '*' == trim($subValue) ? $subValue : $this->sanitizer . $subValue . $this->sanitizer;
+            $valueArr[$key] = '*' == trim($subValue) ? $subValue : $this->sanitizer.$subValue.$this->sanitizer;
         }
 
         // Join these back with "." and return
@@ -676,7 +676,7 @@ 
             list($criteria, $bindings) = $this->buildCriteria($statements[$key], $bindValues);
 
             if ($criteria) {
-                $criteria = $type . ' ' . $criteria;
+                $criteria = $type.' '.$criteria;
             }
         }
 
@@ -697,7 +697,7 @@ 
     {
         $sql = '';
 
-        if (!array_key_exists('joins', $statements) || !is_array($statements['joins'])) {
+        if ( ! array_key_exists('joins', $statements) || ! is_array($statements['joins'])) {
             return $sql;
         }
 
@@ -705,7 +705,7 @@ 
             if (is_array($joinArr['table'])) {
                 $mainTable  = $this->stringifyValue($this->wrapSanitizer($joinArr['table'][0]));
                 $aliasTable = $this->stringifyValue($this->wrapSanitizer($joinArr['table'][1]));
-                $table      = $mainTable . ' AS ' . $aliasTable;
+                $table      = $mainTable.' AS '.$aliasTable;
             } else {
                 $table = $joinArr['table'] instanceof Raw
                     ? $this->parseRaw($joinArr['table'])

src/QueryBuilder/TablePrefixer.php

Spacing +4 added lines, -4 removed lines

@@ -27,7 +27,7 @@ 
 
         // If supplied value is not an array then make it one
         $single = false;
-        if (!is_array($values)) {
+        if ( ! is_array($values)) {
             $values = [$values];
             // We had single value, so should return a single value
             $single = true;
@@ -45,20 +45,20 @@ 
             // If key is not integer, it is likely a alias mapping,
             // so we need to change prefix target
             $target = &$value;
-            if (!is_int($key)) {
+            if ( ! is_int($key)) {
                 $target = &$key;
             }
 
             // Do prefix if the target is an expression or function.
             if (
-                !$tableFieldMix
+                ! $tableFieldMix
                 || (
                     is_string($target) // Must be a string
                     && (bool) preg_match('/^[A-Za-z0-9_.]+$/', $target) // Can only contain letters, numbers, underscore and full stops
                     && 1 === \substr_count($target, '.') // Contains a single full stop ONLY.
                 )
             ) {
-                $target = $this->getTablePrefix() . $target;
+                $target = $this->getTablePrefix().$target;
             }
 
             $return[$key] = $value;

src/QueryBuilder/QueryBuilderHandler.php

Spacing +24 added lines, -24 removed lines

@@ -232,7 +232,7 @@ 
         $start        = microtime(true);
         $sqlStatement = empty($bindings) ? $sql : $this->interpolateQuery($sql, $bindings);
 
-        if (!is_string($sqlStatement)) {
+        if ( ! is_string($sqlStatement)) {
             throw new Exception('Could not interpolate query', 1);
         }
 
@@ -249,7 +249,7 @@ 
     public function get()
     {
         $eventResult = $this->fireEvents('before-select');
-        if (!is_null($eventResult)) {
+        if ( ! is_null($eventResult)) {
             return $eventResult;
         }
         $executionTime = 0;
@@ -274,7 +274,7 @@ 
         $this->sqlStatement = null;
 
         // Ensure we have an array of results.
-        if (!is_array($result) && null !== $result) {
+        if ( ! is_array($result) && null !== $result) {
             $result = [$result];
         }
 
@@ -307,7 +307,7 @@ 
      */
     protected function useHydrator(): bool
     {
-        return !in_array($this->getFetchMode(), [\ARRAY_A, \ARRAY_N, \OBJECT, \OBJECT_K]);
+        return ! in_array($this->getFetchMode(), [\ARRAY_A, \ARRAY_N, \OBJECT, \OBJECT_K]);
     }
 
     /**
@@ -397,7 +397,7 @@ 
             ->select([$this->raw(sprintf('%s(%s) AS field', strtoupper($type), $field))])
             ->first();
 
-        return true === isset($count->field) ? (float)$count->field : 0;
+        return true === isset($count->field) ? (float) $count->field : 0;
     }
 
     /**
@@ -413,7 +413,7 @@ 
      */
     public function count(string $field = '*'): int
     {
-        return (int)$this->aggregate('count', $field);
+        return (int) $this->aggregate('count', $field);
     }
 
     /**
@@ -491,8 +491,8 @@ 
     public function getQuery(string $type = 'select', $dataToBePassed = [])
     {
         $allowedTypes = ['select', 'insert', 'insertignore', 'replace', 'delete', 'update', 'criteriaonly'];
-        if (!in_array(strtolower($type), $allowedTypes)) {
-            throw new Exception($type . ' is not a known type.', 2);
+        if ( ! in_array(strtolower($type), $allowedTypes)) {
+            throw new Exception($type.' is not a known type.', 2);
         }
 
         $queryArr = $this->adapterInstance->$type($this->statements, $dataToBePassed);
@@ -511,9 +511,9 @@ 
      */
     public function subQuery(QueryBuilderHandler $queryBuilder, ?string $alias = null)
     {
-        $sql = '(' . $queryBuilder->getQuery()->getRawSql() . ')';
+        $sql = '('.$queryBuilder->getQuery()->getRawSql().')';
         if (is_string($alias) && 0 !== mb_strlen($alias)) {
-            $sql = $sql . ' as ' . $alias;
+            $sql = $sql.' as '.$alias;
         }
 
         return $queryBuilder->raw($sql);
@@ -530,12 +530,12 @@ 
     private function doInsert(array $data, string $type)
     {
         $eventResult = $this->fireEvents('before-insert');
-        if (!is_null($eventResult)) {
+        if ( ! is_null($eventResult)) {
             return $eventResult;
         }
 
         // If first value is not an array () not a batch insert)
-        if (!is_array(current($data))) {
+        if ( ! is_array(current($data))) {
             $queryObject = $this->getQuery($type, $data);
 
             list($preparedQuery, $executionTime) = $this->statement($queryObject->getSql(), $queryObject->getBindings());
@@ -605,7 +605,7 @@ 
     public function update($data)
     {
         $eventResult = $this->fireEvents('before-update');
-        if (!is_null($eventResult)) {
+        if ( ! is_null($eventResult)) {
             return $eventResult;
         }
         $queryObject                         = $this->getQuery('update', $data);
@@ -651,7 +651,7 @@ 
     public function delete(): int
     {
         $eventResult = $this->fireEvents('before-delete');
-        if (!is_null($eventResult)) {
+        if ( ! is_null($eventResult)) {
             return $eventResult;
         }
 
@@ -673,7 +673,7 @@ 
      */
     public function table(...$tables)
     {
-        $instance =  $this->constructCurrentBuilderClass($this->connection);
+        $instance = $this->constructCurrentBuilderClass($this->connection);
         $this->setFetchMode($this->getFetchMode(), $this->hydratorConstructorArgs);
         $tables = $this->addTablePrefix($tables, false);
         $instance->addStatement('tables', $tables);
@@ -701,7 +701,7 @@ 
      */
     public function select($fields): self
     {
-        if (!is_array($fields)) {
+        if ( ! is_array($fields)) {
             $fields = func_get_args();
         }
 
@@ -762,7 +762,7 @@ 
      */
     public function orderBy($fields, string $defaultDirection = 'ASC'): self
     {
-        if (!is_array($fields)) {
+        if ( ! is_array($fields)) {
             $fields = [$fields];
         }
 
@@ -778,7 +778,7 @@ 
                 $field = $this->jsonHandler->extractAndUnquoteFromJsonSelector($field);
             }
 
-            if (!$field instanceof Raw) {
+            if ( ! $field instanceof Raw) {
                 $field = $this->addTablePrefix($field);
             }
             $this->statements['orderBys'][] = compact('field', 'type');
@@ -1130,7 +1130,7 @@ 
             throw new Exception('Key used for whereNull condition must be a string or raw exrpession.', 1);
         }
 
-        return $this->{$operator . 'Where'}($this->raw("{$key} IS{$prefix} NULL"));
+        return $this->{$operator.'Where'}($this->raw("{$key} IS{$prefix} NULL"));
     }
 
 
@@ -1227,8 +1227,8 @@ 
             $value = $this->jsonHandler->extractAndUnquoteFromJsonSelector($value);
         }
 
-        if (!$key instanceof Closure) {
-            $key = function ($joinBuilder) use ($key, $operator, $value) {
+        if ( ! $key instanceof Closure) {
+            $key = function($joinBuilder) use ($key, $operator, $value) {
                 $joinBuilder->on($key, $operator, $value);
             };
         }
@@ -1323,7 +1323,7 @@ 
      */
     public function joinUsing(string $table, string $key, string $type = 'INNER'): self
     {
-        if (!array_key_exists('tables', $this->statements) || count($this->statements['tables']) !== 1) {
+        if ( ! array_key_exists('tables', $this->statements) || count($this->statements['tables']) !== 1) {
             throw new Exception("JoinUsing can only be used with a single table set as the base of the query", 1);
         }
         $baseTable = end($this->statements['tables']);
@@ -1414,11 +1414,11 @@ 
      */
     protected function addStatement($key, $value)
     {
-        if (!is_array($value)) {
+        if ( ! is_array($value)) {
             $value = [$value];
         }
 
-        if (!array_key_exists($key, $this->statements)) {
+        if ( ! array_key_exists($key, $this->statements)) {
             $this->statements[$key] = $value;
         } else {
             $this->statements[$key] = array_merge($this->statements[$key], $value);

src/JSON/JsonSelectorHandler.php

Spacing +2 added lines, -2 removed lines

@@ -75,7 +75,7 @@ 
      */
     public function toJsonSelector(string $expression): JsonSelector
     {
-        if (! $this->isJsonSelector($expression)) {
+        if ( ! $this->isJsonSelector($expression)) {
             throw new Exception('JSON expression must contain at least 2 values, the table column and at least 1 node.', 1);
         }
 
@@ -85,7 +85,7 @@ 
         $column = array_shift($parts);
         $nodes = $parts;
 
-        if (! is_string($column)) {
+        if ( ! is_string($column)) {
             throw new Exception('JSON expression must contain a valid column name', 1);
         }