adumitru68 / QueryBuilder

src/Traits/DefaultPriority.php

Indentation +9 added lines, -9 removed lines

@@ -14,17 +14,17 @@
 trait DefaultPriority
 {
 
-    use Objects;
+	use Objects;
 
 
-    /**
-     * @return $this
-     */
-    public function defaultPriority()
-    {
-        $this->queryStructure->setElement(QueryStructure::PRIORITY, '');
+	/**
+	 * @return $this
+	 */
+	public function defaultPriority()
+	{
+		$this->queryStructure->setElement(QueryStructure::PRIORITY, '');
 
-        return $this;
-    }
+		return $this;
+	}
 
 }
\ No newline at end of file

src/Dependencies/QueryException.php

Indentation +17 added lines, -17 removed lines

@@ -11,23 +11,23 @@
 class QueryException extends \Exception
 {
 
-    const QUERY_ERROR_ELEMENT_NOT_FOUND = 10;
-    const QUERY_ERROR_ELEMENT_TYPE = 11;
-    const QUERY_ERROR_WHERE_INVALID_PARAM_ARRAY = 20;
-    const QUERY_ERROR_WHERE_INVALID_OPERATOR = 30;
-    const QUERY_ERROR_INVALID_LIMIT = 40;
-    const QUERY_ERROR_INVALID_LIMIT_ZERO = 50;
-    const QUERY_ERROR_INVALID_LIMIT_OFFSET = 60;
-    const QUERY_ERROR_DELETE_NOT_FILTER = 70;
+	const QUERY_ERROR_ELEMENT_NOT_FOUND = 10;
+	const QUERY_ERROR_ELEMENT_TYPE = 11;
+	const QUERY_ERROR_WHERE_INVALID_PARAM_ARRAY = 20;
+	const QUERY_ERROR_WHERE_INVALID_OPERATOR = 30;
+	const QUERY_ERROR_INVALID_LIMIT = 40;
+	const QUERY_ERROR_INVALID_LIMIT_ZERO = 50;
+	const QUERY_ERROR_INVALID_LIMIT_OFFSET = 60;
+	const QUERY_ERROR_DELETE_NOT_FILTER = 70;
 
-    const QUERY_ERROR_INVALID_FIELDS_COUNT = 91;
-    const QUERY_ERROR_INVALID_DISTINCT = 92;
-    const QUERY_ERROR_HAVING_INVALID_PARAM_ARRAY = 93;
-    const QUERY_ERROR_HAVING_INVALID_OPERATOR = 94;
-    const QUERY_ERROR_SELECT_INVALID_FIELD = 95;
-    const QUERY_ERROR_SELECT_INVALID_PARAM = 96;
-    const QUERY_ERROR_INVALID_TABLE_STATEMENT = 97;
-    const QUERY_ERROR_INVALID_COLUMN_NAME = 98;
-    const QUERY_ERROR_INVALID_CONDITION_TYPE = 99;
+	const QUERY_ERROR_INVALID_FIELDS_COUNT = 91;
+	const QUERY_ERROR_INVALID_DISTINCT = 92;
+	const QUERY_ERROR_HAVING_INVALID_PARAM_ARRAY = 93;
+	const QUERY_ERROR_HAVING_INVALID_OPERATOR = 94;
+	const QUERY_ERROR_SELECT_INVALID_FIELD = 95;
+	const QUERY_ERROR_SELECT_INVALID_PARAM = 96;
+	const QUERY_ERROR_INVALID_TABLE_STATEMENT = 97;
+	const QUERY_ERROR_INVALID_COLUMN_NAME = 98;
+	const QUERY_ERROR_INVALID_CONDITION_TYPE = 99;
 
 }
\ No newline at end of file

src/Dependencies/QueryHelper.php

Indentation +142 added lines, -142 removed lines

@@ -11,147 +11,147 @@
 class QueryHelper
 {
 
-    /**
-     * @param string $string
-     * @return mixed|string
-     */
-    public static function clearMultipleSpaces($string = '')
-    {
-        $string = preg_replace('/\s+/', ' ', $string);
-        $string = trim($string);
-
-        return $string;
-    }
-
-    /**
-     * @param $val
-     * @return bool
-     */
-    public static function isInteger($val)
-    {
-        $val = trim($val);
-
-        return is_numeric($val) && floor($val) == $val;
-    }
-
-    /**
-     * @param $val
-     * @return bool
-     * @i
-     */
-    public static function isDecimal($val)
-    {
-        $val = trim($val);
-
-        return is_numeric($val) && floor($val) != $val;
-    }
-
-    public static function isValidOrderBy($order_by_parameter)
-    {
-
-        $columns = array('first_name', 'last_name', 'zip', 'created_at');
-
-        $parts = preg_split("/[\s,]+/", $order_by_parameter);
-
-        foreach ($parts as $part) {
-            $subparts = preg_split("/\s+/", $part);
-
-            if (count($subparts) < 0 || count($subparts) > 2) {
-                // Too many or too few parts.
-                return false;
-            }
-
-            if (!in_array($subparts[0], $columns)) {
-                // Column name is invalid.
-                return false;
-            }
-
-            if (count($subparts) == 2 && !in_array(strtoupper($subparts[1]), array('ASC', 'DESC'))) {
-                // ASC or DESC is invalid
-                return false;
-            }
-        }
-
-        return true;
-    }
-
-
-    /**
-     * @param $string
-     * @param string $delimiter
-     * @return array
-     */
-    public static function explode($string, $delimiter = ',')
-    {
-        $brutArray = explode($delimiter, $string);
-        $newArray = array();
-        foreach ($brutArray as $value) {
-            $value = trim($value);
-            if ('' !== $value)
-                $newArray[] = $value;
-        }
-
-        return $newArray;
-    }
-
-    public static function alphaNum($string)
-    {
-        $string = preg_replace("/[^a-zA-Z0-9 _,]+/", "", $string);
-
-        return self::clearMultipleSpaces($string);
-    }
-
-    /**
-     * @param array $array
-     * @param string $delimiter
-     * @return string
-     */
-    public static function implode(array $array, $delimiter = ',')
-    {
-        $string = implode($delimiter, $array);
-        $string = trim($string);
-        $string = trim($string, trim($delimiter));
-        $string = trim($string);
-
-        return $string;
-    }
-
-    /**
-     * @param $string
-     * @return mixed|string
-     */
-    public static function clearQuotes($string)
-    {
-        $search = array('"', "'");
-        $replace = '';
-        $string = str_replace($search, $replace, $string);
-
-        return self::clearMultipleSpaces($string);
-    }
-
-    /**
-     * @param int $length
-     * @return string
-     */
-    public static function random($length = 5)
-    {
-        $characters = 'abcdefghijklmnopqrstuvwxyz';
-        $charactersLength = strlen($characters);
-        $randomString = '';
-        for ($i = 0; $i < $length; $i++)
-            $randomString .= $characters[ rand(0, $charactersLength - 1) ];
-
-        return str_shuffle($randomString);
-    }
-
-    public static function limitString($rowCount, $offset = null)
-    {
-        $rowCount = intval($rowCount);
-        if (is_null($offset))
-            return $rowCount;
-        $offset = intval($offset);
-
-        return "$offset, $rowCount";
-    }
+	/**
+	 * @param string $string
+	 * @return mixed|string
+	 */
+	public static function clearMultipleSpaces($string = '')
+	{
+		$string = preg_replace('/\s+/', ' ', $string);
+		$string = trim($string);
+
+		return $string;
+	}
+
+	/**
+	 * @param $val
+	 * @return bool
+	 */
+	public static function isInteger($val)
+	{
+		$val = trim($val);
+
+		return is_numeric($val) && floor($val) == $val;
+	}
+
+	/**
+	 * @param $val
+	 * @return bool
+	 * @i
+	 */
+	public static function isDecimal($val)
+	{
+		$val = trim($val);
+
+		return is_numeric($val) && floor($val) != $val;
+	}
+
+	public static function isValidOrderBy($order_by_parameter)
+	{
+
+		$columns = array('first_name', 'last_name', 'zip', 'created_at');
+
+		$parts = preg_split("/[\s,]+/", $order_by_parameter);
+
+		foreach ($parts as $part) {
+			$subparts = preg_split("/\s+/", $part);
+
+			if (count($subparts) < 0 || count($subparts) > 2) {
+				// Too many or too few parts.
+				return false;
+			}
+
+			if (!in_array($subparts[0], $columns)) {
+				// Column name is invalid.
+				return false;
+			}
+
+			if (count($subparts) == 2 && !in_array(strtoupper($subparts[1]), array('ASC', 'DESC'))) {
+				// ASC or DESC is invalid
+				return false;
+			}
+		}
+
+		return true;
+	}
+
+
+	/**
+	 * @param $string
+	 * @param string $delimiter
+	 * @return array
+	 */
+	public static function explode($string, $delimiter = ',')
+	{
+		$brutArray = explode($delimiter, $string);
+		$newArray = array();
+		foreach ($brutArray as $value) {
+			$value = trim($value);
+			if ('' !== $value)
+				$newArray[] = $value;
+		}
+
+		return $newArray;
+	}
+
+	public static function alphaNum($string)
+	{
+		$string = preg_replace("/[^a-zA-Z0-9 _,]+/", "", $string);
+
+		return self::clearMultipleSpaces($string);
+	}
+
+	/**
+	 * @param array $array
+	 * @param string $delimiter
+	 * @return string
+	 */
+	public static function implode(array $array, $delimiter = ',')
+	{
+		$string = implode($delimiter, $array);
+		$string = trim($string);
+		$string = trim($string, trim($delimiter));
+		$string = trim($string);
+
+		return $string;
+	}
+
+	/**
+	 * @param $string
+	 * @return mixed|string
+	 */
+	public static function clearQuotes($string)
+	{
+		$search = array('"', "'");
+		$replace = '';
+		$string = str_replace($search, $replace, $string);
+
+		return self::clearMultipleSpaces($string);
+	}
+
+	/**
+	 * @param int $length
+	 * @return string
+	 */
+	public static function random($length = 5)
+	{
+		$characters = 'abcdefghijklmnopqrstuvwxyz';
+		$charactersLength = strlen($characters);
+		$randomString = '';
+		for ($i = 0; $i < $length; $i++)
+			$randomString .= $characters[ rand(0, $charactersLength - 1) ];
+
+		return str_shuffle($randomString);
+	}
+
+	public static function limitString($rowCount, $offset = null)
+	{
+		$rowCount = intval($rowCount);
+		if (is_null($offset))
+			return $rowCount;
+		$offset = intval($offset);
+
+		return "$offset, $rowCount";
+	}
 
 }
\ No newline at end of file

src/Dependencies/QueryTimer.php

Indentation +28 added lines, -28 removed lines

@@ -11,33 +11,33 @@
 class QueryTimer
 {
 
-    /**
-     * @var mixed
-     */
-    private $queryStart;
-
-    /**
-     * @var mixed
-     */
-    private $queryEnd;
-
-
-    /**
-     * QueryTimer constructor.
-     */
-    public function __construct()
-    {
-        $this->queryStart = microtime(true);
-    }
-
-    /**
-     * @return float
-     */
-    public function getDuration()
-    {
-        $this->queryEnd = microtime(true);
-
-        return $this->queryEnd - $this->queryStart;
-    }
+	/**
+	 * @var mixed
+	 */
+	private $queryStart;
+
+	/**
+	 * @var mixed
+	 */
+	private $queryEnd;
+
+
+	/**
+	 * QueryTimer constructor.
+	 */
+	public function __construct()
+	{
+		$this->queryStart = microtime(true);
+	}
+
+	/**
+	 * @return float
+	 */
+	public function getDuration()
+	{
+		$this->queryEnd = microtime(true);
+
+		return $this->queryEnd - $this->queryStart;
+	}
 
 }
\ No newline at end of file

src/Dependencies/QueryStructure.php

Indentation +229 added lines, -229 removed lines

@@ -13,234 +13,234 @@
 class QueryStructure
 {
 
-    const TABLE = 'table';
-    const EXPLAIN = 'explain';
-    const STATEMENT = 'statement';
-    const PRIORITY = 'priority';
-    const FIELDS = 'fields';
-    const SET_FIELDS = 'set_fields';
-    const WHERE = 'where';
-    const HAVING = 'having';
-    const WHERE_INVERT = 'where_invert';
-    const HAVING_INVERT = 'having_invert';
-    const LIMIT = 'limit_rows';
-    const ORDER_BY = 'order_by';
-    const GROUP_BY = 'group_by';
-    const COUNT = 'count';
-    const COLUMN = 'column';
-    const FIRST = 'first';
-    const DISTINCT = 'distinct';
-    const JOIN = 'join';
-    const IGNORE = 'ignore';
-    const MULTIPLE_ROWS = 'multiple_rows';
-    const QUERY = 'query';
-    const BIND_PARAMS = 'bind_params';
-    const REPLACEMENT = 'replacement';
-    const QUERY_TYPE = 'query_type';
-    const QUERY_STRING = 'query_string';
-    const QUERY_COMMENT = 'query_comment';
-    const QUERY_IDENTIFIER = 'query_identifier';
-    const WHERE_TRIGGER = 'where_trigger';
-    const INSTANCE = 'instance';
-
-    /**
-     *  Elements type
-     */
-
-    const ELEMENT_TYPE_BOOLEAN = 'boolean';
-    const ELEMENT_TYPE_INTEGER = 'integer';
-    const ELEMENT_TYPE_DOUBLE = 'double';
-    const ELEMENT_TYPE_STRING = 'string';
-    const ELEMENT_TYPE_ARRAY = 'array';
-    const ELEMENT_TYPE_OBJECT = 'object';
-    const ELEMENT_TYPE_RESOURCE = 'resource';
-    const ELEMENT_TYPE_NULL = 'NULL';
-    const ELEMENT_TYPE_UNKNOWN = 'unknown type';
-
-    /**
-     * @var array
-     */
-    private static $usedInstanceIds = [];
-
-    /**
-     * @var array
-     */
-    private $syntaxEL = array();
-
-    /**
-     * @var array
-     */
-    private $typeEL = array();
-
-    /**
-     * @var int
-     */
-    private $counter = 0;
-
-
-    /**
-     * QueryStructure constructor.
-     */
-    public function __construct()
-    {
-        $this->syntaxEL = $this->init();
-
-        foreach ($this->syntaxEL as $name => $value)
-            $this->typeEL[ $name ] = gettype($value);
-
-    }
-
-    private function init()
-    {
-        return [self::TABLE => '', self::EXPLAIN => 0, self::STATEMENT => '', self::PRIORITY => '', self::FIELDS => '*', self::SET_FIELDS => array(), self::WHERE => array(), self::HAVING => array(), self::WHERE_INVERT => 0, self::HAVING_INVERT => 0, self::LIMIT => 0, self::ORDER_BY => array(), self::GROUP_BY => array(), self::COUNT => 0, self::COLUMN => '', self::FIRST => 0, self::DISTINCT => 0, self::JOIN => array(), self::IGNORE => 0, self::MULTIPLE_ROWS => 0, self::QUERY => '', self::BIND_PARAMS => array(), self::REPLACEMENT => 0, self::QUERY_TYPE => 0, self::QUERY_STRING => '', self::QUERY_COMMENT => '', self::QUERY_IDENTIFIER => 'DEFAULT', self::WHERE_TRIGGER => 1, self::INSTANCE => $this->makeStatementInstance()];
-    }
-
-
-    private function makeStatementInstance()
-    {
-        $instance = QueryHelper::random(5);
-        while (in_array($instance, self::$usedInstanceIds)) {
-            $instance = QueryHelper::random(7);
-        }
-        self::$usedInstanceIds[] = $instance;
-
-        return $instance;
-    }
-
-
-    /**
-     * @return array
-     */
-    public static function getUsedInstances()
-    {
-        return self::$usedInstanceIds;
-    }
-
-
-    /**
-     * @return array
-     */
-    public function getAllElements()
-    {
-        return $this->syntaxEL;
-    }
-
-    /**
-     * @param $elements
-     */
-    public function setAllElements($elements)
-    {
-        $this->syntaxEL = $elements;
-    }
-
-
-    /**
-     * @param $name
-     * @param $value
-     * @return bool
-     * @throws QueryException
-     */
-    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 ($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;
-
-        return true;
-    }
-
-
-    /**
-     * @param string $elementName
-     * @param $elementValue
-     * @throws QueryException
-     */
-    public function replaceElement($elementName, $elementValue)
-    {
-        if (!array_key_exists($elementName, $this->syntaxEL))
-            throw new QueryException('Invalid Query property', QueryException::QUERY_ERROR_ELEMENT_NOT_FOUND);
-
-        $this->syntaxEL[ $elementName ] = $elementValue;
-    }
-
-
-    /**
-     * @param string $name
-     * @return mixed
-     */
-    public function getElement($name)
-    {
-        return $this->syntaxEL[ $name ];
-    }
-
-
-    /**
-     * @param $name
-     * @param $value
-     */
-    public function setParams($name, $value)
-    {
-        $this->syntaxEL[ QueryStructure::BIND_PARAMS ][ $name ] = $value;
-    }
-
-
-    /**
-     * @param $name
-     * @param $value
-     * @return string
-     */
-    public function bindParam($name, $value)
-    {
-        $pdoName = $this->index($name);
-        $this->syntaxEL[ QueryStructure::BIND_PARAMS ][ $pdoName ] = $value;
-
-        return ':' . $pdoName;
-    }
-
-
-    /**
-     * @param $expression
-     * @param array $params
-     * @param string $search
-     * @return string
-     */
-    public function bindParamsExpression($expression, array $params = [], $search = '?')
-    {
-        if (!count($params))
-            return $expression;
-
-        if (strpos($expression, $search) === false)
-            return $expression;
-
-        $params = array_slice($params, 0, substr_count($expression, $search));
-
-        $i = 0;
-        $arrayReturn = [];
-        $expressionToArray = explode($search, $expression);
-
-        foreach ($expressionToArray as $sub) {
-            $arrayReturn[] = $sub;
-            $arrayReturn[] = array_key_exists($i, $params) ? $this->bindParam('exp', $params[ $i ]) : '';
-            $i++;
-        }
-
-        return implode('', $arrayReturn);
-    }
-
-
-    /**
-     * @param string $fieldName
-     * @return string
-     */
-    public function index($fieldName = '')
-    {
-        return trim($fieldName) . '_' . $this->syntaxEL[ self::INSTANCE ] . '_' . ++$this->counter . 'i';
-    }
+	const TABLE = 'table';
+	const EXPLAIN = 'explain';
+	const STATEMENT = 'statement';
+	const PRIORITY = 'priority';
+	const FIELDS = 'fields';
+	const SET_FIELDS = 'set_fields';
+	const WHERE = 'where';
+	const HAVING = 'having';
+	const WHERE_INVERT = 'where_invert';
+	const HAVING_INVERT = 'having_invert';
+	const LIMIT = 'limit_rows';
+	const ORDER_BY = 'order_by';
+	const GROUP_BY = 'group_by';
+	const COUNT = 'count';
+	const COLUMN = 'column';
+	const FIRST = 'first';
+	const DISTINCT = 'distinct';
+	const JOIN = 'join';
+	const IGNORE = 'ignore';
+	const MULTIPLE_ROWS = 'multiple_rows';
+	const QUERY = 'query';
+	const BIND_PARAMS = 'bind_params';
+	const REPLACEMENT = 'replacement';
+	const QUERY_TYPE = 'query_type';
+	const QUERY_STRING = 'query_string';
+	const QUERY_COMMENT = 'query_comment';
+	const QUERY_IDENTIFIER = 'query_identifier';
+	const WHERE_TRIGGER = 'where_trigger';
+	const INSTANCE = 'instance';
+
+	/**
+	 *  Elements type
+	 */
+
+	const ELEMENT_TYPE_BOOLEAN = 'boolean';
+	const ELEMENT_TYPE_INTEGER = 'integer';
+	const ELEMENT_TYPE_DOUBLE = 'double';
+	const ELEMENT_TYPE_STRING = 'string';
+	const ELEMENT_TYPE_ARRAY = 'array';
+	const ELEMENT_TYPE_OBJECT = 'object';
+	const ELEMENT_TYPE_RESOURCE = 'resource';
+	const ELEMENT_TYPE_NULL = 'NULL';
+	const ELEMENT_TYPE_UNKNOWN = 'unknown type';
+
+	/**
+	 * @var array
+	 */
+	private static $usedInstanceIds = [];
+
+	/**
+	 * @var array
+	 */
+	private $syntaxEL = array();
+
+	/**
+	 * @var array
+	 */
+	private $typeEL = array();
+
+	/**
+	 * @var int
+	 */
+	private $counter = 0;
+
+
+	/**
+	 * QueryStructure constructor.
+	 */
+	public function __construct()
+	{
+		$this->syntaxEL = $this->init();
+
+		foreach ($this->syntaxEL as $name => $value)
+			$this->typeEL[ $name ] = gettype($value);
+
+	}
+
+	private function init()
+	{
+		return [self::TABLE => '', self::EXPLAIN => 0, self::STATEMENT => '', self::PRIORITY => '', self::FIELDS => '*', self::SET_FIELDS => array(), self::WHERE => array(), self::HAVING => array(), self::WHERE_INVERT => 0, self::HAVING_INVERT => 0, self::LIMIT => 0, self::ORDER_BY => array(), self::GROUP_BY => array(), self::COUNT => 0, self::COLUMN => '', self::FIRST => 0, self::DISTINCT => 0, self::JOIN => array(), self::IGNORE => 0, self::MULTIPLE_ROWS => 0, self::QUERY => '', self::BIND_PARAMS => array(), self::REPLACEMENT => 0, self::QUERY_TYPE => 0, self::QUERY_STRING => '', self::QUERY_COMMENT => '', self::QUERY_IDENTIFIER => 'DEFAULT', self::WHERE_TRIGGER => 1, self::INSTANCE => $this->makeStatementInstance()];
+	}
+
+
+	private function makeStatementInstance()
+	{
+		$instance = QueryHelper::random(5);
+		while (in_array($instance, self::$usedInstanceIds)) {
+			$instance = QueryHelper::random(7);
+		}
+		self::$usedInstanceIds[] = $instance;
+
+		return $instance;
+	}
+
+
+	/**
+	 * @return array
+	 */
+	public static function getUsedInstances()
+	{
+		return self::$usedInstanceIds;
+	}
+
+
+	/**
+	 * @return array
+	 */
+	public function getAllElements()
+	{
+		return $this->syntaxEL;
+	}
+
+	/**
+	 * @param $elements
+	 */
+	public function setAllElements($elements)
+	{
+		$this->syntaxEL = $elements;
+	}
+
+
+	/**
+	 * @param $name
+	 * @param $value
+	 * @return bool
+	 * @throws QueryException
+	 */
+	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 ($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;
+
+		return true;
+	}
+
+
+	/**
+	 * @param string $elementName
+	 * @param $elementValue
+	 * @throws QueryException
+	 */
+	public function replaceElement($elementName, $elementValue)
+	{
+		if (!array_key_exists($elementName, $this->syntaxEL))
+			throw new QueryException('Invalid Query property', QueryException::QUERY_ERROR_ELEMENT_NOT_FOUND);
+
+		$this->syntaxEL[ $elementName ] = $elementValue;
+	}
+
+
+	/**
+	 * @param string $name
+	 * @return mixed
+	 */
+	public function getElement($name)
+	{
+		return $this->syntaxEL[ $name ];
+	}
+
+
+	/**
+	 * @param $name
+	 * @param $value
+	 */
+	public function setParams($name, $value)
+	{
+		$this->syntaxEL[ QueryStructure::BIND_PARAMS ][ $name ] = $value;
+	}
+
+
+	/**
+	 * @param $name
+	 * @param $value
+	 * @return string
+	 */
+	public function bindParam($name, $value)
+	{
+		$pdoName = $this->index($name);
+		$this->syntaxEL[ QueryStructure::BIND_PARAMS ][ $pdoName ] = $value;
+
+		return ':' . $pdoName;
+	}
+
+
+	/**
+	 * @param $expression
+	 * @param array $params
+	 * @param string $search
+	 * @return string
+	 */
+	public function bindParamsExpression($expression, array $params = [], $search = '?')
+	{
+		if (!count($params))
+			return $expression;
+
+		if (strpos($expression, $search) === false)
+			return $expression;
+
+		$params = array_slice($params, 0, substr_count($expression, $search));
+
+		$i = 0;
+		$arrayReturn = [];
+		$expressionToArray = explode($search, $expression);
+
+		foreach ($expressionToArray as $sub) {
+			$arrayReturn[] = $sub;
+			$arrayReturn[] = array_key_exists($i, $params) ? $this->bindParam('exp', $params[ $i ]) : '';
+			$i++;
+		}
+
+		return implode('', $arrayReturn);
+	}
+
+
+	/**
+	 * @param string $fieldName
+	 * @return string
+	 */
+	public function index($fieldName = '')
+	{
+		return trim($fieldName) . '_' . $this->syntaxEL[ self::INSTANCE ] . '_' . ++$this->counter . 'i';
+	}
 
 }
\ No newline at end of file

src/QueryBuild.php

Indentation +59 added lines, -59 removed lines

@@ -17,71 +17,71 @@
 class QueryBuild
 {
 
-    /**
-     * @var integer
-     */
-    private $queryType;
+	/**
+	 * @var integer
+	 */
+	private $queryType;
 
-    /**
-     * QueryBuild constructor.
-     * @param $queryType
-     */
-    protected function __construct($queryType)
-    {
-        $this->queryType = $queryType;
-    }
+	/**
+	 * QueryBuild constructor.
+	 * @param $queryType
+	 */
+	protected function __construct($queryType)
+	{
+		$this->queryType = $queryType;
+	}
 
-    /**
-     * @param $table
-     * @return QuerySelect
-     */
-    public static function select($table)
-    {
-        return new QuerySelect(new QueryBuild(0), $table);
-    }
+	/**
+	 * @param $table
+	 * @return QuerySelect
+	 */
+	public static function select($table)
+	{
+		return new QuerySelect(new QueryBuild(0), $table);
+	}
 
-    /**
-     * @param $table
-     * @return QueryUpdate
-     */
-    public static function update($table)
-    {
-        return new QueryUpdate(new QueryBuild(0), $table);
-    }
+	/**
+	 * @param $table
+	 * @return QueryUpdate
+	 */
+	public static function update($table)
+	{
+		return new QueryUpdate(new QueryBuild(0), $table);
+	}
 
-    /**
-     * @param $table
-     * @return QueryInsert
-     */
-    public static function insert($table)
-    {
-        return new QueryInsert(new QueryBuild(0), $table);
-    }
+	/**
+	 * @param $table
+	 * @return QueryInsert
+	 */
+	public static function insert($table)
+	{
+		return new QueryInsert(new QueryBuild(0), $table);
+	}
 
-    /**
-     * @param $table
-     * @return QueryDelete
-     */
-    public static function delete($table)
-    {
-        return new QueryDelete(new QueryBuild(0), $table);
-    }
+	/**
+	 * @param $table
+	 * @return QueryDelete
+	 */
+	public static function delete($table)
+	{
+		return new QueryDelete(new QueryBuild(0), $table);
+	}
 
-    /**
-     * @param $query
-     * @return QueryCustom
-     */
-    public static function query($query)
-    {
-        return new QueryCustom(new QueryBuild(1), $query);
-    }
+	/**
+	 * @param $query
+	 * @return QueryCustom
+	 */
+	public static function query($query)
+	{
+		return new QueryCustom(new QueryBuild(1), $query);
+	}
 
-    /**
-     * @return integer
-     */
-    public function getType()
-    {
-        return $this->queryType;
-    }
+	/**
+	 * @return integer
+	 */
+	public function getType()
+	{
+		return $this->queryType;
+	}
 
 }
\ No newline at end of file

src/Statements/QuerySelect.php

Indentation +174 added lines, -174 removed lines

@@ -29,179 +29,179 @@
 class QuerySelect extends QueryStatement implements QueryStatementInterface
 {
 
-    use SelectFields, Limit, Distinct, Where, Having, WhereAndHavingBuilder, Replacement, OrderBy, GroupBy, Join, DefaultPriority, HighPriority, Utilities;
-
-    /**
-     * @var string
-     */
-    protected $statement = self::QUERY_STATEMENT_SELECT;
-
-
-    /**
-     * QuerySelect constructor.
-     * @param QueryBuild $queryBuild
-     * @param string|QueryStatement $table
-     */
-    public function __construct(QueryBuild $queryBuild, $table)
-    {
-        parent::__construct($queryBuild, $table);
-
-        if (is_a($table, QuerySelect::class)) {
-
-            /**
-             * @var QuerySelect $table
-             */
-            $tableName = '( ' . $table->getSyntax() . ' )';
-            $this->queryStructure->setElement(QueryStructure::TABLE, $tableName);
-
-            $tableSelectParams = $table->getBindParams();
-            foreach ($tableSelectParams as $key => $value)
-                $this->queryStructure->setParams($key, $value);
-
-        }
-    }
-
-    /**
-     * @return $this
-     */
-    public function first()
-    {
-        $this->queryStructure->setElement(QueryStructure::FIRST, 1);
-
-        return $this;
-    }
-
-    /**
-     * @return $this
-     */
-    public function count()
-    {
-        $this->queryStructure->setElement(QueryStructure::COUNT, 1);
-
-        return $this;
-    }
-
-    /**
-     * @param $column
-     * @return $this
-     */
-    public function column($column)
-    {
-        $column = QueryHelper::clearMultipleSpaces($column);
-        $this->queryStructure->setElement(QueryStructure::COLUMN, $column);
-
-        return $this;
-    }
-
-
-    /**
-     * @param bool|int $replacement
-     * @return mixed|string
-     */
-    public function getSyntax($replacement = self::REPLACEMENT_NONE)
-    {
-
-        if ($this->queryStructure->getElement(QueryStructure::COUNT)) {
-            $this->queryStructure->setElement(QueryStructure::FIELDS, 'COUNT(*)');
-            $this->queryStructure->setElement(QueryStructure::LIMIT, 1);
-            $this->queryStructure->setElement(QueryStructure::DISTINCT, 0); //???
-        }
-
-        if ($this->queryStructure->getElement(QueryStructure::FIRST))
-            $this->queryStructure->setElement(QueryStructure::LIMIT, 1);
-
-        $syntax = array();
-
-        /**
-         *  Explain
-         */
-        $syntax[] = $this->getExplainSyntax();
-
-        /**
-         * SELECT statement
-         */
-        $syntax[] = $this->statement;
-
-        /**
-         * PRIORITY
-         */
-        $syntax[] = $this->queryStructure->getElement(QueryStructure::PRIORITY);
-
-        /**
-         * DISTINCT clause
-         */
-        $syntax[] = $this->getDistinctSyntax();
-
-        /**
-         * FIELDS
-         */
-        $syntax[] = $this->queryStructure->getElement(QueryStructure::FIELDS);
-
-        /**
-         * FROM table or queryStructure
-         */
-        $syntax[] = 'FROM ' . $this->queryStructure->getElement(QueryStructure::TABLE);
-
-        /**
-         * JOIN CLAUSES
-         */
-        $syntax[] = $this->getJoinSyntax();
-
-        /**
-         * WHERE clause
-         */
-        $syntax[] = $this->getWhereSyntax();
-
-        /**
-         * GROUP BY clause
-         */
-        $syntax[] = $this->getGroupBySyntax();
-
-        /**
-         * HAVING clause
-         */
-        $syntax[] = $this->getHavingSyntax();
-
-        /**
-         * ORDER BY clause
-         */
-        $syntax[] = $this->getOrderBySyntax();
-
-        /**
-         * LIMIT clause
-         */
-        $syntax[] = $this->getLimitSyntax();
-
-        $syntax = implode(' ', $syntax);
-
-        return $this->getSyntaxReplace($syntax, $replacement);
-
-    }
-
-
-    /**
-     * @return array|int|mixed|null|string
-     */
-    public function execute()
-    {
-
-        switch (true) {
-            case $this->queryStructure->getElement(QueryStructure::COUNT):
-                return DbService::getInstance()->single($this->getSyntax(), $this->queryStructure->getElement(QueryStructure::BIND_PARAMS));
-                break;
-            case $this->queryStructure->getElement(QueryStructure::FIRST):
-                if ($this->queryStructure->getElement(QueryStructure::COLUMN))
-                    return DbService::getInstance()->single($this->getSyntax(), $this->queryStructure->getElement(QueryStructure::BIND_PARAMS));
-
-                return DbService::getInstance()->row($this->getSyntax(), $this->queryStructure->getElement(QueryStructure::BIND_PARAMS));
-                break;
-            case $this->queryStructure->getElement(QueryStructure::COLUMN):
-                return DbService::getInstance()->column($this->getSyntax(), $this->queryStructure->getElement(QueryStructure::BIND_PARAMS));
-                break;
-            default:
-                return DbService::getInstance()->query($this->getSyntax(), $this->queryStructure->getElement(QueryStructure::BIND_PARAMS));
-                break;
-        }
-    }
+	use SelectFields, Limit, Distinct, Where, Having, WhereAndHavingBuilder, Replacement, OrderBy, GroupBy, Join, DefaultPriority, HighPriority, Utilities;
+
+	/**
+	 * @var string
+	 */
+	protected $statement = self::QUERY_STATEMENT_SELECT;
+
+
+	/**
+	 * QuerySelect constructor.
+	 * @param QueryBuild $queryBuild
+	 * @param string|QueryStatement $table
+	 */
+	public function __construct(QueryBuild $queryBuild, $table)
+	{
+		parent::__construct($queryBuild, $table);
+
+		if (is_a($table, QuerySelect::class)) {
+
+			/**
+			 * @var QuerySelect $table
+			 */
+			$tableName = '( ' . $table->getSyntax() . ' )';
+			$this->queryStructure->setElement(QueryStructure::TABLE, $tableName);
+
+			$tableSelectParams = $table->getBindParams();
+			foreach ($tableSelectParams as $key => $value)
+				$this->queryStructure->setParams($key, $value);
+
+		}
+	}
+
+	/**
+	 * @return $this
+	 */
+	public function first()
+	{
+		$this->queryStructure->setElement(QueryStructure::FIRST, 1);
+
+		return $this;
+	}
+
+	/**
+	 * @return $this
+	 */
+	public function count()
+	{
+		$this->queryStructure->setElement(QueryStructure::COUNT, 1);
+
+		return $this;
+	}
+
+	/**
+	 * @param $column
+	 * @return $this
+	 */
+	public function column($column)
+	{
+		$column = QueryHelper::clearMultipleSpaces($column);
+		$this->queryStructure->setElement(QueryStructure::COLUMN, $column);
+
+		return $this;
+	}
+
+
+	/**
+	 * @param bool|int $replacement
+	 * @return mixed|string
+	 */
+	public function getSyntax($replacement = self::REPLACEMENT_NONE)
+	{
+
+		if ($this->queryStructure->getElement(QueryStructure::COUNT)) {
+			$this->queryStructure->setElement(QueryStructure::FIELDS, 'COUNT(*)');
+			$this->queryStructure->setElement(QueryStructure::LIMIT, 1);
+			$this->queryStructure->setElement(QueryStructure::DISTINCT, 0); //???
+		}
+
+		if ($this->queryStructure->getElement(QueryStructure::FIRST))
+			$this->queryStructure->setElement(QueryStructure::LIMIT, 1);
+
+		$syntax = array();
+
+		/**
+		 *  Explain
+		 */
+		$syntax[] = $this->getExplainSyntax();
+
+		/**
+		 * SELECT statement
+		 */
+		$syntax[] = $this->statement;
+
+		/**
+		 * PRIORITY
+		 */
+		$syntax[] = $this->queryStructure->getElement(QueryStructure::PRIORITY);
+
+		/**
+		 * DISTINCT clause
+		 */
+		$syntax[] = $this->getDistinctSyntax();
+
+		/**
+		 * FIELDS
+		 */
+		$syntax[] = $this->queryStructure->getElement(QueryStructure::FIELDS);
+
+		/**
+		 * FROM table or queryStructure
+		 */
+		$syntax[] = 'FROM ' . $this->queryStructure->getElement(QueryStructure::TABLE);
+
+		/**
+		 * JOIN CLAUSES
+		 */
+		$syntax[] = $this->getJoinSyntax();
+
+		/**
+		 * WHERE clause
+		 */
+		$syntax[] = $this->getWhereSyntax();
+
+		/**
+		 * GROUP BY clause
+		 */
+		$syntax[] = $this->getGroupBySyntax();
+
+		/**
+		 * HAVING clause
+		 */
+		$syntax[] = $this->getHavingSyntax();
+
+		/**
+		 * ORDER BY clause
+		 */
+		$syntax[] = $this->getOrderBySyntax();
+
+		/**
+		 * LIMIT clause
+		 */
+		$syntax[] = $this->getLimitSyntax();
+
+		$syntax = implode(' ', $syntax);
+
+		return $this->getSyntaxReplace($syntax, $replacement);
+
+	}
+
+
+	/**
+	 * @return array|int|mixed|null|string
+	 */
+	public function execute()
+	{
+
+		switch (true) {
+			case $this->queryStructure->getElement(QueryStructure::COUNT):
+				return DbService::getInstance()->single($this->getSyntax(), $this->queryStructure->getElement(QueryStructure::BIND_PARAMS));
+				break;
+			case $this->queryStructure->getElement(QueryStructure::FIRST):
+				if ($this->queryStructure->getElement(QueryStructure::COLUMN))
+					return DbService::getInstance()->single($this->getSyntax(), $this->queryStructure->getElement(QueryStructure::BIND_PARAMS));
+
+				return DbService::getInstance()->row($this->getSyntax(), $this->queryStructure->getElement(QueryStructure::BIND_PARAMS));
+				break;
+			case $this->queryStructure->getElement(QueryStructure::COLUMN):
+				return DbService::getInstance()->column($this->getSyntax(), $this->queryStructure->getElement(QueryStructure::BIND_PARAMS));
+				break;
+			default:
+				return DbService::getInstance()->query($this->getSyntax(), $this->queryStructure->getElement(QueryStructure::BIND_PARAMS));
+				break;
+		}
+	}
 
 }
\ No newline at end of file

src/Statements/QueryCustom.php

Indentation +75 added lines, -75 removed lines

@@ -17,81 +17,81 @@
 {
 
 
-    /**
-     * @var string
-     */
-    protected $statement = QueryStatement::QUERY_STATEMENT_CUSTOM;
-
-    /**
-     * @var QueryBuild
-     */
-    protected $queryBuild;
-
-    /**
-     * @var QueryStructure
-     */
-    protected $queryStructure;
-
-    /**
-     * @var array
-     */
-    protected $usedInstanceIds = [];
-
-    /**
-     * @var string
-     */
-    protected $tablePrefix;
-
-
-    /**
-     * QueryCustom constructor.
-     * @param QueryBuild $queryBuild
-     * @param string $query
-     */
-    public function __construct(QueryBuild $queryBuild, $query = '')
-    {
-        $this->queryBuild = $queryBuild;
-        $this->queryStructure = new QueryStructure();
-        $this->queryStructure->setElement(QueryStructure::STATEMENT, $this->statement);
-        $this->queryStructure->setElement(QueryStructure::QUERY_TYPE, $this->queryBuild->getType());
-        $this->queryStructure->setElement(QueryStructure::QUERY_STRING, $query);
-    }
-
-    /**
-     * @param array $params
-     * @return $this
-     */
-    public function withBindParams(array $params = [])
-    {
-        $this->queryStructure->replaceElement(QueryStructure::BIND_PARAMS, $params);
-
-        return $this;
-    }
-
-    /**
-     * @param bool|int $replacement
-     * @return mixed
-     */
-    public function getSyntax($replacement = self::REPLACEMENT_NONE)
-    {
-        return $this->queryStructure->getElement(QueryStructure::QUERY_STRING);
-    }
-
-    /**
-     * @return array
-     */
-    public function getBindParams()
-    {
-        return $this->queryStructure->getElement(QueryStructure::BIND_PARAMS);
-    }
-
-    /**
-     * @return array|int|null
-     */
-    public function execute()
-    {
-        return DbService::getInstance()->query($this->queryStructure->getElement(QueryStructure::QUERY_STRING), $this->queryStructure->getElement(QueryStructure::BIND_PARAMS));
-    }
+	/**
+	 * @var string
+	 */
+	protected $statement = QueryStatement::QUERY_STATEMENT_CUSTOM;
+
+	/**
+	 * @var QueryBuild
+	 */
+	protected $queryBuild;
+
+	/**
+	 * @var QueryStructure
+	 */
+	protected $queryStructure;
+
+	/**
+	 * @var array
+	 */
+	protected $usedInstanceIds = [];
+
+	/**
+	 * @var string
+	 */
+	protected $tablePrefix;
+
+
+	/**
+	 * QueryCustom constructor.
+	 * @param QueryBuild $queryBuild
+	 * @param string $query
+	 */
+	public function __construct(QueryBuild $queryBuild, $query = '')
+	{
+		$this->queryBuild = $queryBuild;
+		$this->queryStructure = new QueryStructure();
+		$this->queryStructure->setElement(QueryStructure::STATEMENT, $this->statement);
+		$this->queryStructure->setElement(QueryStructure::QUERY_TYPE, $this->queryBuild->getType());
+		$this->queryStructure->setElement(QueryStructure::QUERY_STRING, $query);
+	}
+
+	/**
+	 * @param array $params
+	 * @return $this
+	 */
+	public function withBindParams(array $params = [])
+	{
+		$this->queryStructure->replaceElement(QueryStructure::BIND_PARAMS, $params);
+
+		return $this;
+	}
+
+	/**
+	 * @param bool|int $replacement
+	 * @return mixed
+	 */
+	public function getSyntax($replacement = self::REPLACEMENT_NONE)
+	{
+		return $this->queryStructure->getElement(QueryStructure::QUERY_STRING);
+	}
+
+	/**
+	 * @return array
+	 */
+	public function getBindParams()
+	{
+		return $this->queryStructure->getElement(QueryStructure::BIND_PARAMS);
+	}
+
+	/**
+	 * @return array|int|null
+	 */
+	public function execute()
+	{
+		return DbService::getInstance()->query($this->queryStructure->getElement(QueryStructure::QUERY_STRING), $this->queryStructure->getElement(QueryStructure::BIND_PARAMS));
+	}
 
 
 }
\ No newline at end of file

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