>
>
>
>
>
>
QueryBuilder.php
<?php namespace app\core\models; use app\core\helpers\ArrayHelper; class QueryBuilder { /** * Выборка по таблицам * @var array */ private $_select = []; /** * Таблица из которой делаем выборку * @var string */ private $_tableName; /** * Найденные элементы * @var array */ private $_items = []; /** * Если передано название класса в эту переменную * То мы заполним данные из метода one() или выполним "заливку" массива из all() * @var null|string */ private $_modelClass; /** * Если вы не передадите PDO объект для выборки, то выборки не будет. * @var \PDO */ private $_pdo; private $_relations = []; /** * ['AND|OR', $attribute, $condition, $value] * @var array */ private $_where = []; /** * Сколько записей пропустить. * @var */ private $_offset; /** * Сколько записей выводить. * @var */ private $_limit; /** * Сортировка * @var array */ private $_orderBy = []; /** * Группировка * @var array */ private $_groupBy = []; /** * true - Выводить только одну запись, false - выводить все записи * @var bool */ private $_one = false; public function __construct($modelClass = null) { $this->_modelClass = $modelClass; $this->_pdo = \App::$pdo; return $this; } public static function updateById($tableName, $id, array $values) { if (empty($values)) { return false; } $placeholders = []; $updateSet = []; foreach ($values as $key => $value) { $updateSet[] = '`' . $key . '` = :value_' . $key; $placeholders[':value_' . $key] = $value; } $sql = ' UPDATE `'. $tableName .'` SET ' . implode(', ', $updateSet) . ' WHERE id = ' . (int) $id . ' '; return \App::$command ->createCommand($sql) ->bindValues($placeholders) ->query(); } public static function insert($table, $values) { $keys = array_keys($values); $keysPlaceholders = []; foreach ($keys as $key) { $keysPlaceholders[] = ':' . $key; } $sql = ' INSERT INTO `'. $table . '` (' . implode(',', $keys) . ') VALUES('. implode(',', $keysPlaceholders) .') '; $command = \App::$command ->createCommand($sql); foreach ($values as $key => $value) { $command->bindValue(':' . $key, $value); } if ($command->query()) { return $command->lastInsertId(); } return 0; } public static function deleteById($table, $id) { $sql = " DELETE FROM `{$table}` WHERE id = :id "; return \App::$command ->createCommand($sql) ->bindValue(':id', $id) ->query(); } /** * Перечисление массива SELECT, для выборки из таблицы * Сюда можно передавать не только данные но и callback функции, которые будут преобразованы в значения. * Пример: * ```php * $model->select([ * 'foo', * function() use ($user) { * if ($user->isGuest) { * return 'name_guest'; * } else { * return 'name_full; * } * } * ]) * ``` * @param array $select * @return $this */ public function select(array $select = ['*']) { foreach ($select as $item) { $this->addSelect($item); } return $this; } /** * Добавление какого-то одного поля в SELECT * @param $select - строка или callback - функция * @return $this */ public function addSelect($select) { if (is_string($select) == false && is_callable($select)) { $select = call_user_func($select); } $this->_select[] = $select; return $this; } /** * Из какой таблицы делать выборку данных. * @param $table * @return $this; */ public function from($table) { $this->_tableName = $table; return $this; } /** * Функция-хелпер для добавления условия поиска WHERE по таблицам. * Использщуйте вместо этой этой функции функции: * where, orWhere, andWhere. * * @param $type - тип присоединения. OR или AND * @param $attribute - поле фильтрации, например foo * @param $condition - условие, по которому делаем выборку, например = > < * @param $value - значение для поиска. Может быть числом, строкой или функцией. */ private function addWhere($type, $attribute, $condition, $value) { if (is_callable($value)) { $value = call_user_func($value); } $this->_where[] = [$type, $attribute, $condition, $value]; } /** * Функция добавляет новое условие к таблице. * @param $attribute - поле, по которому ищем * @param $condition - условие поиска, > < = !=... * @param $value - значение, может быть строкой, числом или функцией * @return $this */ public function andWhere($attribute, $condition, $value) { $this->addWhere('AND', $attribute, $condition, $value); return $this; } /** * Функция добавляет новое условие с присоединением к предыдущему условию по типу OR * @param $attribute * @param $condition * @param $value * @return $this */ public function orWhere($attribute, $condition, $value) { $this->addWhere('OR', $attribute, $condition, $value); return $this; } /** * Функция добавляет условие Where к запросу. * ``php * $model->where([ * 'foo' => 'bar', * 'foo2' => function() { * return 'bar2'; * }, * ['>', 'foo3', 'bar'], * ['like', 'foo3', '%bar3%'] * ]); * ``` * @param array $andWhereCondition * @throws \Exception * @return $this */ public function where(array $andWhereCondition) { foreach ($andWhereCondition as $key => $value) { // если условие является массивом, то в пером индексе // будет условие выборки > < = != like и так далее if (is_array($value) && is_int($key)) { if (count($value) != 3) { throw new \Exception("Количество параметров в WHERE передано неверно."); } // если третий параметр является callback фунцией, // то выполняем эту функцию, чтобы получить значение if (is_callable($value[2])) { $value[2] = call_user_func($value[2]); } $this->andWhere($value[1], $value[0], $value[2]); } else { // если $key не является массивом, в этом случае // поле было key => value является массивом if (is_callable($value)) { $value = call_user_func($value); } $this->andWhere($key, '=', $value); } } return $this; } /** * Группировка * @param array $group * @return $this */ public function groupBy(array $group) { foreach ($group as $item) { $this->addGroupBy($item); } return $this; } /** * Функция добавляет еще один вариант группировки * @param $field * @return $this */ public function addGroupBy($field) { $this->_groupBy[] = $field; return $this; } /** * Сортировка * ```php * $model->orderBy([ * 'id' => SORT_DESC, * 'name' => SORT_ASC * ]); * ``` * @param array $orderBy * @return $this */ public function orderBy(array $orderBy) { foreach ($orderBy as $field => $sortType) { $this->addOrderBy($field, $sortType); } return $this; } /** * Функция добавляет сортировку к запросу * @param $field - поле, по которому сортируем. * @param $sortType * @return $this */ public function addOrderBy($field, $sortType) { if ($sortType != SORT_ASC && $sortType != SORT_DESC) { return $this; } $this->_orderBy[] = [ 'field' => $field, 'sortType' => $sortType ]; return $this; } /** * Сколько записей пропустить * @param $offset * @return $this */ public function offset($offset) { $this->_offset = $offset; return $this; } /** * Сколько всего записей вывести. * @param $limit * @return $this */ public function limit($limit) { $this->_limit = $limit; return $this; } /** * Добавление новых связей. * @param array $relations * @return $this * @throws \Exception */ public function with(array $relations) { if ($this->_modelClass == null) { throw new \Exception('Для использования метода необходимо передать модель таблицы через ActiveRecord'); } $this->_relations = $relations; return $this; } /** * Функция добавляет \PDO для запросов * @param \PDO $pdo * @return $this */ public function setDb(\PDO $pdo) { $this->_pdo = &$pdo; return $this; } /** * @param $tableName * @param array $select * @param array $where * @param array $group * @param array $order * @param null $offset * @param null $limit * * Первый элемент массива будет сам sql запрос, * второй элемент массива будет array для execute pdo * @return array */ public static function generateSqlCode($tableName, array $select, array $where, array $group, array $order, $offset = null, $limit = null) { $whereType = 0; $whereAttribute = 1; $whereCondition = 2; $whereValue = 3; if (count($select) == 0) { $select = ['*']; } $sql = ' SELECT ' . implode(',', $select) . ' FROM `' . $tableName . '` '; $executeConditionParams = []; $whereString = ''; if (count($where) > 0) { $whereString = ' WHERE '; $i = 0; foreach ($where as $whereItem) { $whereConditionString = null; // ['AND|OR', $attribute, $condition, $value] if ($whereItem[$whereCondition] == 'LIKE' || $whereItem[$whereCondition] == 'like') { $whereConditionString = ' ' . $whereItem[$whereAttribute] . ' LIKE "%' . str_replace(['"', "'", "SELECT", "INSERT", "UPDATE", "DELETE", "DROP"],'', trim(htmlspecialchars($whereItem[$whereValue]))) . '%"'; } else { // проверка на условие вида IN // в QueryBuilder это условие выглядит следующим образом // ->where([ // 'field' => [1, 2, 3] // ]); if (is_array($whereItem[$whereValue])) { $whereConditionString = ' ' . $whereItem[$whereAttribute] .' IN (' . implode(',', $whereItem[$whereValue]) . ')'; } else { if ($whereItem[$whereValue] instanceof Expression) { // // условие является каким-то SQL выражением // в этом случае не нужно обрабатывать его средствами PHP $whereConditionString = ' ' . $whereItem[$whereAttribute] . ' ' . $whereItem[$whereCondition] . ' ' . $whereItem[$whereValue]->getValue(); } else { // здесь нет какого-либо условия, здесь // мы просто подготавливаем шаблоны вида // key = value, где = одно из условий $whereConditionString = ' ' . $whereItem[$whereAttribute] . ' ' . $whereItem[$whereCondition] . ' :' . $whereItem[$whereAttribute]; $executeConditionParams[':' . $whereItem[$whereAttribute]] = $whereItem[$whereValue]; } } } if ($i == 0) { $whereString .= $whereConditionString; } else { $whereString .= ' ' . $whereItem[$whereType] . $whereConditionString; } $i = $i + 1; } } $sql .= $whereString; // группировка if (count($group) > 0) { $sql .= ' GROUP BY ' . implode(',', $group); } // сортировка if (count($order) > 0) { $orderArray = []; foreach ($order as $orderItem) { // field, sortType $sortType = $orderItem['sortType'] == SORT_DESC ? 'DESC' : 'ASC'; $orderArray[] = $orderItem['field'] . ' ' . $sortType; } $sql .= ' ORDER BY ' . implode(',', $orderArray); } if ($offset !== null && $limit !== null) { $sql .= ' LIMIT ' . (int)$offset . ',' . (int)$limit; } else { if ($limit > 0) { $sql .= ' LIMIT ' . (int)$limit; } } return [ $sql, $executeConditionParams ]; } /** * Формируем SQL запрос к базе данных */ public function query() { $modelClass = null; if ($this->_modelClass != null) { $modelClass = new $this->_modelClass(); } if ($this->_pdo instanceof \PDO == false) { throw new \Exception("Невозможно выполнить запрос. PDO объект не найден"); } $sqlArray = static::generateSqlCode( $this->_tableName, $this->_select, $this->_where, $this->_groupBy, $this->_orderBy, $this->_offset, $this->_limit ); $sth = $this->_pdo->prepare($sqlArray[0]); $sth->execute($sqlArray[1]); $this->_items = $sth->fetchAll(); // если был передан класс из $activeRecord // то мы должны заполнить массив $items этим классом и потом вернуть их if ($this->_modelClass != null) { foreach ($this->_items as $key => $item) { $model = new $this->_modelClass(); foreach ($item as $key2 => $value) { $model->{$key2} = $value; } $model->resetModifiedAttributes(); $this->_items[$key] = $model; } } if (count($this->_items) > 0 && count($this->_relations) > 0 && $modelClass != null) { foreach ($this->_relations as $key => $relation) { /** @var RelationAttribute */ if (is_callable($relation)) { $relationClass = $modelClass->{'get' . ucfirst($key)}(); $relationClass->select(call_user_func($relation)); $relationName = $key; } else { $relationClass = $modelClass->{'get' . ucfirst($relation)}(); $relationName = $relation; } // Подробнее о переменной $relationName // когда мы делаем связь через with(), то указываем название связи // переменная $relationName как раз и содержит это название. // к примеру есть вот такой код: // // ->with([ // 'user' // ]) // // то после прохода foreach выше в переменной $relationName // будет название user, ну или то, что в нее подставили. // // Здесь будет связь вида 'id' из родительской таблицы // в дочернию таблицу связи. // пример ['id' => 'user_id'] $where = $relationClass->getCondition(); $whereConditionKey = array_keys($where)[0]; $values = []; foreach ($this->_items as $item) { $values[] = $item->{$whereConditionKey}; } // создаем экземпляр этого класса, // чтобы потом заполнить массив $this->_items по полю $relationName $thisClass = new self($relationClass->getTargetClassName()); $thisClass->from($relationClass->getTableName()) ->select($relationClass->getSelect()) ->setDb($this->_pdo) ->where([ $where[$whereConditionKey] => $values ]); $items = $thisClass->all(); foreach ($this->_items as $keyItem => $item) { if ($relationClass->getRelationType() == RelationAttribute::RELATION_TYPE_HAS_ONE) { $this->_items[$keyItem]->{$relationName} = null; } else { $this->_items[$keyItem]->{$relationName} = []; } foreach ($items as $keyRelation => $relationItem) { if ($relationItem->$where[$whereConditionKey] == $item->$whereConditionKey) { $this->_items[$keyItem]->{$relationName}[] = $relationItem; } } if (isset($this->_items[$keyItem]->{$relationName}) && count($this->_items[$keyItem]->{$relationName}) > 0) { if ($relationClass->getRelationType() == RelationAttribute::RELATION_TYPE_HAS_ONE) { $this->_items[$keyItem]->{$relationName} = $this->_items[$keyItem]->{$relationName}[0]; } } } } } if ($this->_one == true) { if (count($this->_items) > 0) { $this->_items = $this->_items[0]; } } return $this->_items; } public function one() { $this->_one = true; return $this->query(); } public function all() { $this->_one; return $this->query(); } }
/app/core/models/
..
2019-02-12
validators
2026-05-25
ActiveRecord.php
2023-09-07
10 .
ActiveRecord.php~
2016-12-23
10 .
BaseModel.php
2016-12-22
167
Command.php
2016-12-22
199
Expression.php
2016-12-22
329
Form.php
2016-12-22
6 .
Mail.php
2016-12-22
762
MySQLCommand.php
2019-01-31
1 .
NoInjection.php
2019-01-30
987
QueryBuilder.php
2020-03-10
20 .
RelationAttribute.php
2016-12-22
5 .
SqlModel.php
2016-11-24
98
WhereConditionHelper.php
2019-01-30
813
/app/core/models
1
2
3
..
