adumitru68 / QueryBuilder

src/Statements/QueryInsert.php

Indentation +75 added lines, -75 removed lines

@@ -23,81 +23,81 @@
 class QueryInsert extends QueryStatement implements QueryStatementInterface
 {
 
-    use Replacement, SetFields, Ignore, DefaultPriority, LowPriority, HighPriority, Utilities;
-
-    /**
-     * @var string
-     */
-    protected $statement = self::QUERY_STATEMENT_INSERT;
-
-
-    /**
-     * QueryInsert constructor.
-     * @param QueryBuild $queryBuild
-     * @param string $table
-     */
-    public function __construct(QueryBuild $queryBuild, $table = null)
-    {
-        parent::__construct($queryBuild, $table);
-    }
-
-    /**
-     * @return QueryInsertMultiple
-     */
-    public function multiple()
-    {
-        return new QueryInsertMultiple($this->queryBuild, $this->queryStructure->getElement(QueryStructure::TABLE));
-    }
-
-    /**
-     * @param bool|int $replacement
-     * @return mixed|string
-     */
-    public function getSyntax($replacement = self::REPLACEMENT_NONE)
-    {
-        $syntax = array();
-
-        /**
-         *  Explain
-         */
-        $syntax[] = $this->getExplainSyntax();
-
-        /**
-         * UPDATE statement
-         */
-        $syntax[] = $this->statement;
-
-        /**
-         * PRIORITY
-         */
-        $syntax[] = $this->queryStructure->getElement(QueryStructure::PRIORITY);
-
-        /**
-         * IGNORE clause
-         */
-        $syntax[] = $this->queryStructure->getElement(QueryStructure::IGNORE) ? 'IGNORE' : '';
-
-        /**
-         * INTO table
-         */
-        $syntax[] = 'INTO ' . $this->queryStructure->getElement(QueryStructure::TABLE);
-
-        /**
-         * FIELDS update
-         */
-        $syntax[] = $this->getSettingFieldsSyntax();
-
-        $syntax = implode(' ', $syntax);
-
-        return $this->getSyntaxReplace($syntax, $replacement);
-
-    }
-
-
-    public function execute()
-    {
-        return DbService::getInstance()->query($this->getSyntax(), $this->queryStructure->getElement(QueryStructure::BIND_PARAMS));
-    }
+	use Replacement, SetFields, Ignore, DefaultPriority, LowPriority, HighPriority, Utilities;
+
+	/**
+	 * @var string
+	 */
+	protected $statement = self::QUERY_STATEMENT_INSERT;
+
+
+	/**
+	 * QueryInsert constructor.
+	 * @param QueryBuild $queryBuild
+	 * @param string $table
+	 */
+	public function __construct(QueryBuild $queryBuild, $table = null)
+	{
+		parent::__construct($queryBuild, $table);
+	}
+
+	/**
+	 * @return QueryInsertMultiple
+	 */
+	public function multiple()
+	{
+		return new QueryInsertMultiple($this->queryBuild, $this->queryStructure->getElement(QueryStructure::TABLE));
+	}
+
+	/**
+	 * @param bool|int $replacement
+	 * @return mixed|string
+	 */
+	public function getSyntax($replacement = self::REPLACEMENT_NONE)
+	{
+		$syntax = array();
+
+		/**
+		 *  Explain
+		 */
+		$syntax[] = $this->getExplainSyntax();
+
+		/**
+		 * UPDATE statement
+		 */
+		$syntax[] = $this->statement;
+
+		/**
+		 * PRIORITY
+		 */
+		$syntax[] = $this->queryStructure->getElement(QueryStructure::PRIORITY);
+
+		/**
+		 * IGNORE clause
+		 */
+		$syntax[] = $this->queryStructure->getElement(QueryStructure::IGNORE) ? 'IGNORE' : '';
+
+		/**
+		 * INTO table
+		 */
+		$syntax[] = 'INTO ' . $this->queryStructure->getElement(QueryStructure::TABLE);
+
+		/**
+		 * FIELDS update
+		 */
+		$syntax[] = $this->getSettingFieldsSyntax();
+
+		$syntax = implode(' ', $syntax);
+
+		return $this->getSyntaxReplace($syntax, $replacement);
+
+	}
+
+
+	public function execute()
+	{
+		return DbService::getInstance()->query($this->getSyntax(), $this->queryStructure->getElement(QueryStructure::BIND_PARAMS));
+	}
 
 
 }
\ No newline at end of file

Spacing +13 added lines, -13 removed lines

@@ -36,9 +36,9 @@ 
      * @param QueryBuild $queryBuild
      * @param string $table
      */
-    public function __construct(QueryBuild $queryBuild, $table = null)
+    public function __construct( QueryBuild $queryBuild, $table = null )
     {
-        parent::__construct($queryBuild, $table);
+        parent::__construct( $queryBuild, $table );
     }
 
     /**
@@ -46,57 +46,57 @@ 
      */
     public function multiple()
     {
-        return new QueryInsertMultiple($this->queryBuild, $this->queryStructure->getElement(QueryStructure::TABLE));
+        return new QueryInsertMultiple( $this->queryBuild, $this->queryStructure->getElement( QueryStructure::TABLE ) );
     }
 
     /**
      * @param bool|int $replacement
      * @return mixed|string
      */
-    public function getSyntax($replacement = self::REPLACEMENT_NONE)
+    public function getSyntax( $replacement = self::REPLACEMENT_NONE )
     {
         $syntax = array();
 
         /**
          *  Explain
          */
-        $syntax[] = $this->getExplainSyntax();
+        $syntax[ ] = $this->getExplainSyntax();
 
         /**
          * UPDATE statement
          */
-        $syntax[] = $this->statement;
+        $syntax[ ] = $this->statement;
 
         /**
          * PRIORITY
          */
-        $syntax[] = $this->queryStructure->getElement(QueryStructure::PRIORITY);
+        $syntax[ ] = $this->queryStructure->getElement( QueryStructure::PRIORITY );
 
         /**
          * IGNORE clause
          */
-        $syntax[] = $this->queryStructure->getElement(QueryStructure::IGNORE) ? 'IGNORE' : '';
+        $syntax[ ] = $this->queryStructure->getElement( QueryStructure::IGNORE ) ? 'IGNORE' : '';
 
         /**
          * INTO table
          */
-        $syntax[] = 'INTO ' . $this->queryStructure->getElement(QueryStructure::TABLE);
+        $syntax[ ] = 'INTO ' . $this->queryStructure->getElement( QueryStructure::TABLE );
 
         /**
          * FIELDS update
          */
-        $syntax[] = $this->getSettingFieldsSyntax();
+        $syntax[ ] = $this->getSettingFieldsSyntax();
 
-        $syntax = implode(' ', $syntax);
+        $syntax = implode( ' ', $syntax );
 
-        return $this->getSyntaxReplace($syntax, $replacement);
+        return $this->getSyntaxReplace( $syntax, $replacement );
 
     }
 
 
     public function execute()
     {
-        return DbService::getInstance()->query($this->getSyntax(), $this->queryStructure->getElement(QueryStructure::BIND_PARAMS));
+        return DbService::getInstance()->query( $this->getSyntax(), $this->queryStructure->getElement( QueryStructure::BIND_PARAMS ) );
     }
 
 

src/Statements/QueryInsertMultiple.php

Indentation +63 added lines, -63 removed lines

@@ -23,67 +23,67 @@
 class QueryInsertMultiple extends QueryStatement implements QueryStatementInterface
 {
 
-    use InsertMultiple, Replacement, Ignore, DefaultPriority, LowPriority, HighPriority, Utilities;
-
-    /**
-     * @var string
-     */
-    protected $statement = self::QUERY_STATEMENT_INSERT;
-
-
-    /**
-     * QueryInsert constructor.
-     * @param QueryBuild $queryBuild
-     * @param string $table
-     */
-    public function __construct(QueryBuild $queryBuild, $table = null)
-    {
-        parent::__construct($queryBuild, $table);
-        $this->queryStructure->setElement(QueryStructure::FIELDS, array());
-    }
-
-    public function getSyntax($replacement = self::REPLACEMENT_NONE)
-    {
-        $syntax = array();
-
-        /**
-         *  Explain
-         */
-        $syntax[] = $this->getExplainSyntax();
-
-        /**
-         * UPDATE statement
-         */
-        $syntax[] = $this->statement;
-
-        /**
-         * PRIORITY
-         */
-        $syntax[] = $this->queryStructure->getElement(QueryStructure::PRIORITY);
-
-        /**
-         * IGNORE clause
-         */
-        $syntax[] = $this->queryStructure->getElement(QueryStructure::IGNORE) ? 'IGNORE' : '';
-
-        /**
-         * INTO table
-         */
-        $syntax[] = 'INTO ' . $this->queryStructure->getElement(QueryStructure::TABLE);
-
-        /**
-         * FIELDS update
-         */
-        $syntax[] = $this->getInsertMultipleRowsSyntax();
-
-        $syntax = implode(' ', $syntax);
-
-        return $this->getSyntaxReplace($syntax, $replacement);
-
-    }
-
-    public function execute()
-    {
-        return DbService::getInstance()->query($this->getSyntax(), $this->queryStructure->getElement(QueryStructure::BIND_PARAMS));
-    }
+	use InsertMultiple, Replacement, Ignore, DefaultPriority, LowPriority, HighPriority, Utilities;
+
+	/**
+	 * @var string
+	 */
+	protected $statement = self::QUERY_STATEMENT_INSERT;
+
+
+	/**
+	 * QueryInsert constructor.
+	 * @param QueryBuild $queryBuild
+	 * @param string $table
+	 */
+	public function __construct(QueryBuild $queryBuild, $table = null)
+	{
+		parent::__construct($queryBuild, $table);
+		$this->queryStructure->setElement(QueryStructure::FIELDS, array());
+	}
+
+	public function getSyntax($replacement = self::REPLACEMENT_NONE)
+	{
+		$syntax = array();
+
+		/**
+		 *  Explain
+		 */
+		$syntax[] = $this->getExplainSyntax();
+
+		/**
+		 * UPDATE statement
+		 */
+		$syntax[] = $this->statement;
+
+		/**
+		 * PRIORITY
+		 */
+		$syntax[] = $this->queryStructure->getElement(QueryStructure::PRIORITY);
+
+		/**
+		 * IGNORE clause
+		 */
+		$syntax[] = $this->queryStructure->getElement(QueryStructure::IGNORE) ? 'IGNORE' : '';
+
+		/**
+		 * INTO table
+		 */
+		$syntax[] = 'INTO ' . $this->queryStructure->getElement(QueryStructure::TABLE);
+
+		/**
+		 * FIELDS update
+		 */
+		$syntax[] = $this->getInsertMultipleRowsSyntax();
+
+		$syntax = implode(' ', $syntax);
+
+		return $this->getSyntaxReplace($syntax, $replacement);
+
+	}
+
+	public function execute()
+	{
+		return DbService::getInstance()->query($this->getSyntax(), $this->queryStructure->getElement(QueryStructure::BIND_PARAMS));
+	}
 }
\ No newline at end of file

Spacing +13 added lines, -13 removed lines

@@ -36,54 +36,54 @@
      * @param QueryBuild $queryBuild
      * @param string $table
      */
-    public function __construct(QueryBuild $queryBuild, $table = null)
+    public function __construct( QueryBuild $queryBuild, $table = null )
     {
-        parent::__construct($queryBuild, $table);
-        $this->queryStructure->setElement(QueryStructure::FIELDS, array());
+        parent::__construct( $queryBuild, $table );
+        $this->queryStructure->setElement( QueryStructure::FIELDS, array() );
     }
 
-    public function getSyntax($replacement = self::REPLACEMENT_NONE)
+    public function getSyntax( $replacement = self::REPLACEMENT_NONE )
     {
         $syntax = array();
 
         /**
          *  Explain
          */
-        $syntax[] = $this->getExplainSyntax();
+        $syntax[ ] = $this->getExplainSyntax();
 
         /**
          * UPDATE statement
          */
-        $syntax[] = $this->statement;
+        $syntax[ ] = $this->statement;
 
         /**
          * PRIORITY
          */
-        $syntax[] = $this->queryStructure->getElement(QueryStructure::PRIORITY);
+        $syntax[ ] = $this->queryStructure->getElement( QueryStructure::PRIORITY );
 
         /**
          * IGNORE clause
          */
-        $syntax[] = $this->queryStructure->getElement(QueryStructure::IGNORE) ? 'IGNORE' : '';
+        $syntax[ ] = $this->queryStructure->getElement( QueryStructure::IGNORE ) ? 'IGNORE' : '';
 
         /**
          * INTO table
          */
-        $syntax[] = 'INTO ' . $this->queryStructure->getElement(QueryStructure::TABLE);
+        $syntax[ ] = 'INTO ' . $this->queryStructure->getElement( QueryStructure::TABLE );
 
         /**
          * FIELDS update
          */
-        $syntax[] = $this->getInsertMultipleRowsSyntax();
+        $syntax[ ] = $this->getInsertMultipleRowsSyntax();
 
-        $syntax = implode(' ', $syntax);
+        $syntax = implode( ' ', $syntax );
 
-        return $this->getSyntaxReplace($syntax, $replacement);
+        return $this->getSyntaxReplace( $syntax, $replacement );
 
     }
 
     public function execute()
     {
-        return DbService::getInstance()->query($this->getSyntax(), $this->queryStructure->getElement(QueryStructure::BIND_PARAMS));
+        return DbService::getInstance()->query( $this->getSyntax(), $this->queryStructure->getElement( QueryStructure::BIND_PARAMS ) );
     }
 }
\ No newline at end of file

src/Statements/QueryStatement.php

Indentation +65 added lines, -65 removed lines

@@ -18,71 +18,71 @@
 abstract class QueryStatement
 {
 
-    use Utilities, TableValidation, ColumnValidation;
-
-
-    /**
-     * Statements
-     */
-    const QUERY_STATEMENT_SELECT = 'SELECT';
-    const QUERY_STATEMENT_UPDATE = 'UPDATE';
-    const QUERY_STATEMENT_DELETE = 'DELETE';
-    const QUERY_STATEMENT_INSERT = 'INSERT';
-    const QUERY_STATEMENT_CUSTOM = 'CUSTOM';
-
-
-    /**
-     * @var string
-     */
-    protected $statement;
-
-    /**
-     * @var QueryBuild
-     */
-    protected $queryBuild;
-
-    /**
-     * @var QueryStructure
-     */
-    protected $queryStructure;
-
-    /**
-     * @var array
-     */
-    protected $usedInstanceIds = [];
-
-    /**
-     * @var string
-     */
-    protected $tablePrefix;
-
-
-    /**
-     * QueryStatement constructor.
-     * @param QueryBuild $queryBuild
-     * @param string|QuerySelect $table
-     * @throws QueryException
-     */
-    public function __construct(QueryBuild $queryBuild, $table = '')
-    {
-
-        $table = $this->validateTable($table);
-
-        $this->queryBuild = $queryBuild;
-        $this->queryStructure = new QueryStructure();
-        $this->queryStructure->setElement(QueryStructure::TABLE, $table);
-        $this->queryStructure->setElement(QueryStructure::STATEMENT, $this->statement);
-        $this->queryStructure->setElement(QueryStructure::QUERY_TYPE, $this->queryBuild->getType());
-
-    }
-
-    /**
-     * @return mixed
-     */
-    public function getBindParams()
-    {
-        return $this->queryStructure->getElement(QueryStructure::BIND_PARAMS);
-    }
+	use Utilities, TableValidation, ColumnValidation;
+
+
+	/**
+	 * Statements
+	 */
+	const QUERY_STATEMENT_SELECT = 'SELECT';
+	const QUERY_STATEMENT_UPDATE = 'UPDATE';
+	const QUERY_STATEMENT_DELETE = 'DELETE';
+	const QUERY_STATEMENT_INSERT = 'INSERT';
+	const QUERY_STATEMENT_CUSTOM = 'CUSTOM';
+
+
+	/**
+	 * @var string
+	 */
+	protected $statement;
+
+	/**
+	 * @var QueryBuild
+	 */
+	protected $queryBuild;
+
+	/**
+	 * @var QueryStructure
+	 */
+	protected $queryStructure;
+
+	/**
+	 * @var array
+	 */
+	protected $usedInstanceIds = [];
+
+	/**
+	 * @var string
+	 */
+	protected $tablePrefix;
+
+
+	/**
+	 * QueryStatement constructor.
+	 * @param QueryBuild $queryBuild
+	 * @param string|QuerySelect $table
+	 * @throws QueryException
+	 */
+	public function __construct(QueryBuild $queryBuild, $table = '')
+	{
+
+		$table = $this->validateTable($table);
+
+		$this->queryBuild = $queryBuild;
+		$this->queryStructure = new QueryStructure();
+		$this->queryStructure->setElement(QueryStructure::TABLE, $table);
+		$this->queryStructure->setElement(QueryStructure::STATEMENT, $this->statement);
+		$this->queryStructure->setElement(QueryStructure::QUERY_TYPE, $this->queryBuild->getType());
+
+	}
+
+	/**
+	 * @return mixed
+	 */
+	public function getBindParams()
+	{
+		return $this->queryStructure->getElement(QueryStructure::BIND_PARAMS);
+	}
 
 
 }
\ No newline at end of file

Spacing +7 added lines, -7 removed lines

@@ -49,7 +49,7 @@ 
     /**
      * @var array
      */
-    protected $usedInstanceIds = [];
+    protected $usedInstanceIds = [ ];
 
     /**
      * @var string
@@ -63,16 +63,16 @@ 
      * @param string|QuerySelect $table
      * @throws QueryException
      */
-    public function __construct(QueryBuild $queryBuild, $table = '')
+    public function __construct( QueryBuild $queryBuild, $table = '' )
     {
 
-        $table = $this->validateTable($table);
+        $table = $this->validateTable( $table );
 
         $this->queryBuild = $queryBuild;
         $this->queryStructure = new QueryStructure();
-        $this->queryStructure->setElement(QueryStructure::TABLE, $table);
-        $this->queryStructure->setElement(QueryStructure::STATEMENT, $this->statement);
-        $this->queryStructure->setElement(QueryStructure::QUERY_TYPE, $this->queryBuild->getType());
+        $this->queryStructure->setElement( QueryStructure::TABLE, $table );
+        $this->queryStructure->setElement( QueryStructure::STATEMENT, $this->statement );
+        $this->queryStructure->setElement( QueryStructure::QUERY_TYPE, $this->queryBuild->getType() );
 
     }
 
@@ -81,7 +81,7 @@ 
      */
     public function getBindParams()
     {
-        return $this->queryStructure->getElement(QueryStructure::BIND_PARAMS);
+        return $this->queryStructure->getElement( QueryStructure::BIND_PARAMS );
     }
 
 

src/Statements/QueryStatementInterface.php

Indentation +9 added lines, -9 removed lines

@@ -11,17 +11,17 @@
 interface QueryStatementInterface
 {
 
-    const REPLACEMENT_NONE = 0;
-    const REPLACEMENT_VALUES = 1;
+	const REPLACEMENT_NONE = 0;
+	const REPLACEMENT_VALUES = 1;
 
-    /**
-     * @param bool $replacement
-     * @return string
-     */
-    public function getSyntax($replacement = self::REPLACEMENT_NONE);
+	/**
+	 * @param bool $replacement
+	 * @return string
+	 */
+	public function getSyntax($replacement = self::REPLACEMENT_NONE);
 
-    public function execute();
+	public function execute();
 
-    public function getBindParams();
+	public function getBindParams();
 
 }
\ No newline at end of file

Spacing +1 added lines, -1 removed lines

@@ -18,7 +18,7 @@
      * @param bool $replacement
      * @return string
      */
-    public function getSyntax($replacement = self::REPLACEMENT_NONE);
+    public function getSyntax( $replacement = self::REPLACEMENT_NONE );
 
     public function execute();
 

src/Statements/QueryDelete.php

Indentation +75 added lines, -75 removed lines

@@ -27,81 +27,81 @@
 class QueryDelete extends QueryStatement implements QueryStatementInterface
 {
 
-    use Limit, Where, WhereAndHavingBuilder, Replacement, OrderBy, SetFields, Ignore, DefaultPriority, LowPriority, Utilities;
-
-    /**
-     * @var string
-     */
-    protected $statement = self::QUERY_STATEMENT_DELETE;
-
-
-    /**
-     * QueryDelete constructor.
-     * @param QueryBuild $queryBuild
-     * @param string $table
-     */
-    public function __construct(QueryBuild $queryBuild, $table = null)
-    {
-        parent::__construct($queryBuild, $table);
-    }
-
-    public function getSyntax($replacement = self::REPLACEMENT_NONE)
-    {
-        $syntax = array();
-
-        /**
-         *  Explain
-         */
-        $syntax[] = $this->getExplainSyntax();
-
-        /**
-         * UPDATE statement
-         */
-        $syntax[] = $this->statement;
-
-        /**
-         * PRIORITY
-         */
-        $syntax[] = $this->queryStructure->getElement(QueryStructure::PRIORITY);
-
-        /**
-         * TABLE update
-         */
-        $syntax[] = 'FROM ' . $this->queryStructure->getElement(QueryStructure::TABLE);
-
-        /**
-         * WHERE clause
-         */
-        $syntax[] = $this->getWhereSyntax();
-
-        /**
-         * ORDER BY clause
-         */
-        $syntax[] = $this->getOrderBySyntax();
-
-        /**
-         * LIMIT clause
-         */
-        $syntax[] = $this->getLimitSyntax();
-
-        $syntax = implode(' ', $syntax);
-
-        return $this->getSyntaxReplace($syntax, $replacement);
-    }
-
-    /**
-     * @return array|int|null
-     * @throws QueryException
-     */
-    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);
-
-        return DbService::getInstance()->query($this->getSyntax(), $this->queryStructure->getElement(QueryStructure::BIND_PARAMS));
-
-    }
+	use Limit, Where, WhereAndHavingBuilder, Replacement, OrderBy, SetFields, Ignore, DefaultPriority, LowPriority, Utilities;
+
+	/**
+	 * @var string
+	 */
+	protected $statement = self::QUERY_STATEMENT_DELETE;
+
+
+	/**
+	 * QueryDelete constructor.
+	 * @param QueryBuild $queryBuild
+	 * @param string $table
+	 */
+	public function __construct(QueryBuild $queryBuild, $table = null)
+	{
+		parent::__construct($queryBuild, $table);
+	}
+
+	public function getSyntax($replacement = self::REPLACEMENT_NONE)
+	{
+		$syntax = array();
+
+		/**
+		 *  Explain
+		 */
+		$syntax[] = $this->getExplainSyntax();
+
+		/**
+		 * UPDATE statement
+		 */
+		$syntax[] = $this->statement;
+
+		/**
+		 * PRIORITY
+		 */
+		$syntax[] = $this->queryStructure->getElement(QueryStructure::PRIORITY);
+
+		/**
+		 * TABLE update
+		 */
+		$syntax[] = 'FROM ' . $this->queryStructure->getElement(QueryStructure::TABLE);
+
+		/**
+		 * WHERE clause
+		 */
+		$syntax[] = $this->getWhereSyntax();
+
+		/**
+		 * ORDER BY clause
+		 */
+		$syntax[] = $this->getOrderBySyntax();
+
+		/**
+		 * LIMIT clause
+		 */
+		$syntax[] = $this->getLimitSyntax();
+
+		$syntax = implode(' ', $syntax);
+
+		return $this->getSyntaxReplace($syntax, $replacement);
+	}
+
+	/**
+	 * @return array|int|null
+	 * @throws QueryException
+	 */
+	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);
+
+		return DbService::getInstance()->query($this->getSyntax(), $this->queryStructure->getElement(QueryStructure::BIND_PARAMS));
+
+	}
 
 
 }
\ No newline at end of file

Spacing +15 added lines, -15 removed lines

@@ -40,53 +40,53 @@ 
      * @param QueryBuild $queryBuild
      * @param string $table
      */
-    public function __construct(QueryBuild $queryBuild, $table = null)
+    public function __construct( QueryBuild $queryBuild, $table = null )
     {
-        parent::__construct($queryBuild, $table);
+        parent::__construct( $queryBuild, $table );
     }
 
-    public function getSyntax($replacement = self::REPLACEMENT_NONE)
+    public function getSyntax( $replacement = self::REPLACEMENT_NONE )
     {
         $syntax = array();
 
         /**
          *  Explain
          */
-        $syntax[] = $this->getExplainSyntax();
+        $syntax[ ] = $this->getExplainSyntax();
 
         /**
          * UPDATE statement
          */
-        $syntax[] = $this->statement;
+        $syntax[ ] = $this->statement;
 
         /**
          * PRIORITY
          */
-        $syntax[] = $this->queryStructure->getElement(QueryStructure::PRIORITY);
+        $syntax[ ] = $this->queryStructure->getElement( QueryStructure::PRIORITY );
 
         /**
          * TABLE update
          */
-        $syntax[] = 'FROM ' . $this->queryStructure->getElement(QueryStructure::TABLE);
+        $syntax[ ] = 'FROM ' . $this->queryStructure->getElement( QueryStructure::TABLE );
 
         /**
          * WHERE clause
          */
-        $syntax[] = $this->getWhereSyntax();
+        $syntax[ ] = $this->getWhereSyntax();
 
         /**
          * ORDER BY clause
          */
-        $syntax[] = $this->getOrderBySyntax();
+        $syntax[ ] = $this->getOrderBySyntax();
 
         /**
          * LIMIT clause
          */
-        $syntax[] = $this->getLimitSyntax();
+        $syntax[ ] = $this->getLimitSyntax();
 
-        $syntax = implode(' ', $syntax);
+        $syntax = implode( ' ', $syntax );
 
-        return $this->getSyntaxReplace($syntax, $replacement);
+        return $this->getSyntaxReplace( $syntax, $replacement );
     }
 
     /**
@@ -96,10 +96,10 @@ 
     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));
+        return DbService::getInstance()->query( $this->getSyntax(), $this->queryStructure->getElement( QueryStructure::BIND_PARAMS ) );
 
     }
 

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

Indentation +106 added lines, -106 removed lines

@@ -11,111 +11,111 @@
 class DbLog
 {
 
-    private static $instance;
-
-
-    /**
-     * @var string
-     */
-    private $path;
-
-    /**
-     * @var \DateTimeZone
-     */
-    private $dateTimeZone;
-
-
-    /**
-     * DbLog constructor.
-     */
-    private function __construct()
-    {
-        $this->dateTimeZone = new \DateTimeZone('Europe/Bucharest');
-    }
-
-
-    /**
-     * @param $query
-     * @param $duration
-     */
-    public function writeQueryDuration($query, $duration)
-    {
-        $backtrace = end(debug_backtrace());
-        $location = $backtrace['file'] . " Line: " . $backtrace['line'];
-
-        $this->path = DbConfig::getInstance()->getLogPathQueryDuration(); //my comments
-        $message = "Duration: " . round($duration, 5) . "\r\n";
-        $message .= "Location: $location\r\n";
-        $message .= "Query: $query";
-        $this->write($message);
-    }
-
-    /**
-     * @param $query
-     * @param $duration
-     */
-    public function writeQueryErros($query, $code, $error)
-    {
-        $backtrace = end(debug_backtrace());
-        $location = $backtrace['file'] . " Line: " . $backtrace['line'];
-
-        $this->path = DbConfig::getInstance()->getLogPathErrors(); //my comments
-        $message = "Query: $query" . "\r\n";
-        $message .= "Location: $location\r\n";
-        $message .= "Error code : " . $code . "\r\n";
-        $message .= "" . $error;
-
-        $this->write($message);
-    }
-
-
-    public function write($message)
-    {
-
-        $date = new \DateTime();
-        $date->setTimezone($this->dateTimeZone);
-
-        $log = $this->path . $date->format('Y-m-d') . ".txt";
-        $time = $date->format('H:i:s');
-
-        $messageFormat = "[$time]\r\n$message\r\n\r\n";
-
-        if (is_dir($this->path)) {
-            if (!file_exists($log)) {
-                $fh = fopen($log, 'a+');
-                fwrite($fh, $messageFormat);
-                fclose($fh);
-            } else {
-                $this->edit($log, $messageFormat);
-            }
-        } else {
-            if (mkdir($this->path, 0777) === true) {
-                $this->write($message);
-            }
-        }
-    }
-
-
-    /**
-     * @param string $log
-     * @param  string $message
-     */
-    private function edit($log, $message)
-    {
-        file_put_contents($log, $message, FILE_APPEND);
-    }
-
-
-    /**
-     * @return DbLog
-     */
-    public static function getInstance()
-    {
-        if (null === self::$instance) {
-            self::$instance = new self();
-        }
-
-        return self::$instance;
-    }
+	private static $instance;
+
+
+	/**
+	 * @var string
+	 */
+	private $path;
+
+	/**
+	 * @var \DateTimeZone
+	 */
+	private $dateTimeZone;
+
+
+	/**
+	 * DbLog constructor.
+	 */
+	private function __construct()
+	{
+		$this->dateTimeZone = new \DateTimeZone('Europe/Bucharest');
+	}
+
+
+	/**
+	 * @param $query
+	 * @param $duration
+	 */
+	public function writeQueryDuration($query, $duration)
+	{
+		$backtrace = end(debug_backtrace());
+		$location = $backtrace['file'] . " Line: " . $backtrace['line'];
+
+		$this->path = DbConfig::getInstance()->getLogPathQueryDuration(); //my comments
+		$message = "Duration: " . round($duration, 5) . "\r\n";
+		$message .= "Location: $location\r\n";
+		$message .= "Query: $query";
+		$this->write($message);
+	}
+
+	/**
+	 * @param $query
+	 * @param $duration
+	 */
+	public function writeQueryErros($query, $code, $error)
+	{
+		$backtrace = end(debug_backtrace());
+		$location = $backtrace['file'] . " Line: " . $backtrace['line'];
+
+		$this->path = DbConfig::getInstance()->getLogPathErrors(); //my comments
+		$message = "Query: $query" . "\r\n";
+		$message .= "Location: $location\r\n";
+		$message .= "Error code : " . $code . "\r\n";
+		$message .= "" . $error;
+
+		$this->write($message);
+	}
+
+
+	public function write($message)
+	{
+
+		$date = new \DateTime();
+		$date->setTimezone($this->dateTimeZone);
+
+		$log = $this->path . $date->format('Y-m-d') . ".txt";
+		$time = $date->format('H:i:s');
+
+		$messageFormat = "[$time]\r\n$message\r\n\r\n";
+
+		if (is_dir($this->path)) {
+			if (!file_exists($log)) {
+				$fh = fopen($log, 'a+');
+				fwrite($fh, $messageFormat);
+				fclose($fh);
+			} else {
+				$this->edit($log, $messageFormat);
+			}
+		} else {
+			if (mkdir($this->path, 0777) === true) {
+				$this->write($message);
+			}
+		}
+	}
+
+
+	/**
+	 * @param string $log
+	 * @param  string $message
+	 */
+	private function edit($log, $message)
+	{
+		file_put_contents($log, $message, FILE_APPEND);
+	}
+
+
+	/**
+	 * @return DbLog
+	 */
+	public static function getInstance()
+	{
+		if (null === self::$instance) {
+			self::$instance = new self();
+		}
+
+		return self::$instance;
+	}
 
 }
\ No newline at end of file

Spacing +25 added lines, -25 removed lines

@@ -30,7 +30,7 @@ 
      */
     private function __construct()
     {
-        $this->dateTimeZone = new \DateTimeZone('Europe/Bucharest');
+        $this->dateTimeZone = new \DateTimeZone( 'Europe/Bucharest' );
     }
 
 
@@ -38,26 +38,26 @@ 
      * @param $query
      * @param $duration
      */
-    public function writeQueryDuration($query, $duration)
+    public function writeQueryDuration( $query, $duration )
     {
-        $backtrace = end(debug_backtrace());
-        $location = $backtrace['file'] . " Line: " . $backtrace['line'];
+        $backtrace = end( debug_backtrace() );
+        $location = $backtrace[ 'file' ] . " Line: " . $backtrace[ 'line' ];
 
         $this->path = DbConfig::getInstance()->getLogPathQueryDuration(); //my comments
-        $message = "Duration: " . round($duration, 5) . "\r\n";
+        $message = "Duration: " . round( $duration, 5 ) . "\r\n";
         $message .= "Location: $location\r\n";
         $message .= "Query: $query";
-        $this->write($message);
+        $this->write( $message );
     }
 
     /**
      * @param $query
      * @param $duration
      */
-    public function writeQueryErros($query, $code, $error)
+    public function writeQueryErros( $query, $code, $error )
     {
-        $backtrace = end(debug_backtrace());
-        $location = $backtrace['file'] . " Line: " . $backtrace['line'];
+        $backtrace = end( debug_backtrace() );
+        $location = $backtrace[ 'file' ] . " Line: " . $backtrace[ 'line' ];
 
         $this->path = DbConfig::getInstance()->getLogPathErrors(); //my comments
         $message = "Query: $query" . "\r\n";
@@ -65,32 +65,32 @@ 
         $message .= "Error code : " . $code . "\r\n";
         $message .= "" . $error;
 
-        $this->write($message);
+        $this->write( $message );
     }
 
 
-    public function write($message)
+    public function write( $message )
     {
 
         $date = new \DateTime();
-        $date->setTimezone($this->dateTimeZone);
+        $date->setTimezone( $this->dateTimeZone );
 
-        $log = $this->path . $date->format('Y-m-d') . ".txt";
-        $time = $date->format('H:i:s');
+        $log = $this->path . $date->format( 'Y-m-d' ) . ".txt";
+        $time = $date->format( 'H:i:s' );
 
         $messageFormat = "[$time]\r\n$message\r\n\r\n";
 
-        if (is_dir($this->path)) {
-            if (!file_exists($log)) {
-                $fh = fopen($log, 'a+');
-                fwrite($fh, $messageFormat);
-                fclose($fh);
+        if ( is_dir( $this->path ) ) {
+            if ( !file_exists( $log ) ) {
+                $fh = fopen( $log, 'a+' );
+                fwrite( $fh, $messageFormat );
+                fclose( $fh );
             } else {
-                $this->edit($log, $messageFormat);
+                $this->edit( $log, $messageFormat );
             }
         } else {
-            if (mkdir($this->path, 0777) === true) {
-                $this->write($message);
+            if ( mkdir( $this->path, 0777 ) === true ) {
+                $this->write( $message );
             }
         }
     }
@@ -100,9 +100,9 @@ 
      * @param string $log
      * @param  string $message
      */
-    private function edit($log, $message)
+    private function edit( $log, $message )
     {
-        file_put_contents($log, $message, FILE_APPEND);
+        file_put_contents( $log, $message, FILE_APPEND );
     }
 
 
@@ -111,7 +111,7 @@ 
      */
     public static function getInstance()
     {
-        if (null === self::$instance) {
+        if ( null === self::$instance ) {
             self::$instance = new self();
         }
 

src/DB/DbService.php

Indentation +246 added lines, -246 removed lines

@@ -11,251 +11,251 @@
 class DbService
 {
 
-    const QUERY_TYPE_INSERT = 'INSERT';
-    const QUERY_TYPE_DELETE = 'DELETE';
-    const QUERY_TYPE_UPDATE = 'UPDATE';
-    const QUERY_TYPE_SELECT = 'SELECT';
-    const QUERY_TYPE_REPLACE = 'REPLACE';
-    const QUERY_TYPE_SHOW = 'SHOW';
-    const QUERY_TYPE_DESC = 'DESC';
-    const QUERY_TYPE_EMPTY = 'EMPTY';
-    const QUERY_TYPE_OTHER = 'OTHER';
-    const QUERY_TYPE_EXPLAIN = 'EXPLAIN';
-
-    const ON_ERROR_THROW_EXCEPTION = 1;
-    const ON_ERROR_RETURN_ERROR = 2;
-
-    /**
-     * @var DbService
-     */
-    private static $instance;
-
-    /**
-     * @var \PDO
-     */
-    private $pdo;
-
-    /**
-     * @var \PDOStatement
-     */
-    private $sQuery;
-
-    /**
-     * @var array
-     */
-    private $parameters = [];
-
-    /**
-     * @return DbService
-     */
-    public static function getInstance()
-    {
-        if (null === self::$instance) {
-            self::$instance = new self();
-        }
-
-        return self::$instance;
-    }
-
-    /**
-     * @param string $query
-     * @param array $params
-     * @param int $fetchMode
-     * @return array|int|null
-     */
-    public function query($query, $params = null, $fetchMode = \PDO::FETCH_ASSOC)
-    {
-
-        $query = trim(str_replace("\r", " ", $query));
-        $statement = self::getQueryStatement($query);
-
-        $this->queryInit($query, $params);
-
-        if ($statement === self::QUERY_TYPE_SELECT || $statement === self::QUERY_TYPE_SHOW || $statement === self::QUERY_TYPE_DESC || $statement === self::QUERY_TYPE_EXPLAIN) {
-            return $this->sQuery->fetchAll($fetchMode);
-        } elseif ($statement === self::QUERY_TYPE_INSERT || $statement === self::QUERY_TYPE_UPDATE || $statement === self::QUERY_TYPE_DELETE) {
-            return $this->sQuery->rowCount();
-        } else {
-
-            return NULL;
-        }
-    }
-
-    /**
-     * @param $queryString
-     * @return string
-     */
-    public static function getQueryStatement($queryString)
-    {
-        $queryString = trim($queryString);
-
-        if ($queryString === '') {
-            return self::QUERY_TYPE_EMPTY;
-        }
-
-        if (preg_match('/^(select|insert|update|delete|replace|show|desc|explain)[\s]+/i', $queryString, $matches)) {
-            switch (strtolower($matches[1])) {
-                case 'select':
-                    return self::QUERY_TYPE_SELECT;
-                case 'insert':
-                    return self::QUERY_TYPE_INSERT;
-                case 'update':
-                    return self::QUERY_TYPE_UPDATE;
-                case 'delete':
-                    return self::QUERY_TYPE_DELETE;
-                case 'replace':
-                    return self::QUERY_TYPE_REPLACE;
-                case 'explain':
-                    return self::QUERY_TYPE_EXPLAIN;
-                default:
-                    return self::QUERY_TYPE_OTHER;
-            }
-        } else {
-            return self::QUERY_TYPE_OTHER;
-        }
-    }
-
-    /**
-     * @param $query
-     * @param array $parameters
-     * @throws DbException
-     */
-    private function queryInit($query, $parameters = [])
-    {
-        $this->pdo = DbConnect::getInstance()->getConnection(self::getQueryStatement($query));
-        $startQueryTime = microtime(true);
-
-        try {
-
-            /**
-             * Prepare query
-             */
-            $this->sQuery = $this->pdo->prepare($query);
-
-            /**
-             * Add parameters to the parameter array
-             */
-            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])) {
-                        $type = \PDO::PARAM_BOOL;
-                    } elseif (is_null($value[1])) {
-                        $type = \PDO::PARAM_NULL;
-                    } else {
-                        $type = \PDO::PARAM_STR;
-                    }
-                    $this->sQuery->bindValue($value[0], $value[1], $type);
-                }
-            }
-
-            $this->sQuery->execute();
-
-            if (DbConfig::getInstance()->isEnableLogQueryDuration()) {
-                $duration = microtime(true) - $startQueryTime;
-                DbLog::getInstance()->writeQueryDuration($query, $duration);
-            }
-
-        } catch (\PDOException $e) {
-            if (DbConfig::getInstance()->isEnableLogErrors()) {
-                DbLog::getInstance()->writeQueryErros($query, $e->getCode(), $e->getMessage());
-            }
-            throw new DbException('Database error!', DbException::DB_QUERY_ERROR);
-        }
-
-        /**
-         * Reset the parameters
-         */
-        $this->parameters = array();
-    }
-
-    /**
-     * @param array $arr
-     * @return bool
-     */
-    public static function isArrayAssoc(array $arr)
-    {
-        if (array() === $arr)
-            return false;
-
-        return array_keys($arr) !== range(0, count($arr) - 1);
-    }
-
-    public function bindMore($parray)
-    {
-        if (!count($this->parameters) && is_array($parray)) {
-            $columns = array_keys($parray);
-            foreach ($columns as $i => &$column) {
-                $this->bind($column, $parray[ $column ]);
-            }
-        }
-    }
-
-    public function bind($para, $value)
-    {
-        $this->parameters[ sizeof($this->parameters) ] = [":" . $para, $value];
-    }
-
-    /**
-     * @param $query
-     * @param array $params
-     * @return array|null
-     */
-    public function column($query, $params = null)
-    {
-        $this->queryInit($query, $params);
-
-        $query = trim(str_replace("\r", " ", $query));
-        $statement = self::getQueryStatement($query);
-
-        if ($statement === self::QUERY_TYPE_EXPLAIN)
-            return $this->sQuery->fetchAll(\PDO::FETCH_ASSOC);
-
-        $Columns = $this->sQuery->fetchAll(\PDO::FETCH_NUM);
-
-        $column = null;
-
-        foreach ($Columns as $cells) {
-            $column[] = $cells[0];
-        }
-
-        return $column;
-    }
-
-    public function row($query, $params = null, $fetchmode = \PDO::FETCH_ASSOC)
-    {
-        $this->queryInit($query, $params);
-
-        $query = trim(str_replace("\r", " ", $query));
-        $statement = self::getQueryStatement($query);
-
-        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,
-
-        return $result;
-    }
-
-    public function single($query, $params = null)
-    {
-        $this->queryInit($query, $params);
-        $result = $this->sQuery->fetchColumn();
-        $this->sQuery->closeCursor(); // Frees up the connection to the server so that other SQL statements may be issued
-
-        return $result;
-    }
-
-    public function CloseConnection()
-    {
-        $this->pdo = null;
-    }
+	const QUERY_TYPE_INSERT = 'INSERT';
+	const QUERY_TYPE_DELETE = 'DELETE';
+	const QUERY_TYPE_UPDATE = 'UPDATE';
+	const QUERY_TYPE_SELECT = 'SELECT';
+	const QUERY_TYPE_REPLACE = 'REPLACE';
+	const QUERY_TYPE_SHOW = 'SHOW';
+	const QUERY_TYPE_DESC = 'DESC';
+	const QUERY_TYPE_EMPTY = 'EMPTY';
+	const QUERY_TYPE_OTHER = 'OTHER';
+	const QUERY_TYPE_EXPLAIN = 'EXPLAIN';
+
+	const ON_ERROR_THROW_EXCEPTION = 1;
+	const ON_ERROR_RETURN_ERROR = 2;
+
+	/**
+	 * @var DbService
+	 */
+	private static $instance;
+
+	/**
+	 * @var \PDO
+	 */
+	private $pdo;
+
+	/**
+	 * @var \PDOStatement
+	 */
+	private $sQuery;
+
+	/**
+	 * @var array
+	 */
+	private $parameters = [];
+
+	/**
+	 * @return DbService
+	 */
+	public static function getInstance()
+	{
+		if (null === self::$instance) {
+			self::$instance = new self();
+		}
+
+		return self::$instance;
+	}
+
+	/**
+	 * @param string $query
+	 * @param array $params
+	 * @param int $fetchMode
+	 * @return array|int|null
+	 */
+	public function query($query, $params = null, $fetchMode = \PDO::FETCH_ASSOC)
+	{
+
+		$query = trim(str_replace("\r", " ", $query));
+		$statement = self::getQueryStatement($query);
+
+		$this->queryInit($query, $params);
+
+		if ($statement === self::QUERY_TYPE_SELECT || $statement === self::QUERY_TYPE_SHOW || $statement === self::QUERY_TYPE_DESC || $statement === self::QUERY_TYPE_EXPLAIN) {
+			return $this->sQuery->fetchAll($fetchMode);
+		} elseif ($statement === self::QUERY_TYPE_INSERT || $statement === self::QUERY_TYPE_UPDATE || $statement === self::QUERY_TYPE_DELETE) {
+			return $this->sQuery->rowCount();
+		} else {
+
+			return NULL;
+		}
+	}
+
+	/**
+	 * @param $queryString
+	 * @return string
+	 */
+	public static function getQueryStatement($queryString)
+	{
+		$queryString = trim($queryString);
+
+		if ($queryString === '') {
+			return self::QUERY_TYPE_EMPTY;
+		}
+
+		if (preg_match('/^(select|insert|update|delete|replace|show|desc|explain)[\s]+/i', $queryString, $matches)) {
+			switch (strtolower($matches[1])) {
+				case 'select':
+					return self::QUERY_TYPE_SELECT;
+				case 'insert':
+					return self::QUERY_TYPE_INSERT;
+				case 'update':
+					return self::QUERY_TYPE_UPDATE;
+				case 'delete':
+					return self::QUERY_TYPE_DELETE;
+				case 'replace':
+					return self::QUERY_TYPE_REPLACE;
+				case 'explain':
+					return self::QUERY_TYPE_EXPLAIN;
+				default:
+					return self::QUERY_TYPE_OTHER;
+			}
+		} else {
+			return self::QUERY_TYPE_OTHER;
+		}
+	}
+
+	/**
+	 * @param $query
+	 * @param array $parameters
+	 * @throws DbException
+	 */
+	private function queryInit($query, $parameters = [])
+	{
+		$this->pdo = DbConnect::getInstance()->getConnection(self::getQueryStatement($query));
+		$startQueryTime = microtime(true);
+
+		try {
+
+			/**
+			 * Prepare query
+			 */
+			$this->sQuery = $this->pdo->prepare($query);
+
+			/**
+			 * Add parameters to the parameter array
+			 */
+			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])) {
+						$type = \PDO::PARAM_BOOL;
+					} elseif (is_null($value[1])) {
+						$type = \PDO::PARAM_NULL;
+					} else {
+						$type = \PDO::PARAM_STR;
+					}
+					$this->sQuery->bindValue($value[0], $value[1], $type);
+				}
+			}
+
+			$this->sQuery->execute();
+
+			if (DbConfig::getInstance()->isEnableLogQueryDuration()) {
+				$duration = microtime(true) - $startQueryTime;
+				DbLog::getInstance()->writeQueryDuration($query, $duration);
+			}
+
+		} catch (\PDOException $e) {
+			if (DbConfig::getInstance()->isEnableLogErrors()) {
+				DbLog::getInstance()->writeQueryErros($query, $e->getCode(), $e->getMessage());
+			}
+			throw new DbException('Database error!', DbException::DB_QUERY_ERROR);
+		}
+
+		/**
+		 * Reset the parameters
+		 */
+		$this->parameters = array();
+	}
+
+	/**
+	 * @param array $arr
+	 * @return bool
+	 */
+	public static function isArrayAssoc(array $arr)
+	{
+		if (array() === $arr)
+			return false;
+
+		return array_keys($arr) !== range(0, count($arr) - 1);
+	}
+
+	public function bindMore($parray)
+	{
+		if (!count($this->parameters) && is_array($parray)) {
+			$columns = array_keys($parray);
+			foreach ($columns as $i => &$column) {
+				$this->bind($column, $parray[ $column ]);
+			}
+		}
+	}
+
+	public function bind($para, $value)
+	{
+		$this->parameters[ sizeof($this->parameters) ] = [":" . $para, $value];
+	}
+
+	/**
+	 * @param $query
+	 * @param array $params
+	 * @return array|null
+	 */
+	public function column($query, $params = null)
+	{
+		$this->queryInit($query, $params);
+
+		$query = trim(str_replace("\r", " ", $query));
+		$statement = self::getQueryStatement($query);
+
+		if ($statement === self::QUERY_TYPE_EXPLAIN)
+			return $this->sQuery->fetchAll(\PDO::FETCH_ASSOC);
+
+		$Columns = $this->sQuery->fetchAll(\PDO::FETCH_NUM);
+
+		$column = null;
+
+		foreach ($Columns as $cells) {
+			$column[] = $cells[0];
+		}
+
+		return $column;
+	}
+
+	public function row($query, $params = null, $fetchmode = \PDO::FETCH_ASSOC)
+	{
+		$this->queryInit($query, $params);
+
+		$query = trim(str_replace("\r", " ", $query));
+		$statement = self::getQueryStatement($query);
+
+		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,
+
+		return $result;
+	}
+
+	public function single($query, $params = null)
+	{
+		$this->queryInit($query, $params);
+		$result = $this->sQuery->fetchColumn();
+		$this->sQuery->closeCursor(); // Frees up the connection to the server so that other SQL statements may be issued
+
+		return $result;
+	}
+
+	public function CloseConnection()
+	{
+		$this->pdo = null;
+	}
 
 }
\ No newline at end of file

Spacing +64 added lines, -64 removed lines

@@ -43,14 +43,14 @@ 
     /**
      * @var array
      */
-    private $parameters = [];
+    private $parameters = [ ];
 
     /**
      * @return DbService
      */
     public static function getInstance()
     {
-        if (null === self::$instance) {
+        if ( null === self::$instance ) {
             self::$instance = new self();
         }
 
@@ -63,17 +63,17 @@ 
      * @param int $fetchMode
      * @return array|int|null
      */
-    public function query($query, $params = null, $fetchMode = \PDO::FETCH_ASSOC)
+    public function query( $query, $params = null, $fetchMode = \PDO::FETCH_ASSOC )
     {
 
-        $query = trim(str_replace("\r", " ", $query));
-        $statement = self::getQueryStatement($query);
+        $query = trim( str_replace( "\r", " ", $query ) );
+        $statement = self::getQueryStatement( $query );
 
-        $this->queryInit($query, $params);
+        $this->queryInit( $query, $params );
 
-        if ($statement === self::QUERY_TYPE_SELECT || $statement === self::QUERY_TYPE_SHOW || $statement === self::QUERY_TYPE_DESC || $statement === self::QUERY_TYPE_EXPLAIN) {
-            return $this->sQuery->fetchAll($fetchMode);
-        } elseif ($statement === self::QUERY_TYPE_INSERT || $statement === self::QUERY_TYPE_UPDATE || $statement === self::QUERY_TYPE_DELETE) {
+        if ( $statement === self::QUERY_TYPE_SELECT || $statement === self::QUERY_TYPE_SHOW || $statement === self::QUERY_TYPE_DESC || $statement === self::QUERY_TYPE_EXPLAIN ) {
+            return $this->sQuery->fetchAll( $fetchMode );
+        } elseif ( $statement === self::QUERY_TYPE_INSERT || $statement === self::QUERY_TYPE_UPDATE || $statement === self::QUERY_TYPE_DELETE ) {
             return $this->sQuery->rowCount();
         } else {
 
@@ -85,16 +85,16 @@ 
      * @param $queryString
      * @return string
      */
-    public static function getQueryStatement($queryString)
+    public static function getQueryStatement( $queryString )
     {
-        $queryString = trim($queryString);
+        $queryString = trim( $queryString );
 
-        if ($queryString === '') {
+        if ( $queryString === '' ) {
             return self::QUERY_TYPE_EMPTY;
         }
 
-        if (preg_match('/^(select|insert|update|delete|replace|show|desc|explain)[\s]+/i', $queryString, $matches)) {
-            switch (strtolower($matches[1])) {
+        if ( preg_match( '/^(select|insert|update|delete|replace|show|desc|explain)[\s]+/i', $queryString, $matches ) ) {
+            switch ( strtolower( $matches[ 1 ] ) ) {
                 case 'select':
                     return self::QUERY_TYPE_SELECT;
                 case 'insert':
@@ -120,53 +120,53 @@ 
      * @param array $parameters
      * @throws DbException
      */
-    private function queryInit($query, $parameters = [])
+    private function queryInit( $query, $parameters = [ ] )
     {
-        $this->pdo = DbConnect::getInstance()->getConnection(self::getQueryStatement($query));
-        $startQueryTime = microtime(true);
+        $this->pdo = DbConnect::getInstance()->getConnection( self::getQueryStatement( $query ) );
+        $startQueryTime = microtime( true );
 
         try {
 
             /**
              * Prepare query
              */
-            $this->sQuery = $this->pdo->prepare($query);
+            $this->sQuery = $this->pdo->prepare( $query );
 
             /**
              * Add parameters to the parameter array
              */
-            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])) {
+            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 {
                         $type = \PDO::PARAM_STR;
                     }
-                    $this->sQuery->bindValue($value[0], $value[1], $type);
+                    $this->sQuery->bindValue( $value[ 0 ], $value[ 1 ], $type );
                 }
             }
 
             $this->sQuery->execute();
 
-            if (DbConfig::getInstance()->isEnableLogQueryDuration()) {
-                $duration = microtime(true) - $startQueryTime;
-                DbLog::getInstance()->writeQueryDuration($query, $duration);
+            if ( DbConfig::getInstance()->isEnableLogQueryDuration() ) {
+                $duration = microtime( true ) - $startQueryTime;
+                DbLog::getInstance()->writeQueryDuration( $query, $duration );
             }
 
-        } catch (\PDOException $e) {
-            if (DbConfig::getInstance()->isEnableLogErrors()) {
-                DbLog::getInstance()->writeQueryErros($query, $e->getCode(), $e->getMessage());
+        } catch ( \PDOException $e ) {
+            if ( DbConfig::getInstance()->isEnableLogErrors() ) {
+                DbLog::getInstance()->writeQueryErros( $query, $e->getCode(), $e->getMessage() );
             }
-            throw new DbException('Database error!', DbException::DB_QUERY_ERROR);
+            throw new DbException( 'Database error!', DbException::DB_QUERY_ERROR );
         }
 
         /**
@@ -179,27 +179,27 @@ 
      * @param array $arr
      * @return bool
      */
-    public static function isArrayAssoc(array $arr)
+    public static function isArrayAssoc( array $arr )
     {
-        if (array() === $arr)
+        if ( array() === $arr )
             return false;
 
-        return array_keys($arr) !== range(0, count($arr) - 1);
+        return array_keys( $arr ) !== range( 0, count( $arr ) - 1 );
     }
 
-    public function bindMore($parray)
+    public function bindMore( $parray )
     {
-        if (!count($this->parameters) && is_array($parray)) {
-            $columns = array_keys($parray);
-            foreach ($columns as $i => &$column) {
-                $this->bind($column, $parray[ $column ]);
+        if ( !count( $this->parameters ) && is_array( $parray ) ) {
+            $columns = array_keys( $parray );
+            foreach ( $columns as $i => &$column ) {
+                $this->bind( $column, $parray[ $column ] );
             }
         }
     }
 
-    public function bind($para, $value)
+    public function bind( $para, $value )
     {
-        $this->parameters[ sizeof($this->parameters) ] = [":" . $para, $value];
+        $this->parameters[ sizeof( $this->parameters ) ] = [ ":" . $para, $value ];
     }
 
     /**
@@ -207,46 +207,46 @@ 
      * @param array $params
      * @return array|null
      */
-    public function column($query, $params = null)
+    public function column( $query, $params = null )
     {
-        $this->queryInit($query, $params);
+        $this->queryInit( $query, $params );
 
-        $query = trim(str_replace("\r", " ", $query));
-        $statement = self::getQueryStatement($query);
+        $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);
+        $Columns = $this->sQuery->fetchAll( \PDO::FETCH_NUM );
 
         $column = null;
 
-        foreach ($Columns as $cells) {
-            $column[] = $cells[0];
+        foreach ( $Columns as $cells ) {
+            $column[ ] = $cells[ 0 ];
         }
 
         return $column;
     }
 
-    public function row($query, $params = null, $fetchmode = \PDO::FETCH_ASSOC)
+    public function row( $query, $params = null, $fetchmode = \PDO::FETCH_ASSOC )
     {
-        $this->queryInit($query, $params);
+        $this->queryInit( $query, $params );
 
-        $query = trim(str_replace("\r", " ", $query));
-        $statement = self::getQueryStatement($query);
+        $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);
+        $result = $this->sQuery->fetch( $fetchmode );
         $this->sQuery->closeCursor(); // Frees up the connection to the server so that other SQL statements may be issued,
 
         return $result;
     }
 
-    public function single($query, $params = null)
+    public function single( $query, $params = null )
     {
-        $this->queryInit($query, $params);
+        $this->queryInit( $query, $params );
         $result = $this->sQuery->fetchColumn();
         $this->sQuery->closeCursor(); // Frees up the connection to the server so that other SQL statements may be issued
 

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

Indentation +3 added lines, -3 removed lines

@@ -11,9 +11,9 @@
 class DbException extends \Exception
 {
 
-    const DB_CONNECTION_ERROR = 1;
-    const DB_QUERY_ERROR = 2;
-    const DB_ERROR_MASTER_DATA_CONNECTION_MISSING = 3;
+	const DB_CONNECTION_ERROR = 1;
+	const DB_QUERY_ERROR = 2;
+	const DB_ERROR_MASTER_DATA_CONNECTION_MISSING = 3;
 
 
 }
\ No newline at end of file

src/DB/DbConnect.php

Indentation +117 added lines, -117 removed lines

@@ -11,122 +11,122 @@
 class DbConnect
 {
 
-    private static $instance;
-
-    /**
-     * @var \PDO
-     */
-    private $pdoMaster;
-
-    /**
-     * @var \PDO
-     */
-    private $pdoSlave;
-
-    /**
-     * @var DbConfig
-     */
-    private $config;
-
-
-    /**
-     * DbConnect constructor.
-     */
-    private function __construct()
-    {
-        $this->config = DbConfig::getInstance();
-    }
-
-    /**
-     * @return \PDO
-     */
-    public function getMasterConnection()
-    {
-        if (!is_a($this->pdoMaster, \PDO::class))
-            $this->pdoMaster = $this->connect($this->config->getMasterDataConnect());
-
-        return $this->pdoMaster;
-    }
-
-    /**
-     * @return \PDO
-     */
-    public function getSlaveConnection()
-    {
-        if (!$this->config->getReplicationEnable())
-            return $this->getMasterConnection();
-
-        if (!is_a($this->pdoSlave, \PDO::class))
-            $this->pdoSlave = $this->connect($this->config->getSlaveDataConnect());
-
-        return $this->pdoSlave;
-    }
-
-    /**
-     * @param $statement
-     * @return \PDO
-     */
-    public function getConnection($statement)
-    {
-        $statement = trim(strtolower($statement));
-
-        if ($statement === DbService::QUERY_TYPE_SELECT)
-            return $this->getSlaveConnection();
-
-        return $this->getMasterConnection();
-    }
-
-    /**
-     * @param $string
-     * @return string
-     */
-    public function quote($string)
-    {
-        return $this->getMasterConnection()->quote($string);
-    }
-
-    /**
-     * @return string
-     */
-    public function lastInsertId()
-    {
-        return $this->getMasterConnection()->lastInsertId();
-    }
-
-    /**
-     * @param $dataConnect
-     * @return \PDO
-     */
-    private function connect($dataConnect)
-    {
-        $dsn = 'mysql:dbname=' . $dataConnect["dbname"] . ';host=' . $dataConnect["host"] . '';
-        try {
-
-            $pdo = new \PDO($dsn, $dataConnect["user"], $dataConnect["password"], array(\PDO::MYSQL_ATTR_INIT_COMMAND => "SET NAMES utf8"));
-
-            $pdo->setAttribute(\PDO::ATTR_ERRMODE, \PDO::ERRMODE_EXCEPTION);
-            $pdo->setAttribute(\PDO::ATTR_EMULATE_PREPARES, false);
-        } catch (\PDOException $e) {
-            if (DbConfig::getInstance()->isEnableLogErrors()) {
-                DbLog::getInstance()->writeQueryErros('Connection fail!', $e->getCode(), $e->getMessage());
-            }
-            throw new DbException('Database connection error!', DbException::DB_CONNECTION_ERROR);
-        }
-
-        return $pdo;
-    }
-
-
-    /**
-     * @return DbConnect
-     */
-    public static function getInstance()
-    {
-        if (null === self::$instance) {
-            self::$instance = new self();
-        }
-
-        return self::$instance;
-    }
+	private static $instance;
+
+	/**
+	 * @var \PDO
+	 */
+	private $pdoMaster;
+
+	/**
+	 * @var \PDO
+	 */
+	private $pdoSlave;
+
+	/**
+	 * @var DbConfig
+	 */
+	private $config;
+
+
+	/**
+	 * DbConnect constructor.
+	 */
+	private function __construct()
+	{
+		$this->config = DbConfig::getInstance();
+	}
+
+	/**
+	 * @return \PDO
+	 */
+	public function getMasterConnection()
+	{
+		if (!is_a($this->pdoMaster, \PDO::class))
+			$this->pdoMaster = $this->connect($this->config->getMasterDataConnect());
+
+		return $this->pdoMaster;
+	}
+
+	/**
+	 * @return \PDO
+	 */
+	public function getSlaveConnection()
+	{
+		if (!$this->config->getReplicationEnable())
+			return $this->getMasterConnection();
+
+		if (!is_a($this->pdoSlave, \PDO::class))
+			$this->pdoSlave = $this->connect($this->config->getSlaveDataConnect());
+
+		return $this->pdoSlave;
+	}
+
+	/**
+	 * @param $statement
+	 * @return \PDO
+	 */
+	public function getConnection($statement)
+	{
+		$statement = trim(strtolower($statement));
+
+		if ($statement === DbService::QUERY_TYPE_SELECT)
+			return $this->getSlaveConnection();
+
+		return $this->getMasterConnection();
+	}
+
+	/**
+	 * @param $string
+	 * @return string
+	 */
+	public function quote($string)
+	{
+		return $this->getMasterConnection()->quote($string);
+	}
+
+	/**
+	 * @return string
+	 */
+	public function lastInsertId()
+	{
+		return $this->getMasterConnection()->lastInsertId();
+	}
+
+	/**
+	 * @param $dataConnect
+	 * @return \PDO
+	 */
+	private function connect($dataConnect)
+	{
+		$dsn = 'mysql:dbname=' . $dataConnect["dbname"] . ';host=' . $dataConnect["host"] . '';
+		try {
+
+			$pdo = new \PDO($dsn, $dataConnect["user"], $dataConnect["password"], array(\PDO::MYSQL_ATTR_INIT_COMMAND => "SET NAMES utf8"));
+
+			$pdo->setAttribute(\PDO::ATTR_ERRMODE, \PDO::ERRMODE_EXCEPTION);
+			$pdo->setAttribute(\PDO::ATTR_EMULATE_PREPARES, false);
+		} catch (\PDOException $e) {
+			if (DbConfig::getInstance()->isEnableLogErrors()) {
+				DbLog::getInstance()->writeQueryErros('Connection fail!', $e->getCode(), $e->getMessage());
+			}
+			throw new DbException('Database connection error!', DbException::DB_CONNECTION_ERROR);
+		}
+
+		return $pdo;
+	}
+
+
+	/**
+	 * @return DbConnect
+	 */
+	public static function getInstance()
+	{
+		if (null === self::$instance) {
+			self::$instance = new self();
+		}
+
+		return self::$instance;
+	}
 
 }
\ No newline at end of file

Spacing +20 added lines, -20 removed lines

@@ -42,8 +42,8 @@ 
      */
     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 +53,11 @@ 
      */
     public function getSlaveConnection()
     {
-        if (!$this->config->getReplicationEnable())
+        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;
     }
@@ -66,11 +66,11 @@ 
      * @param $statement
      * @return \PDO
      */
-    public function getConnection($statement)
+    public function getConnection( $statement )
     {
-        $statement = trim(strtolower($statement));
+        $statement = trim( strtolower( $statement ) );
 
-        if ($statement === DbService::QUERY_TYPE_SELECT)
+        if ( $statement === DbService::QUERY_TYPE_SELECT )
             return $this->getSlaveConnection();
 
         return $this->getMasterConnection();
@@ -80,9 +80,9 @@ 
      * @param $string
      * @return string
      */
-    public function quote($string)
+    public function quote( $string )
     {
-        return $this->getMasterConnection()->quote($string);
+        return $this->getMasterConnection()->quote( $string );
     }
 
     /**
@@ -97,20 +97,20 @@ 
      * @param $dataConnect
      * @return \PDO
      */
-    private function connect($dataConnect)
+    private function connect( $dataConnect )
     {
-        $dsn = 'mysql:dbname=' . $dataConnect["dbname"] . ';host=' . $dataConnect["host"] . '';
+        $dsn = 'mysql:dbname=' . $dataConnect[ "dbname" ] . ';host=' . $dataConnect[ "host" ] . '';
         try {
 
-            $pdo = new \PDO($dsn, $dataConnect["user"], $dataConnect["password"], array(\PDO::MYSQL_ATTR_INIT_COMMAND => "SET NAMES utf8"));
+            $pdo = new \PDO( $dsn, $dataConnect[ "user" ], $dataConnect[ "password" ], array( \PDO::MYSQL_ATTR_INIT_COMMAND => "SET NAMES utf8" ) );
 
-            $pdo->setAttribute(\PDO::ATTR_ERRMODE, \PDO::ERRMODE_EXCEPTION);
-            $pdo->setAttribute(\PDO::ATTR_EMULATE_PREPARES, false);
-        } catch (\PDOException $e) {
-            if (DbConfig::getInstance()->isEnableLogErrors()) {
-                DbLog::getInstance()->writeQueryErros('Connection fail!', $e->getCode(), $e->getMessage());
+            $pdo->setAttribute( \PDO::ATTR_ERRMODE, \PDO::ERRMODE_EXCEPTION );
+            $pdo->setAttribute( \PDO::ATTR_EMULATE_PREPARES, false );
+        } catch ( \PDOException $e ) {
+            if ( DbConfig::getInstance()->isEnableLogErrors() ) {
+                DbLog::getInstance()->writeQueryErros( 'Connection fail!', $e->getCode(), $e->getMessage() );
             }
-            throw new DbException('Database connection error!', DbException::DB_CONNECTION_ERROR);
+            throw new DbException( 'Database connection error!', DbException::DB_CONNECTION_ERROR );
         }
 
         return $pdo;
@@ -122,7 +122,7 @@ 
      */
     public static function getInstance()
     {
-        if (null === self::$instance) {
+        if ( null === self::$instance ) {
             self::$instance = new self();
         }
 

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