You can not select more than 25 topics
			Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
		
		
		
		
		
			
		
			
				
					
					
						
							109 lines
						
					
					
						
							3.1 KiB
						
					
					
				
			
		
		
	
	
							109 lines
						
					
					
						
							3.1 KiB
						
					
					
				<?php | 
						|
/** | 
						|
 * @link http://www.yiiframework.com/ | 
						|
 * @copyright Copyright (c) 2008 Yii Software LLC | 
						|
 * @license http://www.yiiframework.com/license/ | 
						|
 */ | 
						|
 | 
						|
namespace yii\mongodb; | 
						|
 | 
						|
use yii\db\ActiveQueryInterface; | 
						|
use yii\db\ActiveQueryTrait; | 
						|
 | 
						|
/** | 
						|
 * ActiveQuery represents a Mongo query associated with an Active Record class. | 
						|
 * | 
						|
 * ActiveQuery instances are usually created by [[ActiveRecord::find()]]. | 
						|
 * | 
						|
 * Because ActiveQuery extends from [[Query]], one can use query methods, such as [[where()]], | 
						|
 * [[orderBy()]] to customize the query options. | 
						|
 * | 
						|
 * ActiveQuery also provides the following additional query options: | 
						|
 * | 
						|
 * - [[with()]]: list of relations that this query should be performed with. | 
						|
 * - [[asArray()]]: whether to return each record as an array. | 
						|
 * | 
						|
 * These options can be configured using methods of the same name. For example: | 
						|
 * | 
						|
 * ~~~ | 
						|
 * $customers = Customer::find()->with('orders')->asArray()->all(); | 
						|
 * ~~~ | 
						|
 * | 
						|
 * @property Collection $collection Collection instance. This property is read-only. | 
						|
 * | 
						|
 * @author Paul Klimov <klimov.paul@gmail.com> | 
						|
 * @since 2.0 | 
						|
 */ | 
						|
class ActiveQuery extends Query implements ActiveQueryInterface | 
						|
{ | 
						|
	use ActiveQueryTrait; | 
						|
 | 
						|
	/** | 
						|
	 * Executes query and returns all results as an array. | 
						|
	 * @param Connection $db the Mongo connection used to execute the query. | 
						|
	 * If null, the Mongo connection returned by [[modelClass]] will be used. | 
						|
	 * @return array the query results. If the query results in nothing, an empty array will be returned. | 
						|
	 */ | 
						|
	public function all($db = null) | 
						|
	{ | 
						|
		$cursor = $this->buildCursor($db); | 
						|
		$rows = $this->fetchRows($cursor); | 
						|
		if (!empty($rows)) { | 
						|
			$models = $this->createModels($rows); | 
						|
			if (!empty($this->with)) { | 
						|
				$this->findWith($this->with, $models); | 
						|
			} | 
						|
			return $models; | 
						|
		} else { | 
						|
			return []; | 
						|
		} | 
						|
	} | 
						|
 | 
						|
	/** | 
						|
	 * Executes query and returns a single row of result. | 
						|
	 * @param Connection $db the Mongo connection used to execute the query. | 
						|
	 * If null, the Mongo connection returned by [[modelClass]] will be used. | 
						|
	 * @return ActiveRecord|array|null a single row of query result. Depending on the setting of [[asArray]], | 
						|
	 * the query result may be either an array or an ActiveRecord object. Null will be returned | 
						|
	 * if the query results in nothing. | 
						|
	 */ | 
						|
	public function one($db = null) | 
						|
	{ | 
						|
		$row = parent::one($db); | 
						|
		if ($row !== false) { | 
						|
			if ($this->asArray) { | 
						|
				$model = $row; | 
						|
			} else { | 
						|
				/** @var ActiveRecord $class */ | 
						|
				$class = $this->modelClass; | 
						|
				$model = $class::create($row); | 
						|
			} | 
						|
			if (!empty($this->with)) { | 
						|
				$models = [$model]; | 
						|
				$this->findWith($this->with, $models); | 
						|
				$model = $models[0]; | 
						|
			} | 
						|
			return $model; | 
						|
		} else { | 
						|
			return null; | 
						|
		} | 
						|
	} | 
						|
 | 
						|
	/** | 
						|
	 * Returns the Mongo collection for this query. | 
						|
	 * @param Connection $db Mongo connection. | 
						|
	 * @return Collection collection instance. | 
						|
	 */ | 
						|
	public function getCollection($db = null) | 
						|
	{ | 
						|
		/** @var ActiveRecord $modelClass */ | 
						|
		$modelClass = $this->modelClass; | 
						|
		if ($db === null) { | 
						|
			$db = $modelClass::getDb(); | 
						|
		} | 
						|
		if ($this->from === null) { | 
						|
			$this->from = $modelClass::collectionName(); | 
						|
		} | 
						|
		return $db->getCollection($this->from); | 
						|
	} | 
						|
} |