diff --git a/framework/db/ar/ActiveFinder.php b/framework/db/ar/ActiveFinder.php deleted file mode 100644 index 3334d79..0000000 --- a/framework/db/ar/ActiveFinder.php +++ /dev/null @@ -1,601 +0,0 @@ - - * @link http://www.yiiframework.com/ - * @copyright Copyright © 2008-2012 Yii Software LLC - * @license http://www.yiiframework.com/license/ - */ - -namespace yii\db\ar; - -use yii\base\Object; -use yii\base\VectorIterator; -use yii\db\dao\Query; -use yii\db\Exception; - -/** - * ActiveFinder.php is ... - * - * @property integer $count - * - * @author Qiang Xue - * @since 2.0 - */ -class ActiveFinder extends \yii\base\Object -{ - /** - * @var \yii\db\dao\Connection - */ - public $connection; - - public function __construct($connection, $config = array()) - { - $this->connection = $connection; - parent::__construct($config); - } - - /** - * @param ActiveQuery $query - */ - public function find($query, $returnScalar = false) - { - if (!empty($query->with)) { - return $this->findWithRelations($query, $returnScalar); - } - - if ($query->sql !== null) { - $sql = $query->sql; - } else { - $modelClass = $query->modelClass; - $tableName = $modelClass::tableName(); - if ($query->from === null) { - if ($query->tableAlias !== null) { - $tableName .= ' ' . $query->tableAlias; - } - $query->from = array($tableName); - } - $this->applyScopes($query); - $sql = $this->connection->getQueryBuilder()->build($query); - - if ($query->tableAlias !== null) { - $alias = $this->connection->quoteTableName($query->tableAlias) . '.'; - } else { - $alias = $this->connection->quoteTableName($tableName) . '.'; - } - $tokens = array( - '@.' => $alias, - $this->connection->quoteTableName('@', true) . '.' => $alias, - ); - $sql = strtr($sql, $tokens); - } - $command = $this->connection->createCommand($sql, $query->params); - - if ($returnScalar) { - return $command->queryScalar(); - } else { - $rows = $command->queryAll(); - return $this->createRecords($query, $rows); - } - } - - private $_joinCount; - private $_tableAliases; - private $_hasMany; - - /** - * @param ActiveQuery $query - * @return array - */ - protected function findWithRelations($query, $returnScalar = false) - { - $this->_joinCount = 0; - $this->_tableAliases = array(); - $this->_hasMany = false; - $joinTree = new JoinElement($this->_joinCount++, $query, null, null); - - if ($query->sql !== null) { - $command = $this->connection->createCommand($query->sql, $query->params); - if ($returnScalar) { - return $command->queryScalar(); - } - $rows = $command->queryAll(); - $records = $this->createRecords($query, $rows); - $modelClass = $query->modelClass; - $table = $modelClass::getMetaData()->table; - foreach ($records as $record) { - $pk = array(); - foreach ($table->primaryKey as $name) { - $pk[] = $record[$name]; - } - $pk = count($pk) === 1 ? $pk[0] : serialize($pk); - $joinTree->records[$pk] = $record; - } - - $q = new ActiveQuery($modelClass); - $q->with = $query->with; - $q->tableAlias = 't'; - $q->asArray = $query->asArray; - $q->index = $query->index; - $q->select = $table->primaryKey; - $this->addPkCondition($q, $table, $rows, 't.'); - $joinTree->query = $query = $q; - } - - $this->buildJoinTree($joinTree, $query->with); - $this->initJoinTree($joinTree); - - $q = new Query; - $this->buildJoinQuery($joinTree, $q, $returnScalar); - - if ($returnScalar) { - return $q->createCommand($this->connection)->queryScalar(); - } else { - if ($this->_hasMany && ($query->limit > 0 || $query->offset > 0)) { - $this->limitQuery($query, $q); - } - $command = $q->createCommand($this->connection); - $rows = $command->queryAll(); - $joinTree->populateData($rows); - return $query->index === null ? array_values($joinTree->records) : $joinTree->records; - } - } - - /** - * @param ActiveRecord $record - * @param ActiveRelation $relation - * @return array - */ - public function findWithRecord($record, $relation) - { - $this->_joinCount = 0; - $this->_tableAliases = array(); - $this->_hasMany = false; - $query = new ActiveQuery(get_class($record)); - $modelClass = $query->modelClass; - $table = $modelClass::getMetaData()->table; - $query->select = $table->primaryKey; - $query->limit = $relation->limit; - $query->offset = $relation->offset; - $joinTree = new JoinElement($this->_joinCount++, $query, null, null); - $child = $this->buildJoinTree($joinTree, $relation->name); - $child->query = $relation; - $child->container = null; - $this->buildJoinTree($child, $relation->with); - $this->initJoinTree($joinTree); - - $pk = $record->getPrimaryKey(true); - $this->addPkCondition($query, $table, array($pk), $query->tableAlias . '.'); - - $q = new Query; - $this->buildJoinQuery($joinTree, $q); - - if ($this->_hasMany && ($query->limit > 0 || $query->offset > 0)) { - $this->limitQuery($query, $q); - } - - $rows = $q->createCommand($this->connection)->queryAll(); - $child->populateData($rows); - - $records = $relation->index === null ? array_values($child->records) : $child->records; - if ($relation->hasMany) { - return $records; - } else { - return $records === array() ? null : reset($records); - } - } - - protected function createRecords($query, $rows) - { - $records = array(); - if ($query->asArray) { - if ($query->index === null) { - return $rows; - } - foreach ($rows as $row) { - $records[$row[$query->index]] = $row; - } - } else { - /** @var $class ActiveRecord */ - $class = $query->modelClass; - if ($query->index === null) { - foreach ($rows as $row) { - $records[] = $class::create($row); - } - } else { - foreach ($rows as $row) { - $records[$row[$query->index]] = $class::create($row); - } - } - } - return $records; - } - - protected function applyScopes($query) - { - /** @var $class ActiveRecord */ - $class = $query->modelClass; - $class::defaultScope($query); - if (is_array($query->scopes)) { - $model = new $class; - foreach ($query->scopes as $name => $params) { - if (is_string($params)) { - // scope name only without parameters - $name = $params; - $params = array(); - } - if (method_exists($class, $name)) { - array_unshift($params, $query); - call_user_func_array(array($model, $name), $params); - } else { - throw new Exception("$class has no scope named '$name'."); - } - } - } - } - - /** - * @param JoinElement $parent - * @param array|string $with - * @param array|\Closure $config - * @return null|JoinElement - * @throws \yii\db\Exception - */ - protected function buildJoinTree($parent, $with, $config = array()) - { - if (empty($with)) { - return null; - } - if (is_array($with)) { - foreach ($with as $name => $value) { - if (is_array($value) || $value instanceof \Closure) { - $this->buildJoinTree($parent, $name, $value); - } else { - $this->buildJoinTree($parent, $value); - } - } - return null; - } - - if (($pos = strrpos($with, '.')) !== false) { - $parent = $this->buildJoinTree($parent, substr($with, 0, $pos)); - $with = substr($with, $pos + 1); - } - - if (isset($parent->children[$with])) { - $child = $parent->children[$with]; - } else { - $modelClass = $parent->query->modelClass; - $relations = $modelClass::getMetaData()->relations; - if (!isset($relations[$with])) { - throw new Exception("$modelClass has no relation named '$with'."); - } - $relation = clone $relations[$with]; - if (is_string($relation->via)) { - // join via an existing relation - $parent2 = $this->buildJoinTree($parent, $relation->via); - if ($parent2->query->select === null) { - $parent2->query->select = false; - unset($parent2->container->relations[$parent2->query->name]); - } - $child = new JoinElement($this->_joinCount++, $relation, $parent2, $parent); - } elseif (is_array($relation->via)) { - // join via a pivoting table - $r = new ActiveRelation; - $r->name = 'vt' . $this->_joinCount; - $r->hasMany = $relation->hasMany; - - foreach ($relation->via as $name => $value) { - $r->$name = $value; - } - - $r->select = false; - if ($r->joinType === null) { - $r->joinType = $relation->joinType; - } - - $parent2 = new JoinElement($this->_joinCount++, $r, $parent, $parent); - $child = new JoinElement($this->_joinCount++, $relation, $parent2, $parent); - - } else { - $child = new JoinElement($this->_joinCount++, $relation, $parent, $parent); - } - } - - if ($config instanceof \Closure) { - $config($child->query); - } else { - foreach ($config as $name => $value) { - $child->query->$name = $value; - } - } - - return $child; - } - - /** - * @param JoinElement $element - */ - protected function initJoinTree($element) - { - if ($element->query->tableAlias !== null) { - $alias = $element->query->tableAlias; - } elseif ($element->query instanceof ActiveRelation) { - $alias = $element->query->name; - } else { - $alias = 't'; - } - if ($element->query instanceof ActiveRelation) { - if ($element->query->hasMany) { - $this->_hasMany = true; - } - if ($element->parent->query->asArray !== null && $element->query->asArray === null) { - $element->query->asArray = $element->parent->query->asArray; - } - } - $count = 0; - while (isset($this->_tableAliases[$alias])) { - $alias = 't' . $count++; - } - $this->_tableAliases[$alias] = true; - $element->query->tableAlias = $alias; - - if ($element->records !== array()) { - $this->applyScopes($element->query); - } - - if ($element->container !== null && $element->query->asArray === null) { - $element->query->asArray = $element->container->query->asArray; - } - - foreach ($element->children as $child) { - $this->initJoinTree($child); - } - } - - /** - * @param JoinElement $element - * @param \yii\db\dao\Query $query - */ - protected function buildJoinQuery($element, $query, $keepSelect = false) - { - if ($element->parent) { - $prefixes = array( - '@.' => $element->query->tableAlias . '.', - '?.' => $element->parent->query->tableAlias . '.', - ); - $quotedPrefixes = array( - '@.' => $this->connection->quoteTableName($element->query->tableAlias, true) . '.', - '?.' => $this->connection->quoteTableName($element->parent->query->tableAlias, true) . '.', - ); - } else { - $prefixes = array( - '@.' => $element->query->tableAlias . '.', - ); - $quotedPrefixes = array( - '@.' => $this->connection->quoteTableName($element->query->tableAlias, true) . '.', - ); - $query->limit = $element->query->limit; - $query->offset = $element->query->offset; - } - - $qb = $this->connection->getQueryBuilder(); - - if ($keepSelect) { - if (!empty($element->query->select)) { - $select = $element->query->select; - if (is_string($select)) { - $select = explode(',', $select); - } - foreach ($select as $column) { - $query->select[] = strtr(trim($column), $prefixes); - } - } - } else { - foreach ($this->buildSelect($element, $element->query->select) as $column) { - $query->select[] = strtr($column, $prefixes); - } - } - - if ($element->query instanceof ActiveQuery) { - if ($element->query->from === null) { - $modelClass = $element->query->modelClass; - $tableName = $modelClass::tableName(); - if ($element->query->tableAlias !== null) { - $tableName .= ' ' . $element->query->tableAlias; - } - $query->from = array($tableName); - } else { - $query->from = $element->query->from; - } - } - - if (($where = $qb->buildCondition($element->query->where)) !== '') { - $query->andWhere(strtr($where, $quotedPrefixes)); - } - - if (($having = $qb->buildCondition($element->query->having)) !== '') { - $query->andHaving(strtr($having, $quotedPrefixes)); - } - - if ($element->query instanceof ActiveRelation) { - $joinType = $element->query->joinType ?: 'LEFT JOIN'; - if ($element->query->modelClass !== null) { - $modelClass = $element->query->modelClass; - $tableName = $this->connection->quoteTableName($modelClass::tableName()); - } else { - $tableName = $this->connection->quoteTableName($element->query->table); - } - $tableAlias = $this->connection->quoteTableName($element->query->tableAlias); - $join = "$joinType $tableName $tableAlias"; - $on = ''; - if (is_array($element->query->link)) { - foreach ($element->query->link as $pk => $fk) { - $pk = $quotedPrefixes['@.'] . $this->connection->quoteColumnName($pk, true); - $fk = $quotedPrefixes['?.'] . $this->connection->quoteColumnName($fk, true); - if ($on !== '') { - $on .= ' AND '; - } - $on .= "$pk = $fk"; - } - } - if ($element->query->on !== null) { - $condition = strtr($qb->buildCondition($element->query->on), $quotedPrefixes); - if ($on !== '') { - $on .= " AND ($condition)"; - } else { - $on = $condition; - } - } - if ($on !== '') { - $join .= ' ON ' . $on; - } - $query->join[] = $join; - } - - if ($element->query->join !== null) { - if (is_array($element->query->join)) { - foreach ($element->query->join as $join) { - if (is_array($join) && isset($join[2])) { - $join[2] = strtr($join[2], $quotedPrefixes); - } - $query->join[] = $join; - } - } else { - $query->join[] = strtr($element->query->join, $quotedPrefixes); - } - } - - if ($element->query->orderBy !== null) { - if (!is_array($element->query->orderBy)) { - $element->query->orderBy = preg_split('/\s*,\s*/', trim($element->query->orderBy), -1, PREG_SPLIT_NO_EMPTY); - } - foreach ($element->query->orderBy as $order) { - $query->orderBy[] = strtr($order, $prefixes); - } - } - - if ($element->query->groupBy !== null) { - if (!is_array($element->query->groupBy)) { - $element->query->groupBy = preg_split('/\s*,\s*/', trim($element->query->groupBy), -1, PREG_SPLIT_NO_EMPTY); - } - foreach ($element->query->groupBy as $group) { - $query->groupBy[] = strtr($group, $prefixes); - } - } - - if ($element->query->params !== null) { - $query->addParams($element->query->params); - } - - foreach ($element->children as $child) { - $this->buildJoinQuery($child, $query, $keepSelect); - } - } - - protected function buildSelect($element, $select) - { - if ($select === false) { - return array(); - } - $modelClass = $element->query->modelClass; - $table = $modelClass::getMetaData()->table; - $columns = array(); - $columnCount = 0; - $prefix = $element->query->tableAlias; - - foreach ($table->primaryKey as $column) { - $alias = "c{$element->id}_" . ($columnCount++); - $columns[] = "$prefix.$column AS $alias"; - $element->pkAlias[$column] = $alias; - $element->columnAliases[$alias] = $column; - } - - if (empty($select) || $select === '*') { - foreach ($table->columns as $column) { - if (!isset($element->pkAlias[$column->name])) { - $alias = "c{$element->id}_" . ($columnCount++); - $columns[] = "$prefix.{$column->name} AS $alias"; - $element->columnAliases[$alias] = $column->name; - } - } - } else { - if (is_string($select)) { - $select = explode(',', $select); - } - foreach ($select as $column) { - $column = trim($column); - if (preg_match('/^(.*?)\s+AS\s+(\w+)$/im', $column, $matches)) { - // if the column is already aliased - $element->columnAliases[$matches[2]] = $matches[2]; - $columns[] = $column; - } elseif (!isset($element->pkAlias[$column])) { - $alias = "c{$element->id}_" . ($columnCount++); - if (strpos($column, '(') !== false) { - $columns[] = "$column AS $alias"; - } else { - $columns[] = "$prefix.$column AS $alias"; - } - $element->columnAliases[$alias] = $column; - } - } - } - - // determine the actual index column(s) - if ($element->query->index !== null) { - $index = array_search($element->query->index, $element->columnAliases); - } - if (empty($index)) { - $index = $element->pkAlias; - if (count($index) === 1) { - $index = reset($element->pkAlias); - } - } - $element->key = $index; - - return $columns; - } - - protected function limitQuery($activeQuery, $query) - { - $q = clone $query; - $modelClass = $activeQuery->modelClass; - $table = $modelClass::getMetaData()->table; - $q->select = array(); - foreach ($table->primaryKey as $name) { - $q->select[] = $alias = $activeQuery->tableAlias . '.' . $name; - } - $q->distinct = true; - $rows = $q->createCommand($this->connection)->queryAll(); - $prefix = $activeQuery->tableAlias . '.'; - $this->addPkCondition($query, $table, $rows, $prefix); - $query->limit = $query->offset = null; - } - - protected function addPkCondition($query, $table, $rows, $prefix) - { - if (count($table->primaryKey) === 1 && count($rows) > 1) { - $name = $table->primaryKey[0]; - $values = array(); - foreach ($rows as $row) { - $values[] = $table->columns[$name]->typecast($row[$name]); - } - $query->andWhere(array('in', $prefix . $name, $values)); - } else { - $ors = array('or'); - foreach ($rows as $row) { - $hash = array(); - foreach ($table->primaryKey as $name) { - $value = $table->columns[$name]->typecast($row[$name]); - if (is_string($value)) { - $value = $this->connection->quoteValue($value); - } - $hash[$prefix . $name] = $value; - } - $ors[] = $hash; - } - $query->andWhere($ors); - } - } -} \ No newline at end of file diff --git a/framework/db/ar/ActiveMetaData.php b/framework/db/ar/ActiveMetaData.php deleted file mode 100644 index 0ff2e41..0000000 --- a/framework/db/ar/ActiveMetaData.php +++ /dev/null @@ -1,103 +0,0 @@ - - * @since 2.0 - */ -class ActiveMetaData -{ - /** - * @var ActiveMetaData[] list of ActiveMetaData instances indexed by the model class names - */ - public static $instances; - /** - * @var TableSchema the table schema information - */ - public $table; - /** - * @var string the model class name - */ - public $modelClass; - /** - * @var ActiveRecord the model instance that can be used to access non-static methods - */ - public $model; - - /** - * Returns an instance of ActiveMetaData for the specified model class. - * Note that each model class only has a single ActiveMetaData instance. - * This method will only create the ActiveMetaData instance if it is not previously - * done so for the specified model class. - * @param string $modelClass the model class name. Make sure the class name do NOT have a leading backslash "\". - * @param boolean $refresh whether to recreate the ActiveMetaData instance. Defaults to false. - * @return ActiveMetaData the ActiveMetaData instance for the specified model class. - */ - public static function getInstance($modelClass, $refresh = false) - { - if (isset(self::$instances[$modelClass]) && !$refresh) { - return self::$instances[$modelClass]; - } else { - return self::$instances[$modelClass] = new self($modelClass); - } - } - - /** - * Constructor. - * @param string $modelClass the model class name - */ - public function __construct($modelClass) - { - $this->modelClass = $modelClass; - $this->model = new $modelClass; - $tableName = $this->model->tableName(); - $this->table = $this->model->getDbConnection()->getDriver()->getTableSchema($tableName); - if ($this->table === null) { - throw new Exception("Unable to find table '$tableName' for ActiveRecord class '$modelClass'."); - } - $primaryKey = $this->model->primaryKey(); - if ($primaryKey !== $this->table->primaryKey) { - $this->table->fixPrimaryKey($primaryKey); - } elseif ($primaryKey === null) { - throw new Exception("The table '$tableName' for ActiveRecord class '$modelClass' does not have a primary key."); - } - } - - /** - * Adds a relation. - * - * $config is an array with three elements: - * relation type, the related active record class and the foreign key. - * - * @throws Exception - * @param string $name $name Name of the relation. - * @param array $config $config Relation parameters. - * @return void - */ - public function addRelation($name, $config) - { - if (preg_match('/^(\w+)\s*:\s*\\\\?([\w\\\\]+)(\[\])?$/', $name, $matches)) { - if (is_string($config)) { - $config = array('on' => $config); - } - $relation = new ActiveRelation($config); - $relation->name = $matches[1]; - $modelClass = $matches[2]; - if (strpos($modelClass, '\\') !== false) { - $relation->modelClass = ltrim($modelClass, '\\'); - } else { - $relation->modelClass = dirname($this->modelClass) . '\\' . $modelClass; - } - $relation->hasMany = isset($matches[3]); - $this->relations[$relation->name] = $relation; - } else { - throw new Exception("{$this->modelClass} has an invalid relation: $name"); - } - } -} \ No newline at end of file diff --git a/framework/db/ar/BaseActiveQuery.php b/framework/db/ar/BaseActiveQuery.php deleted file mode 100644 index 5b61644..0000000 --- a/framework/db/ar/BaseActiveQuery.php +++ /dev/null @@ -1,107 +0,0 @@ - - * @link http://www.yiiframework.com/ - * @copyright Copyright © 2008-2012 Yii Software LLC - * @license http://www.yiiframework.com/license/ - */ - -namespace yii\db\ar; - -use yii\db\dao\BaseQuery; - -/** - * @author Qiang Xue - * @since 2.0 - */ -class BaseActiveQuery extends BaseQuery -{ - /** - * @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 string the table alias to be used for query - */ - public $tableAlias; - /** - * @var string the name of the column that the result should be indexed by. - * This is only useful when the query result is returned as an array. - */ - public $index; - /** - * @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; - /** - * @var array list of scopes that should be applied to this query - */ - public $scopes; - - public function asArray($value = true) - { - $this->asArray = $value; - return $this; - } - - 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; - } - - public function index($column) - { - $this->index = $column; - return $this; - } - - public function tableAlias($value) - { - $this->tableAlias = $value; - return $this; - } - - public function scopes($names) - { - $this->scopes = $names; - return $this; - } - - protected function createModels($rows) - { - $models = array(); - if ($this->asArray) { - if ($this->index === null) { - return $rows; - } - foreach ($rows as $row) { - $models[$row[$this->index]] = $row; - } - } else { - /** @var $class ActiveRecord */ - $class = $this->modelClass; - if ($this->index === null) { - foreach ($rows as $row) { - $models[] = $class::create($row); - } - } else { - foreach ($rows as $row) { - $models[$row[$this->index]] = $class::create($row); - } - } - } - return $models; - } -} diff --git a/framework/db/ar/HasManyRelation.php b/framework/db/ar/HasManyRelation.php deleted file mode 100644 index b62ed1d..0000000 --- a/framework/db/ar/HasManyRelation.php +++ /dev/null @@ -1,8 +0,0 @@ - - * @link http://www.yiiframework.com/ - * @copyright Copyright © 2008-2012 Yii Software LLC - * @license http://www.yiiframework.com/license/ - */ - -namespace yii\db\ar; - -use yii\base\VectorIterator; -use yii\db\dao\Query; -use yii\db\Exception; - - -class JoinElement -{ - /** - * @var integer ID of this join element - */ - public $id; - /** - * @var BaseActiveQuery - */ - public $query; - /** - * @var JoinElement the parent element that this element needs to join with - */ - public $parent; - public $container; - /** - * @var JoinElement[] the child elements that need to join with this element - */ - public $children = array(); - /** - * @var JoinElement[] the child elements that have corresponding relations declared in the AR class of this element - */ - public $relations = array(); - /** - * @var array column aliases (alias => original name) - */ - public $columnAliases = array(); - /** - * @var array primary key column aliases (original name => alias) - */ - public $pkAlias = array(); - /** - * @var string|array the column(s) used for index the query results - */ - public $key; - /** - * @var array query results for this element (PK value => AR instance or data array) - */ - public $records = array(); - public $related = array(); - - /** - * @param integer $id - * @param ActiveRelation|ActiveQuery $query - * @param null|JoinElement $parent - * @param null|JoinElement $container - */ - public function __construct($id, $query, $parent, $container) - { - $this->id = $id; - $this->query = $query; - if ($parent !== null) { - $this->parent = $parent; - $this->container = $container; - $parent->children[$query->name] = $this; - if ($query->select !== false) { - $container->relations[$query->name] = $this; - } - } - } - - public function populateData($rows) - { - if ($this->container === null) { - foreach ($rows as $row) { - if (($key = $this->getKeyValue($row)) !== null && !isset($this->records[$key])) { - $this->records[$key] = $this->createRecord($row); - } - } - } else { - foreach ($rows as $row) { - $key = $this->getKeyValue($row); - $containerKey = $this->container->getKeyValue($row); - if ($key === null || $containerKey === null || isset($this->related[$containerKey][$key])) { - continue; - } - $this->related[$containerKey][$key] = true; - if ($this->query->asArray) { - if (isset($this->records[$key])) { - if ($this->query->hasMany) { - if ($this->query->index !== null) { - $this->container->records[$containerKey][$this->query->name][$key] =& $this->records[$key]; - } else { - $this->container->records[$containerKey][$this->query->name][] =& $this->records[$key]; - } - } else { - $this->container->records[$containerKey][$this->query->name] =& $this->records[$key]; - } - } else { - $record = $this->createRecord($row); - if ($this->query->hasMany) { - if ($this->query->index !== null) { - $this->container->records[$containerKey][$this->query->name][$key] = $record; - $this->records[$key] =& $this->container->records[$containerKey][$this->query->name][$key]; - } else { - $count = count($this->container->records[$containerKey][$this->query->name]); - $this->container->records[$containerKey][$this->query->name][] = $record; - $this->records[$key] =& $this->container->records[$containerKey][$this->query->name][$count]; - } - } else { - $this->container->records[$containerKey][$this->query->name] = $record; - $this->records[$key] =& $this->container->records[$containerKey][$this->query->name]; - } - } - } else { - if (isset($this->records[$key])) { - $record = $this->records[$key]; - } else { - $this->records[$key] = $record = $this->createRecord($row); - } - $this->container->records[$containerKey]->addRelatedRecord($this->query, $record); - } - } - } - - foreach ($this->relations as $child) { - $child->populateData($rows); - } - } - - protected function getKeyValue($row) - { - if (is_array($this->key)) { - $key = array(); - foreach ($this->key as $alias) { - if (!isset($row[$alias])) { - return null; - } - $key[] = $row[$alias]; - } - return serialize($key); - } else { - return $row[$this->key]; - } - } - - protected function createRecord($row) - { - $record = array(); - foreach ($this->columnAliases as $alias => $name) { - $record[$name] = $row[$alias]; - } - if ($this->query->asArray) { - foreach ($this->relations as $child) { - $record[$child->query->name] = $child->query->hasMany ? array() : null; - } - } else { - $modelClass = $this->query->modelClass; - $record = $modelClass::create($record); - foreach ($this->relations as $child) { - $record->{$child->query->name} = $child->query->hasMany ? array() : null; - } - } - return $record; - } -} \ No newline at end of file diff --git a/framework/db/ar/ManyManyRelation.php b/framework/db/ar/ManyManyRelation.php deleted file mode 100644 index 7624623..0000000 --- a/framework/db/ar/ManyManyRelation.php +++ /dev/null @@ -1,10 +0,0 @@ -link) || !is_array($this->link)) { - throw new \yii\base\Exception('invalid link'); - } - $this->addLinkCondition($parentRecords); - $records = $this->find(); - - /** @var array $map mapping key(s) to index of $parentRecords */ - $index = $this->buildRecordIndex($parentRecords, array_values($this->link)); - $this->initRecordRelation($parentRecords, $name); - foreach ($records as $record) { - $key = $this->getRecordKey($record, array_keys($this->link)); - if (isset($index[$key])) { - $parentRecords[$map[$key]][$name] = $record; - } - } - } - - protected function getRecordKey($record, $attributes) - { - if (isset($attributes[1])) { - $key = array(); - foreach ($attributes as $attribute) { - $key[] = is_array($record) ? $record[$attribute] : $record->$attribute; - } - return serialize($key); - } else { - $attribute = $attributes[0]; - return is_array($record) ? $record[$attribute] : $record->$attribute; - } - } - - protected function buildRecordIndex($records, $attributes) - { - $map = array(); - foreach ($records as $i => $record) { - $map[$this->getRecordKey($record, $attributes)] = $i; - } - return $map; - } - - protected function addLinkCondition($parentRecords) - { - $attributes = array_keys($this->link); - $values = array(); - if (isset($links[1])) { - // composite keys - foreach ($parentRecords as $record) { - $v = array(); - foreach ($this->link as $attribute => $link) { - $v[$attribute] = is_array($record) ? $record[$link] : $record->$link; - } - $values[] = $v; - } - } else { - // single key - $attribute = $this->link[$links[0]]; - foreach ($parentRecords as $record) { - $values[] = is_array($record) ? $record[$attribute] : $record->$attribute; - } - } - $this->andWhere(array('in', $attributes, $values)); - } -}