| @@ 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 | } |
|