@@ 480-488 (lines=9) @@ | ||
477 | case self::TYPE_REMOVE: |
|
478 | return $this->collection->deleteMany($this->query['query'], $options); |
|
479 | ||
480 | case self::TYPE_DISTINCT: |
|
481 | $collection = $this->collection; |
|
482 | $query = $this->query; |
|
483 | ||
484 | return $collection->distinct( |
|
485 | $query['distinct'], |
|
486 | $query['query'], |
|
487 | array_merge($options, $this->getQueryOptions('readPreference')) |
|
488 | ); |
|
489 | ||
490 | case self::TYPE_COUNT: |
|
491 | $collection = $this->collection; |
|
@@ 490-497 (lines=8) @@ | ||
487 | array_merge($options, $this->getQueryOptions('readPreference')) |
|
488 | ); |
|
489 | ||
490 | case self::TYPE_COUNT: |
|
491 | $collection = $this->collection; |
|
492 | $query = $this->query; |
|
493 | ||
494 | return $collection->count( |
|
495 | $query['query'], |
|
496 | array_merge($options, $this->getQueryOptions('hint', 'limit', 'skip', 'readPreference')) |
|
497 | ); |
|
498 | } |
|
499 | } |
|
500 | } |