adumitru68 / QueryBuilder

src/Traits/ColumnValidation.php

Braces +6 added lines, -4 removed lines

@@ -16,11 +16,13 @@
 
     protected function validateColumn($columnName, array $allowed)
     {
-        if (is_integer($columnName))
-            return true;
+        if (is_integer($columnName)) {
+                    return true;
+        }
 
-        if (!count($allowed))
-            return true;
+        if (!count($allowed)) {
+                    return true;
+        }
 
         return false;
     }

src/Traits/Utilities.php

Braces +3 added lines, -2 removed lines

@@ -28,8 +28,9 @@
 
     protected function getExplainSyntax()
     {
-        if ($this->queryStructure->getElement(QueryStructure::EXPLAIN))
-            return 'EXPLAIN';
+        if ($this->queryStructure->getElement(QueryStructure::EXPLAIN)) {
+                    return 'EXPLAIN';
+        }
 
         return '';
     }

src/Dependencies/QueryHelper.php

Braces +9 added lines, -6 removed lines

@@ -87,8 +87,9 @@ 
         $newArray = array();
         foreach ($brutArray as $value) {
             $value = trim($value);
-            if ('' !== $value)
-                $newArray[] = $value;
+            if ('' !== $value) {
+                            $newArray[] = $value;
+            }
         }
 
         return $newArray;
@@ -138,8 +139,9 @@ 
         $characters = 'abcdefghijklmnopqrstuvwxyz';
         $charactersLength = strlen($characters);
         $randomString = '';
-        for ($i = 0; $i < $length; $i++)
-            $randomString .= $characters[ rand(0, $charactersLength - 1) ];
+        for ($i = 0; $i < $length; $i++) {
+                    $randomString .= $characters[ rand(0, $charactersLength - 1) ];
+        }
 
         return str_shuffle($randomString);
     }
@@ -147,8 +149,9 @@ 
     public static function limitString($rowCount, $offset = null)
     {
         $rowCount = intval($rowCount);
-        if (is_null($offset))
-            return $rowCount;
+        if (is_null($offset)) {
+                    return $rowCount;
+        }
         $offset = intval($offset);
 
         return "$offset, $rowCount";

src/Dependencies/QueryStructure.php

Braces +23 added lines, -15 removed lines

@@ -85,8 +85,9 @@ 
     {
         $this->syntaxEL = $this->init();
 
-        foreach ($this->syntaxEL as $name => $value)
-            $this->typeEL[ $name ] = gettype($value);
+        foreach ($this->syntaxEL as $name => $value) {
+                    $this->typeEL[ $name ] = gettype($value);
+        }
 
     }
 
@@ -142,15 +143,19 @@ 
      */
     public function setElement($name, $value)
     {
-        if (!array_key_exists($name, $this->syntaxEL))
-            throw new QueryException('Invalid Query property', QueryException::QUERY_ERROR_ELEMENT_NOT_FOUND);
+        if (!array_key_exists($name, $this->syntaxEL)) {
+                    throw new QueryException('Invalid Query property', QueryException::QUERY_ERROR_ELEMENT_NOT_FOUND);
+        }
 
-        if ($name == self::TABLE && is_a($value, QueryStatement::class))
-            return true;
+        if ($name == self::TABLE && is_a($value, QueryStatement::class)) {
+                    return true;
+        }
 
-        if ($this->typeEL[ $name ] === self::ELEMENT_TYPE_ARRAY)
-            $this->syntaxEL[ $name ][] = $value; else
-            $this->syntaxEL[ $name ] = $value;
+        if ($this->typeEL[ $name ] === self::ELEMENT_TYPE_ARRAY) {
+                    $this->syntaxEL[ $name ][] = $value;
+        } else {
+                        $this->syntaxEL[ $name ] = $value;
+            }
 
         return true;
     }
@@ -163,8 +168,9 @@ 
      */
     public function replaceElement($elementName, $elementValue)
     {
-        if (!array_key_exists($elementName, $this->syntaxEL))
-            throw new QueryException('Invalid Query property', QueryException::QUERY_ERROR_ELEMENT_NOT_FOUND);
+        if (!array_key_exists($elementName, $this->syntaxEL)) {
+                    throw new QueryException('Invalid Query property', QueryException::QUERY_ERROR_ELEMENT_NOT_FOUND);
+        }
 
         $this->syntaxEL[ $elementName ] = $elementValue;
     }
@@ -212,11 +218,13 @@ 
      */
     public function bindParamsExpression($expression, array $params = [], $search = '?')
     {
-        if (!count($params))
-            return $expression;
+        if (!count($params)) {
+                    return $expression;
+        }
 
-        if (strpos($expression, $search) === false)
-            return $expression;
+        if (strpos($expression, $search) === false) {
+                    return $expression;
+        }
 
         $params = array_slice($params, 0, substr_count($expression, $search));
 

src/Statements/QuerySelect.php

Braces +9 added lines, -6 removed lines

@@ -55,8 +55,9 @@ 
             $this->queryStructure->setElement(QueryStructure::TABLE, $tableName);
 
             $tableSelectParams = $table->getBindParams();
-            foreach ($tableSelectParams as $key => $value)
-                $this->queryStructure->setParams($key, $value);
+            foreach ($tableSelectParams as $key => $value) {
+                            $this->queryStructure->setParams($key, $value);
+            }
 
         }
     }
@@ -107,8 +108,9 @@ 
             $this->queryStructure->setElement(QueryStructure::DISTINCT, 0); //???
         }
 
-        if ($this->queryStructure->getElement(QueryStructure::FIRST))
-            $this->queryStructure->setElement(QueryStructure::LIMIT, 1);
+        if ($this->queryStructure->getElement(QueryStructure::FIRST)) {
+                    $this->queryStructure->setElement(QueryStructure::LIMIT, 1);
+        }
 
         $syntax = array();
 
@@ -190,8 +192,9 @@ 
                 return DbService::getInstance()->single($this->getSyntax(), $this->queryStructure->getElement(QueryStructure::BIND_PARAMS));
                 break;
             case $this->queryStructure->getElement(QueryStructure::FIRST):
-                if ($this->queryStructure->getElement(QueryStructure::COLUMN))
-                    return DbService::getInstance()->single($this->getSyntax(), $this->queryStructure->getElement(QueryStructure::BIND_PARAMS));
+                if ($this->queryStructure->getElement(QueryStructure::COLUMN)) {
+                                    return DbService::getInstance()->single($this->getSyntax(), $this->queryStructure->getElement(QueryStructure::BIND_PARAMS));
+                }
 
                 return DbService::getInstance()->row($this->getSyntax(), $this->queryStructure->getElement(QueryStructure::BIND_PARAMS));
                 break;

src/Statements/QueryUpdate.php

Braces +3 added lines, -2 removed lines

@@ -106,8 +106,9 @@
      */
     public function execute()
     {
-        if ($this->queryStructure->getElement((QueryStructure::WHERE_TRIGGER)) && !count($this->queryStructure->getElement(QueryStructure::WHERE)))
-            throw new QueryException('Where clause is required for this statement!', QueryException::QUERY_ERROR_DELETE_NOT_FILTER);
+        if ($this->queryStructure->getElement((QueryStructure::WHERE_TRIGGER)) && !count($this->queryStructure->getElement(QueryStructure::WHERE))) {
+                    throw new QueryException('Where clause is required for this statement!', QueryException::QUERY_ERROR_DELETE_NOT_FILTER);
+        }
 
         return DbService::getInstance()->query($this->getSyntax(), $this->queryStructure->getElement(QueryStructure::BIND_PARAMS));
     }

src/Statements/QueryDelete.php

Braces +3 added lines, -2 removed lines

@@ -96,8 +96,9 @@
     public function execute()
     {
 
-        if ($this->queryStructure->getElement((QueryStructure::WHERE_TRIGGER)) && !count($this->queryStructure->getElement(QueryStructure::WHERE)))
-            throw new QueryException('Where or Having clause is required for this statement!', QueryException::QUERY_ERROR_DELETE_NOT_FILTER);
+        if ($this->queryStructure->getElement((QueryStructure::WHERE_TRIGGER)) && !count($this->queryStructure->getElement(QueryStructure::WHERE))) {
+                    throw new QueryException('Where or Having clause is required for this statement!', QueryException::QUERY_ERROR_DELETE_NOT_FILTER);
+        }
 
         return DbService::getInstance()->query($this->getSyntax(), $this->queryStructure->getElement(QueryStructure::BIND_PARAMS));
 

src/DB/DbService.php

Braces +14 added lines, -9 removed lines

@@ -135,10 +135,12 @@ 
             /**
              * Add parameters to the parameter array
              */
-            if (self::isArrayAssoc($parameters))
-                $this->bindMore($parameters); else
-                foreach ($parameters as $key => $val)
+            if (self::isArrayAssoc($parameters)) {
+                            $this->bindMore($parameters);
+            } else {
+                                foreach ($parameters as $key => $val)
                     $this->parameters[] = array($key + 1, $val);
+                }
 
             if (count($this->parameters)) {
                 foreach ($this->parameters as $param => $value) {
@@ -181,8 +183,9 @@ 
      */
     public static function isArrayAssoc(array $arr)
     {
-        if (array() === $arr)
-            return false;
+        if (array() === $arr) {
+                    return false;
+        }
 
         return array_keys($arr) !== range(0, count($arr) - 1);
     }
@@ -214,8 +217,9 @@ 
         $query = trim(str_replace("\r", " ", $query));
         $statement = self::getQueryStatement($query);
 
-        if ($statement === self::QUERY_TYPE_EXPLAIN)
-            return $this->sQuery->fetchAll(\PDO::FETCH_ASSOC);
+        if ($statement === self::QUERY_TYPE_EXPLAIN) {
+                    return $this->sQuery->fetchAll(\PDO::FETCH_ASSOC);
+        }
 
         $Columns = $this->sQuery->fetchAll(\PDO::FETCH_NUM);
 
@@ -235,8 +239,9 @@ 
         $query = trim(str_replace("\r", " ", $query));
         $statement = self::getQueryStatement($query);
 
-        if ($statement === self::QUERY_TYPE_EXPLAIN)
-            return $this->sQuery->fetchAll(\PDO::FETCH_ASSOC);
+        if ($statement === self::QUERY_TYPE_EXPLAIN) {
+                    return $this->sQuery->fetchAll(\PDO::FETCH_ASSOC);
+        }
 
         $result = $this->sQuery->fetch($fetchmode);
         $this->sQuery->closeCursor(); // Frees up the connection to the server so that other SQL statements may be issued,

src/DB/DbConnect.php

Braces +12 added lines, -8 removed lines

@@ -42,8 +42,9 @@ 
      */
     public function getMasterConnection()
     {
-        if (!is_a($this->pdoMaster, \PDO::class))
-            $this->pdoMaster = $this->connect($this->config->getMasterDataConnect());
+        if (!is_a($this->pdoMaster, \PDO::class)) {
+                    $this->pdoMaster = $this->connect($this->config->getMasterDataConnect());
+        }
 
         return $this->pdoMaster;
     }
@@ -53,11 +54,13 @@ 
      */
     public function getSlaveConnection()
     {
-        if (!$this->config->getReplicationEnable())
-            return $this->getMasterConnection();
+        if (!$this->config->getReplicationEnable()) {
+                    return $this->getMasterConnection();
+        }
 
-        if (!is_a($this->pdoSlave, \PDO::class))
-            $this->pdoSlave = $this->connect($this->config->getSlaveDataConnect());
+        if (!is_a($this->pdoSlave, \PDO::class)) {
+                    $this->pdoSlave = $this->connect($this->config->getSlaveDataConnect());
+        }
 
         return $this->pdoSlave;
     }
@@ -70,8 +73,9 @@ 
     {
         $statement = trim(strtolower($statement));
 
-        if ($statement === DbService::QUERY_TYPE_SELECT)
-            return $this->getSlaveConnection();
+        if ($statement === DbService::QUERY_TYPE_SELECT) {
+                    return $this->getSlaveConnection();
+        }
 
         return $this->getMasterConnection();
     }