adumitru68 / QueryBuilder

src/Statements/QueryUpdate.php

Indentation +85 added lines, -85 removed lines

@@ -26,89 +26,89 @@
 class QueryUpdate extends QueryStatement implements QueryStatementInterface
 {
 
-    use Limit, Where, WhereAndHavingBuilder, Replacement, OrderBy, SetFields, Ignore, DefaultPriority, LowPriority, Utilities;
-
-    /**
-     * @var string
-     */
-    protected $statement = self::QUERY_STATEMENT_UPDATE;
-
-
-    /**
-     * QueryUpdate 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);
-
-        /**
-         * IGNORE clause
-         */
-        $syntax[] = $this->queryStructure->getElement(QueryStructure::IGNORE) ? 'IGNORE' : '';
-
-        /**
-         * TABLE update
-         */
-        $syntax[] = $this->queryStructure->getElement(QueryStructure::TABLE);
-
-        /**
-         * FIELDS update
-         */
-        $syntax[] = $this->getSettingFieldsSyntax();
-
-        /**
-         * 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 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_UPDATE;
+
+
+	/**
+	 * QueryUpdate 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);
+
+		/**
+		 * IGNORE clause
+		 */
+		$syntax[] = $this->queryStructure->getElement(QueryStructure::IGNORE) ? 'IGNORE' : '';
+
+		/**
+		 * TABLE update
+		 */
+		$syntax[] = $this->queryStructure->getElement(QueryStructure::TABLE);
+
+		/**
+		 * FIELDS update
+		 */
+		$syntax[] = $this->getSettingFieldsSyntax();
+
+		/**
+		 * 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 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

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

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

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

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

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

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