kakserpom /
phpdaemon
| @@ 461-469 (lines=9) @@ | ||
| 458 | $query['$readPreference'] = $v; |
|
| 459 | } |
|
| 460 | ||
| 461 | if (is_string($p['where'])) { |
|
| 462 | $query['where'] = new \MongoCode($p['where']); |
|
| 463 | } elseif (is_object($p['where']) || sizeof($p['where'])) { |
|
| 464 | $query['query'] = $p['where']; |
|
| 465 | } |
|
| 466 | $cb = CallbackWrapper::wrap($cb); |
|
| 467 | if ($this->safeMode) { |
|
| 468 | static::safeModeEnc($query); |
|
| 469 | } |
|
| 470 | try { |
|
| 471 | $this->request( |
|
| 472 | self::OP_QUERY, |
|
| @@ 730-738 (lines=9) @@ | ||
| 727 | $query['$max'] = $p['max']; |
|
| 728 | } |
|
| 729 | ||
| 730 | if (is_string($p['where'])) { |
|
| 731 | $query['where'] = new \MongoCode($p['where']); |
|
| 732 | } elseif (is_object($p['where']) || sizeof($p['where'])) { |
|
| 733 | $query['query'] = $p['where']; |
|
| 734 | } |
|
| 735 | ||
| 736 | $cb = CallbackWrapper::wrap($cb); |
|
| 737 | if ($this->safeMode) { |
|
| 738 | static::safeModeEnc($query); |
|
| 739 | } |
|
| 740 | try { |
|
| 741 | $this->request( |
|
