Class yii\mongodb\file\Query
Inheritance | yii\mongodb\file\Query » yii\mongodb\Query » yii\base\Component |
---|---|
Implements | yii\db\QueryInterface |
Uses Traits | yii\db\QueryTrait |
Subclasses | yii\mongodb\file\ActiveQuery |
Available since extension's version | 2.0 |
Source Code | https://github.com/yiisoft/yii2-mongodb/blob/master/src/file/Query.php |
Query represents Mongo "find" operation for GridFS collection.
Query behaves exactly as regular yii\mongodb\Query. Found files will be represented as arrays of file document attributes with additional 'file' key, which stores \MongoGridFSFile instance.
Public Properties
Property | Type | Description | Defined By |
---|---|---|---|
$collection | yii\mongodb\file\Collection | Collection instance. | yii\mongodb\file\Query |
$from | string|array | The collection to be selected from. | yii\mongodb\Query |
$options | array | Cursor options in format: optionKey => optionValue | yii\mongodb\Query |
$select | array | The fields of the results to return. | yii\mongodb\Query |
Public Methods
Method | Description | Defined By |
---|---|---|
addOptions() | Adds additional cursor options. | yii\mongodb\Query |
all() | Executes the query and returns all results as an array. | yii\mongodb\Query |
andFilterCompare() | Helper method for easy querying on values containing some common operators. | yii\mongodb\Query |
average() | Returns the average of the specified column values. | yii\mongodb\Query |
batch() | Starts a batch query. | yii\mongodb\Query |
buildCursor() | Builds the MongoDB cursor for this query. | yii\mongodb\Query |
column() | Executes the query and returns the first column of the result. | yii\mongodb\Query |
count() | Returns the number of records. | yii\mongodb\Query |
distinct() | Returns a list of distinct values for the given column across a collection. | yii\mongodb\Query |
each() | Starts a batch query and retrieves data row by row. | yii\mongodb\Query |
exists() | Returns a value indicating whether the query result contains any row of data. | yii\mongodb\Query |
from() | Sets the collection to be selected from. | yii\mongodb\Query |
getCollection() | Returns the Mongo collection for this query. | yii\mongodb\file\Query |
max() | Returns the maximum of the specified column values. | yii\mongodb\Query |
min() | Returns the minimum of the specified column values. | yii\mongodb\Query |
modify() | Performs 'findAndModify' query and returns a single row of result. | yii\mongodb\Query |
one() | Executes the query and returns a single row of result. | yii\mongodb\Query |
options() | Sets the cursor options. | yii\mongodb\Query |
populate() | Converts the raw query results into the format as specified by this query. | yii\mongodb\Query |
prepare() | Prepares for query building. | yii\mongodb\Query |
scalar() | Returns the query result as a scalar value. | yii\mongodb\Query |
select() | Sets the list of fields of the results to return. | yii\mongodb\Query |
sum() | Returns the sum of the specified column values. | yii\mongodb\Query |
Protected Methods
Method | Description | Defined By |
---|---|---|
aggregate() | Performs the aggregation for the given column. | yii\mongodb\Query |
fetchRows() | Fetches rows from the given Mongo cursor. | yii\mongodb\Query |
fetchRowsInternal() | yii\mongodb\Query |
Property Details
Collection instance.
Method Details
public $this addOptions ( $options ) | ||
$options | array |
Cursor options in format: optionName => optionValue |
return | $this |
The query object itself |
---|
public function addOptions($options)
{
if (is_array($this->options)) {
$this->options = array_merge($this->options, $options);
} else {
$this->options = $options;
}
return $this;
}
Defined in: yii\mongodb\Query::aggregate()
Performs the aggregation for the given column.
protected integer aggregate ( $column, $operator, $db ) | ||
$column | string |
Column name. |
$operator | string |
Aggregation operator. |
$db | yii\mongodb\Connection |
The database connection used to execute the query. |
return | integer |
Aggregation result. |
---|
protected function aggregate($column, $operator, $db)
{
if (!empty($this->emulateExecution)) {
return null;
}
$this->prepare();
$collection = $this->getCollection($db);
$pipelines = [];
if ($this->where !== null) {
$pipelines[] = ['$match' => $this->where];
}
$pipelines[] = [
'$group' => [
'_id' => '1',
'total' => [
'$' . $operator => '$' . $column
],
]
];
$result = $collection->aggregate($pipelines);
if (array_key_exists(0, $result)) {
return $result[0]['total'];
}
return null;
}
Defined in: yii\mongodb\Query::all()
Executes the query and returns all results as an array.
public array all ( $db = null ) | ||
$db | yii\mongodb\Connection |
The Mongo connection used to execute the query.
If this parameter is not given, the |
return | array |
The query results. If the query results in nothing, an empty array will be returned. |
---|
public function all($db = null)
{
if (!empty($this->emulateExecution)) {
return [];
}
$cursor = $this->buildCursor($db);
$rows = $this->fetchRows($cursor, true, $this->indexBy);
return $this->populate($rows);
}
Defined in: yii\mongodb\Query::andFilterCompare()
Helper method for easy querying on values containing some common operators.
The comparison operator is intelligently determined based on the first few characters in the given value and internally translated to a MongoDB operator. In particular, it recognizes the following operators if they appear as the leading characters in the given value: <: the column must be less than the given value ($lt). >: the column must be greater than the given value ($gt). <=: the column must be less than or equal to the given value ($lte). >=: the column must be greater than or equal to the given value ($gte). <>: the column must not be the same as the given value ($ne). Note that when $partialMatch is true, this would mean the value must not be a substring of the column. =: the column must be equal to the given value ($eq). none of the above: use the $defaultOperator
Note that when the value is empty, no comparison expression will be added to the search condition.
See also \yii\mongodb\Collection::buildCondition().
public $this andFilterCompare ( $name, $value, $defaultOperator = '=' ) | ||
$name | string |
Column name |
$value | string |
Column value |
$defaultOperator | string |
Defaults to =, performing an exact match. For example: use 'LIKE' or 'REGEX' for partial cq regex matching |
return | $this |
The query object itself. |
---|
public function andFilterCompare($name, $value, $defaultOperator = '=')
{
$matches = [];
if (preg_match('/^(<>|>=|>|<=|<|=)/', (string)$value, $matches)) {
$op = $matches[1];
$value = substr($value, strlen($op));
} else {
$op = $defaultOperator;
}
return $this->andFilterWhere([$op, $name, $value]);
}
Defined in: yii\mongodb\Query::average()
Returns the average of the specified column values.
public integer average ( $q, $db = null ) | ||
$q | string |
The column name. Make sure you properly quote column names in the expression. |
$db | yii\mongodb\Connection |
The Mongo connection used to execute the query.
If this parameter is not given, the |
return | integer |
The average of the specified column values. |
---|
public function average($q, $db = null)
{
if (!empty($this->emulateExecution)) {
return 0;
}
return $this->aggregate($q, 'avg', $db);
}
Defined in: yii\mongodb\Query::batch()
Starts a batch query.
A batch query supports fetching data in batches, which can keep the memory usage under a limit.
This method will return a yii\mongodb\BatchQueryResult object which implements the Iterator
interface
and can be traversed to retrieve the data in batches.
For example,
$query = (new Query)->from('user');
foreach ($query->batch() as $rows) {
// $rows is an array of 10 or fewer rows from user collection
}
public yii\mongodb\BatchQueryResult batch ( $batchSize = 100, $db = null ) | ||
$batchSize | integer |
The number of records to be fetched in each batch. |
$db | yii\mongodb\Connection |
The MongoDB connection. If not set, the "mongodb" application component will be used. |
return | yii\mongodb\BatchQueryResult |
The batch query result. It implements the |
---|
public function batch($batchSize = 100, $db = null)
{
return Yii::createObject([
'class' => BatchQueryResult::className(),
'query' => $this,
'batchSize' => $batchSize,
'db' => $db,
'each' => false,
]);
}
Defined in: yii\mongodb\Query::buildCursor()
Builds the MongoDB cursor for this query.
public \MongoDB\Driver\Cursor buildCursor ( $db = null ) | ||
$db | yii\mongodb\Connection |
The MongoDB connection used to execute the query. |
return | \MongoDB\Driver\Cursor |
Mongo cursor instance. |
---|
public function buildCursor($db = null)
{
$this->prepare();
$options = $this->options;
if (!empty($this->orderBy)) {
$options['sort'] = $this->orderBy;
}
$options['limit'] = $this->limit;
$options['skip'] = $this->offset;
$cursor = $this->getCollection($db)->find($this->composeCondition(), $this->select, $options);
return $cursor;
}
Defined in: yii\mongodb\Query::column()
Executes the query and returns the first column of the result.
Column _id
will be automatically excluded from select fields, if select() is not empty and
_id
is not selected explicitly.
public array column ( $db = null ) | ||
$db | yii\mongodb\Connection |
The MongoDB connection used to generate the query.
If this parameter is not given, the |
return | array |
The first column of the query result. An empty array is returned if the query results in nothing. |
---|
public function column($db = null)
{
if (!empty($this->emulateExecution)) {
return [];
}
$originSelect = (array)$this->select;
if (!isset($originSelect['_id']) && array_search('_id', $originSelect, true) === false) {
$this->select['_id'] = false;
}
if (is_string($this->indexBy) && $originSelect && count($originSelect) === 1) {
$this->select[] = $this->indexBy;
}
$cursor = $this->buildCursor($db);
$rows = $this->fetchRows($cursor, true);
if (empty($rows)) {
return [];
}
$results = [];
foreach ($rows as $row) {
$value = reset($row);
if ($this->indexBy === null) {
$results[] = $value;
} else {
if ($this->indexBy instanceof \Closure) {
$results[call_user_func($this->indexBy, $row)] = $value;
} else {
$results[$row[$this->indexBy]] = $value;
}
}
}
return $results;
}
Defined in: yii\mongodb\Query::count()
Returns the number of records.
public integer count ( $q = '*', $db = null ) | ||
$q | string |
Kept to match QueryInterface, its value is ignored. |
$db | yii\mongodb\Connection |
The Mongo connection used to execute the query.
If this parameter is not given, the |
return | integer |
Number of records |
---|---|---|
throws | yii\mongodb\Exception |
on failure. |
public function count($q = '*', $db = null)
{
if (!empty($this->emulateExecution)) {
return 0;
}
$this->prepare();
$collection = $this->getCollection($db);
return $collection->count($this->where, $this->options);
}
Defined in: yii\mongodb\Query::distinct()
Returns a list of distinct values for the given column across a collection.
public array distinct ( $q, $db = null ) | ||
$q | string |
Column to use. |
$db | yii\mongodb\Connection |
The MongoDB connection used to execute the query.
If this parameter is not given, the |
return | array |
Array of distinct values |
---|
public function distinct($q, $db = null)
{
if (!empty($this->emulateExecution)) {
return [];
}
$this->prepare();
$collection = $this->getCollection($db);
if ($this->where !== null) {
$condition = $this->where;
} else {
$condition = [];
}
$result = $collection->distinct($q, $condition);
if ($result === false) {
return [];
}
return $result;
}
Defined in: yii\mongodb\Query::each()
Starts a batch query and retrieves data row by row.
This method is similar to batch() except that in each iteration of the result, only one row of data is returned. For example,
$query = (new Query)->from('user');
foreach ($query->each() as $row) {
}
public yii\mongodb\BatchQueryResult each ( $batchSize = 100, $db = null ) | ||
$batchSize | integer |
The number of records to be fetched in each batch. |
$db | yii\mongodb\Connection |
The MongoDB connection. If not set, the "mongodb" application component will be used. |
return | yii\mongodb\BatchQueryResult |
The batch query result. It implements the |
---|
public function each($batchSize = 100, $db = null)
{
return Yii::createObject([
'class' => BatchQueryResult::className(),
'query' => $this,
'batchSize' => $batchSize,
'db' => $db,
'each' => true,
]);
}
Defined in: yii\mongodb\Query::exists()
Returns a value indicating whether the query result contains any row of data.
public boolean exists ( $db = null ) | ||
$db | yii\mongodb\Connection |
The Mongo connection used to execute the query.
If this parameter is not given, the |
return | boolean |
Whether the query result contains any row of data. |
---|
public function exists($db = null)
{
if (!empty($this->emulateExecution)) {
return false;
}
$cursor = $this->buildCursor($db);
foreach ($cursor as $row) {
return true;
}
return false;
}
Defined in: yii\mongodb\Query::fetchRows()
Fetches rows from the given Mongo cursor.
protected array|boolean fetchRows ( $cursor, $all = true, $indexBy = null ) | ||
$cursor | \MongoDB\Driver\Cursor |
Mongo cursor instance to fetch data from. |
$all | boolean |
Whether to fetch all rows or only first one. |
$indexBy | string|callable |
The column name or PHP callback, by which the query results should be indexed by. |
return | array|boolean |
Result. |
---|---|---|
throws | yii\mongodb\Exception |
on failure. |
protected function fetchRows($cursor, $all = true, $indexBy = null)
{
$token = 'fetch cursor id = ' . $cursor->getId();
Yii::info($token, __METHOD__);
try {
Yii::beginProfile($token, __METHOD__);
$result = $this->fetchRowsInternal($cursor, $all);
Yii::endProfile($token, __METHOD__);
return $result;
} catch (\Exception $e) {
Yii::endProfile($token, __METHOD__);
throw new Exception($e->getMessage(), (int) $e->getCode(), $e);
}
}
protected array|boolean fetchRowsInternal ( $cursor, $all ) | ||
$cursor | \MongoDB\Driver\Cursor |
Mongo cursor instance to fetch data from. |
$all | boolean |
Whether to fetch all rows or only first one. |
return | array|boolean |
Result. |
---|
protected function fetchRowsInternal($cursor, $all)
{
$result = [];
if ($all) {
foreach ($cursor as $row) {
$result[] = $row;
}
} else {
if ($row = current($cursor->toArray())) {
$result = $row;
} else {
$result = false;
}
}
return $result;
}
Defined in: yii\mongodb\Query::from()
Sets the collection to be selected from.
public $this from ( $collection ) | ||
$collection | ||
return | $this |
The query object itself. |
---|
public function from($collection)
{
$this->from = $collection;
return $this;
}
Returns the Mongo collection for this query.
public yii\mongodb\file\Collection getCollection ( $db = null ) | ||
$db | yii\mongodb\Connection |
Mongo connection. |
return | yii\mongodb\file\Collection |
Collection instance. |
---|
public function getCollection($db = null)
{
if ($db === null) {
$db = Yii::$app->get('mongodb');
}
return $db->getFileCollection($this->from);
}
Defined in: yii\mongodb\Query::max()
Returns the maximum of the specified column values.
public integer max ( $q, $db = null ) | ||
$q | string |
The column name. Make sure you properly quote column names in the expression. |
$db | yii\mongodb\Connection |
The MongoDB connection used to execute the query.
If this parameter is not given, the |
return | integer |
The maximum of the specified column values. |
---|
public function max($q, $db = null)
{
return $this->aggregate($q, 'max', $db);
}
Defined in: yii\mongodb\Query::min()
Returns the minimum of the specified column values.
public integer min ( $q, $db = null ) | ||
$q | string |
The column name. Make sure you properly quote column names in the expression. |
$db | yii\mongodb\Connection |
The MongoDB connection used to execute the query.
If this parameter is not given, the |
return | integer |
The minimum of the specified column values. |
---|
public function min($q, $db = null)
{
return $this->aggregate($q, 'min', $db);
}
Defined in: yii\mongodb\Query::modify()
Performs 'findAndModify' query and returns a single row of result.
public array|null modify ( $update, $options = [], $db = null ) | ||
$update | array |
Update criteria |
$options | array |
List of options in format: optionName => optionValue. |
$db | yii\mongodb\Connection |
The Mongo connection used to execute the query. |
return | array|null |
The original document, or the modified document when $options['new'] is set. |
---|
public function modify($update, $options = [], $db = null)
{
if (!empty($this->emulateExecution)) {
return null;
}
$this->prepare();
$collection = $this->getCollection($db);
if (!empty($this->orderBy)) {
$options['sort'] = $this->orderBy;
}
$options['fields'] = $this->select;
return $collection->findAndModify($this->composeCondition(), $update, $options);
}
Defined in: yii\mongodb\Query::one()
Executes the query and returns a single row of result.
public array|false one ( $db = null ) | ||
$db | yii\mongodb\Connection |
The Mongo connection used to execute the query.
If this parameter is not given, the |
return | array|false |
The first row (in terms of an array) of the query result. |
---|
public function one($db = null)
{
if (!empty($this->emulateExecution)) {
return false;
}
$cursor = $this->buildCursor($db);
return $this->fetchRows($cursor, false);
}
public $this options ( $options ) | ||
$options | array |
Cursor options in format: optionName => optionValue |
return | $this |
The query object itself |
---|
public function options($options)
{
$this->options = $options;
return $this;
}
Defined in: yii\mongodb\Query::populate()
Converts the raw query results into the format as specified by this query.
This method is internally used to convert the data fetched from database into the format as required by this query.
public array populate ( $rows ) | ||
$rows | array |
The raw query result from database |
return | array |
The converted query result |
---|
public function populate($rows)
{
if ($this->indexBy === null) {
return $rows;
}
$result = [];
foreach ($rows as $row) {
$result[ArrayHelper::getValue($row, $this->indexBy)] = $row;
}
return $result;
}
Defined in: yii\mongodb\Query::prepare()
Prepares for query building.
This method is called before actual query composition, e.g. building cursor, count etc. You may override this method to do some final preparation work before query execution.
public $this prepare ( ) | ||
return | $this |
A prepared query instance. |
---|
public function prepare()
{
return $this;
}
Defined in: yii\mongodb\Query::scalar()
Returns the query result as a scalar value.
The value returned will be the first column in the first row of the query results.
Column _id
will be automatically excluded from select fields, if select() is not empty and
_id
is not selected explicitly.
public string|null|false scalar ( $db = null ) | ||
$db | yii\mongodb\Connection |
The MongoDB connection used to generate the query.
If this parameter is not given, the |
return | string|null|false |
The value of the first column in the first row of the query result.
|
---|
public function scalar($db = null)
{
if (!empty($this->emulateExecution)) {
return null;
}
$originSelect = (array)$this->select;
if (!isset($originSelect['_id']) && array_search('_id', $originSelect, true) === false) {
$this->select['_id'] = false;
}
$cursor = $this->buildCursor($db);
$row = $this->fetchRows($cursor, false);
if (empty($row)) {
return false;
}
return reset($row);
}
Defined in: yii\mongodb\Query::select()
Sets the list of fields of the results to return.
public $this select ( array $fields ) | ||
$fields | array |
Fields of the results to return. |
return | $this |
The query object itself. |
---|
public function select(array $fields)
{
$this->select = $fields;
return $this;
}
Defined in: yii\mongodb\Query::sum()
Returns the sum of the specified column values.
public integer sum ( $q, $db = null ) | ||
$q | string |
The column name. Make sure you properly quote column names in the expression. |
$db | yii\mongodb\Connection |
The Mongo connection used to execute the query.
If this parameter is not given, the |
return | integer |
The sum of the specified column values |
---|
public function sum($q, $db = null)
{
if (!empty($this->emulateExecution)) {
return 0;
}
return $this->aggregate($q, 'sum', $db);
}