* @author Carsten Brandt * @since 2.0 */ trait ActiveQueryTrait { /** * @var string the name of the ActiveRecord class. */ public $modelClass; /** * @var array list of relations that this query should be performed with */ public $with; /** * @var boolean whether to return each record as an array. If false (default), an object * of [[modelClass]] will be created to represent each record. */ public $asArray; /** * PHP magic method. * This method allows calling static method defined in [[modelClass]] via this query object. * It is mainly implemented for supporting the feature of scope. * @param string $name the method name to be called * @param array $params the parameters passed to the method * @return mixed the method return result */ public function __call($name, $params) { if (method_exists($this->modelClass, $name)) { array_unshift($params, $this); call_user_func_array([$this->modelClass, $name], $params); return $this; } else { return parent::__call($name, $params); } } /** * Sets the [[asArray]] property. * @param boolean $value whether to return the query results in terms of arrays instead of Active Records. * @return static the query object itself */ public function asArray($value = true) { $this->asArray = $value; return $this; } /** * Specifies the relations with which this query should be performed. * * The parameters to this method can be either one or multiple strings, or a single array * of relation names and the optional callbacks to customize the relations. * * A relation name can refer to a relation defined in [[modelClass]] * or a sub-relation that stands for a relation of a related record. * For example, `orders.address` means the `address` relation defined * in the model class corresponding to the `orders` relation. * * The followings are some usage examples: * * ~~~ * // find customers together with their orders and country * Customer::find()->with('orders', 'country')->all(); * // find customers together with their orders and the orders' shipping address * Customer::find()->with('orders.address')->all(); * // find customers together with their country and orders of status 1 * Customer::find()->with([ * 'orders' => function($query) { * $query->andWhere('status = 1'); * }, * 'country', * ])->all(); * ~~~ * * @return static the query object itself */ public function with() { $this->with = func_get_args(); if (isset($this->with[0]) && is_array($this->with[0])) { // the parameter is given as an array $this->with = $this->with[0]; } return $this; } /** * Sets the [[indexBy]] property. * @param string|callable $column the name of the column by which the query results should be indexed by. * This can also be a callable (e.g. anonymous function) that returns the index value based on the given * row or model data. The signature of the callable should be: * * ~~~ * // $model is an AR instance when `asArray` is false, * // or an array of column values when `asArray` is true. * function ($model) * { * // return the index value corresponding to $model * } * ~~~ * * @return static the query object itself */ public function indexBy($column) { return parent::indexBy($column); } /** * Converts found rows into model instances * @param array $rows * @return array|ActiveRecord[] */ private function createModels($rows) { $models = []; if ($this->asArray) { if ($this->indexBy === null) { return $rows; } foreach ($rows as $row) { if (is_string($this->indexBy)) { $key = $row[$this->indexBy]; } else { $key = call_user_func($this->indexBy, $row); } $models[$key] = $row; } } else { /** @var ActiveRecord $class */ $class = $this->modelClass; if ($this->indexBy === null) { foreach ($rows as $row) { $models[] = $class::create($row); } } else { foreach ($rows as $row) { $model = $class::create($row); if (is_string($this->indexBy)) { $key = $model->{$this->indexBy}; } else { $key = call_user_func($this->indexBy, $model); } $models[$key] = $model; } } } return $models; } /** * @param ActiveRecord[] $models * @param array $with */ private function populateRelations(&$models, $with) { $primaryModel = new $this->modelClass; $relations = $this->normalizeRelations($primaryModel, $with); foreach ($relations as $name => $relation) { if ($relation->asArray === null) { // inherit asArray from primary query $relation->asArray = $this->asArray; } $relation->findWith($name, $models); } } /** * @param ActiveRecord $model * @param array $with * @return ActiveRelationInterface[] */ private function normalizeRelations($model, $with) { $relations = []; foreach ($with as $name => $callback) { if (is_integer($name)) { $name = $callback; $callback = null; } if (($pos = strpos($name, '.')) !== false) { // with sub-relations $childName = substr($name, $pos + 1); $name = substr($name, 0, $pos); } else { $childName = null; } if (!isset($relations[$name])) { $relation = $model->getRelation($name); $relation->primaryModel = null; $relations[$name] = $relation; } else { $relation = $relations[$name]; } if (isset($childName)) { $relation->with[$childName] = $callback; } elseif ($callback !== null) { call_user_func($callback, $relation); } } return $relations; } }