adumitru68 / QueryBuilder

src/Traits/TableValidation.php

Braces +12 added lines, -8 removed lines

@@ -44,22 +44,26 @@
 	{
 		$table = trim( $table );
 
-		if ( '' === $table )
-			throw new QueryException( 'Table name is empty string!', QueryException::QUERY_ERROR_INVALID_TABLE_STATEMENT );
+		if ( '' === $table ) {
+					throw new QueryException( 'Table name is empty string!', QueryException::QUERY_ERROR_INVALID_TABLE_STATEMENT );
+		}
 
-		if ( DbConfig::getInstance()->useTablePrefix() )
-			$table = str_ireplace( '::', DbConfig::getInstance()->getTablePrefix(), $table );
+		if ( DbConfig::getInstance()->useTablePrefix() ) {
+					$table = str_ireplace( '::', DbConfig::getInstance()->getTablePrefix(), $table );
+		}
 
 		return $table;
 	}
 
 	private function validateTableSubQuery( $table )
 	{
-		if ( $this->statement !== self::QUERY_STATEMENT_SELECT )
-			throw new QueryException( 'Invalid subQuery statement!', QueryException::QUERY_ERROR_INVALID_TABLE_STATEMENT );
+		if ( $this->statement !== self::QUERY_STATEMENT_SELECT ) {
+					throw new QueryException( 'Invalid subQuery statement!', QueryException::QUERY_ERROR_INVALID_TABLE_STATEMENT );
+		}
 
-		if ( !is_a( $table, QuerySelect::class ) )
-			throw new QueryException( 'Invalid subQuery statement!', QueryException::QUERY_ERROR_INVALID_TABLE_STATEMENT );
+		if ( !is_a( $table, QuerySelect::class ) ) {
+					throw new QueryException( 'Invalid subQuery statement!', QueryException::QUERY_ERROR_INVALID_TABLE_STATEMENT );
+		}
 
 		return $table;
 	}

src/Traits/GroupBy.php

Braces +9 added lines, -6 removed lines

@@ -28,8 +28,9 @@ 
 	{
 		$column = trim( $column );
 
-		if ( !$this->validateColumn( $column, $allowedColumns ) )
-			throw new QueryException( 'Invalid column name in GROUP BY clause', QueryException::QUERY_ERROR_INVALID_COLUMN_NAME );
+		if ( !$this->validateColumn( $column, $allowedColumns ) ) {
+					throw new QueryException( 'Invalid column name in GROUP BY clause', QueryException::QUERY_ERROR_INVALID_COLUMN_NAME );
+		}
 
 		$this->queryStructure->setElement( QueryStructure::GROUP_BY, $column );
 
@@ -47,8 +48,9 @@ 
 	{
 		$column = trim( $column );
 
-		if ( !$this->validateColumn( $column, $allowedColumns ) )
-			throw new QueryException( 'Invalid column name in GROUP BY clause', QueryException::QUERY_ERROR_INVALID_COLUMN_NAME );
+		if ( !$this->validateColumn( $column, $allowedColumns ) ) {
+					throw new QueryException( 'Invalid column name in GROUP BY clause', QueryException::QUERY_ERROR_INVALID_COLUMN_NAME );
+		}
 
 		$this->queryStructure->setElement( QueryStructure::GROUP_BY, $column . ' DESC' );
 
@@ -73,8 +75,9 @@ 
 	 */
 	private function getGroupBySyntax()
 	{
-		if ( count( $this->queryStructure->getElement( QueryStructure::GROUP_BY ) ) )
-			return 'GROUP BY ' . QueryHelper::implode( $this->queryStructure->getElement( QueryStructure::GROUP_BY ), ', ' );
+		if ( count( $this->queryStructure->getElement( QueryStructure::GROUP_BY ) ) ) {
+					return 'GROUP BY ' . QueryHelper::implode( $this->queryStructure->getElement( QueryStructure::GROUP_BY ), ', ' );
+		}
 
 		return '';
 	}

src/Dependencies/QueryHelper.php

Braces +9 added lines, -5 removed lines

@@ -87,7 +87,9 @@ 
 		$newArray = array();
 		foreach ( $brutArray as $value ) {
 			$value = trim( $value );
-			if ( '' !== $value ) $newArray[] = $value;
+			if ( '' !== $value ) {
+				$newArray[] = $value;
+			}
 		}
 
 		return $newArray;
@@ -137,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 );
 	}
@@ -146,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, -16 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 );
+		}
 
 	}
 
@@ -172,16 +173,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;
 	}
@@ -194,8 +198,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;
 	}
@@ -243,11 +248,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/Dependencies/Tree.php

Braces +15 added lines, -9 removed lines

@@ -173,13 +173,15 @@ 
 	private function calculateParents( $nodeId )
 	{
 
-		if(!array_key_exists($this->flatArray[ $nodeId ][ $this->role[ self::PARENT_ID_NAME ] ], $this->flatArray))
-			return false;
+		if(!array_key_exists($this->flatArray[ $nodeId ][ $this->role[ self::PARENT_ID_NAME ] ], $this->flatArray)) {
+					return false;
+		}
 
 		$parentNode = $this->flatArray[ $nodeId ][ $this->role[ self::PARENT_ID_NAME ] ];
 
-		if ( $parentNode != $this->rootValue )
-			$this->parents[] = $parentNode;
+		if ( $parentNode != $this->rootValue ) {
+					$this->parents[] = $parentNode;
+		}
 
 		if ( $parentNode != $this->rootValue ) {
 			$this->calculateParents( $parentNode );
@@ -217,13 +219,15 @@ 
 	 */
 	private function prepareFlatArray()
 	{
-		if ( self::isArrayAssoc( $this->flatArray ) )
-			return true;
+		if ( self::isArrayAssoc( $this->flatArray ) ) {
+					return true;
+		}
 
 		$newFlat = [];
 
-		foreach ( $this->flatArray as $value )
-			$newFlat[ $value[ $this->role[ self::ID_NAME ] ] ] = $value;
+		foreach ( $this->flatArray as $value ) {
+					$newFlat[ $value[ $this->role[ self::ID_NAME ] ] ] = $value;
+		}
 
 		$this->flatArray = $newFlat;
 
@@ -237,7 +241,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 );
 	}

src/DB/DbLog.php

Braces +2 added lines, -4 removed lines

@@ -85,12 +85,10 @@
 				$fh = fopen( $log, 'a+' ) or die( "Fatal Error !" );
 				fwrite( $fh, $messageFormat );
 				fclose( $fh );
-			}
-			else {
+			} else {
 				$this->edit( $log, $date, $messageFormat );
 			}
-		}
-		else {
+		} else {
 			if ( mkdir( $this->path, 0777 ) === true ) {
 				$this->write( $message );
 			}

src/DB/DbService.php

Braces +20 added lines, -21 removed lines

@@ -66,14 +66,12 @@ 
 			$statement === self::QUERY_TYPE_EXPLAIN
 		) {
 			return $this->sQuery->fetchAll( $fetchMode );
-		}
-		elseif ( $statement === self::QUERY_TYPE_INSERT ||
+		} elseif ( $statement === self::QUERY_TYPE_INSERT ||
 			$statement === self::QUERY_TYPE_UPDATE ||
 			$statement === self::QUERY_TYPE_DELETE
 		) {
 			return $this->sQuery->rowCount();
-		}
-		else {
+		} else {
 
 			return NULL;
 		}
@@ -91,8 +89,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 );
 
@@ -112,8 +111,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,
@@ -150,24 +150,22 @@ 
 			/**
 			 * 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 ) {
 					if ( is_int( $value[1] ) ) {
 						$type = \PDO::PARAM_INT;
-					}
-					elseif ( is_bool( $value[1] ) ) {
+					} elseif ( is_bool( $value[1] ) ) {
 						$type = \PDO::PARAM_BOOL;
-					}
-					elseif ( is_null( $value[1] ) ) {
+					} elseif ( is_null( $value[1] ) ) {
 						$type = \PDO::PARAM_NULL;
-					}
-					else {
+					} else {
 						$type = \PDO::PARAM_STR;
 					}
 					$this->sQuery->bindValue( $value[0], $value[1], $type );
@@ -253,8 +251,7 @@ 
 					return self::QUERY_TYPE_OTHER;
 					break;
 			}
-		}
-		else {
+		} else {
 			return self::QUERY_TYPE_OTHER;
 		}
 	}
@@ -265,7 +262,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 );
 	}

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();
 	}

src/DB/DbConfig.php

Braces +11 added lines, -8 removed lines

@@ -60,10 +60,11 @@ 
 	private function __construct()
 	{
 		$vendorCfg = __DIR__ . '/../../../../../vendor-cfg/qpdb_db_config.php';
-		if(file_exists($vendorCfg))
-			$this->dbConfig = require $vendorCfg;
-		else
-			$this->dbConfig = require __DIR__ . '/../../config/qpdb_db_config.php';
+		if(file_exists($vendorCfg)) {
+					$this->dbConfig = require $vendorCfg;
+		} else {
+					$this->dbConfig = require __DIR__ . '/../../config/qpdb_db_config.php';
+		}
 
 		$this->buildConfig();
 	}
@@ -146,8 +147,9 @@ 
 
 	public function useTablePrefix()
 	{
-		if ( !empty( $this->dbConfig['use_table_prefix'] ) )
-			return $this->dbConfig['use_table_prefix'];
+		if ( !empty( $this->dbConfig['use_table_prefix'] ) ) {
+					return $this->dbConfig['use_table_prefix'];
+		}
 
 		return false;
 	}
@@ -182,8 +184,9 @@ 
 	private function readMasterDataConnect()
 	{
 
-		if ( !isset( $this->dbConfig['master_data_connect'][0] ) )
-			throw new DbException( 'Master data connect is missing', DbException::DB_ERROR_MASTER_DATA_CONNECTION_MISSING );
+		if ( !isset( $this->dbConfig['master_data_connect'][0] ) ) {
+					throw new DbException( 'Master data connect is missing', DbException::DB_ERROR_MASTER_DATA_CONNECTION_MISSING );
+		}
 
 		$dataConnection = $this->dbConfig['master_data_connect'];