Skip to content

M
mongo-php-library
Commit d337c985 authored by Hannes Magnusson's avatar Hannes Magnusson
Browse files
Options

Make this more namespace and autoload friendly, class per file

parent da84ba51
Hide whitespace changes
Inline Side-by-side
Showing with 242 additions and 230 deletions
examples/find.php
View file @ d337c985
<?php <?php
require __DIR__ . "/../src/Collection.php"; require __DIR__ . "/../src/MongoDB/QueryFlags.php";
require __DIR__ . "/../src/MongoDB/CursorType.php";
require __DIR__ . "/../src/MongoDB/Collection.php";
$manager = new MongoDB\Manager("mongodb://localhost:27017"); $manager = new MongoDB\Manager("mongodb://localhost:27017");
var_dump($manager);
$collection = new MongoDB\Collection($manager, "crud.examples"); $collection = new MongoDB\Collection($manager, "crud.examples");
$result = $collection->find(array("nick" => "bjori"), array("projection" => array("name" =>1))); $result = $collection->find(array("nick" => "bjori"), array("projection" => array("name" =>1)));
......
examples/write.php
View file @ d337c985
<?php <?php
require __DIR__ . "/../src/Collection.php"; require __DIR__ . "/../src/MongoDB/QueryFlags.php";
require __DIR__ . "/../src/MongoDB/CursorType.php";
require __DIR__ . "/../src/MongoDB/Collection.php";
$manager = new MongoDB\Manager("mongodb://localhost:27017"); $manager = new MongoDB\Manager("mongodb://localhost:27017");
......
src/Collection.php
View file @ d337c985
<?php
namespace MongoDB;
use MongoDB\Manager;
use MongoDB\Query;
use MongoDB\ReadPreference;
use MongoDB\WriteBatch;
class QueryFlags {
const TAILABLE_CURSOR = 0x02;
const SLAVE_OKAY = 0x04;
const OPLOG_REPLY = 0x08;
const NO_CURSOR_TIMEOUT = 0x10;
const AWAIT_DATA = 0x20;
const EXHAUST = 0x40;
const PARTIAL = 0x80;
}
class CursorType {
const NON_TAILABLE = 0x00;
const TAILABLE = QueryFlags::TAILABLE_CURSOR;
/* QueryFlags::TAILABLE_CURSOR | QueryFlags::AWAIT_DATA; */
const TAILABLE_AWAIT = 0x22;
}
class Collection {
const INSERT = 0x01;
const UPDATE = 0x02;
const DELETE = 0x04;
protected $manager;
protected $rp;
protected $wc;
protected $ns;
function __construct(Manager $manager, $ns, WriteConcern $wc = null, ReadPreference $rp = null) {
$this->manager = $manager;
$this->ns = $ns;
$this->wc = $wc;
$this->rp = $rp;
}
function find(array $filter = array(), array $options = array()) { /* {{{ {{{ */
$options = array_merge($this->getFindOptions(), $options);
$query = $this->_buildQuery($filter, $options);
$cursor = $this->manager->executeQuery($this->ns, $query, $this->rp);
return $cursor;
} /* }}} */
function getFindOptions() { /* {{{ */
return array(
/**
* Get partial results from a mongos if some shards are down (instead of throwing an error).
*
* @see http://docs.mongodb.org/meta-driver/latest/legacy/mongodb-wire-protocol/#op-query
*/
"allowPartialResults" => false,
/**
* The number of documents to return per batch.
*
* @see http://docs.mongodb.org/manual/reference/method/cursor.batchSize/
*/
"batchSize" => 101,
/**
* Attaches a comment to the query. If $comment also exists
* in the modifiers document, the comment field overwrites $comment.
*
* @see http://docs.mongodb.org/manual/reference/operator/meta/comment/
*/
"comment" => "",
/**
* Indicates the type of cursor to use. This value includes both
* the tailable and awaitData options.
* The default is NON_TAILABLE.
*
* @see http://docs.mongodb.org/manual/reference/operator/meta/comment/
*/
"cursorType" => CursorType::NON_TAILABLE,
/**
* The maximum number of documents to return.
*
* @see http://docs.mongodb.org/manual/reference/method/cursor.limit/
*/
"limit" => 0,
/**
* The maximum amount of time to allow the query to run. If $maxTimeMS also exists
* in the modifiers document, the maxTimeMS field overwrites $maxTimeMS.
*
* @see http://docs.mongodb.org/manual/reference/operator/meta/maxTimeMS/
*/
"maxTimeMS" => 0,
/**
* Meta-operators modifying the output or behavior of a query.
*
* @see http://docs.mongodb.org/manual/reference/operator/query-modifier/
*/
"modifiers" => array(),
/**
* The server normally times out idle cursors after an inactivity period (10 minutes)
* to prevent excess memory use. Set this option to prevent that.
*
* @see http://docs.mongodb.org/meta-driver/latest/legacy/mongodb-wire-protocol/#op-query
*/
"noCursorTimeout" => false,
/**
* Internal replication use only - driver should not set
*
* @see http://docs.mongodb.org/meta-driver/latest/legacy/mongodb-wire-protocol/#op-query
*/
"oplogReplay" => false,
/**
* Limits the fields to return for all matching documents.
*
* @see http://docs.mongodb.org/manual/tutorial/project-fields-from-query-results/
*/
"projection" => array(),
/**
* The number of documents to skip before returning.
*
* @see http://docs.mongodb.org/manual/reference/method/cursor.skip/
*/
"skip" => 0,
/**
* The order in which to return matching documents. If $orderby also exists
* in the modifiers document, the sort field overwrites $orderby.
*
* @see http://docs.mongodb.org/manual/reference/method/cursor.sort/
*/
"sort" => array(),
);
} /* }}} */
protected function _opQueryFlags($options) { /* {{{ */
$flags = 0;
$flags |= $options["allowPartialResults"] ? QueryFlags::PARTIAL : 0;
$flags |= $options["cursorType"] ? $options["cursorType"] : 0;
$flags |= $options["oplogReplay"] ? QueryFlags::OPLOG_REPLY: 0;
$flags |= $options["noCursorTimeout"] ? QueryFlags::NO_CURSOR_TIMEOUT : 0;
return $flags;
} /* }}} */
protected function _buildQuery($filter, $options) { /* {{{ */
if ($options["comment"]) {
$options["modifiers"]['$comment'] = $options["comment"];
}
if ($options["maxTimeMS"]) {
$options["modifiers"]['$maxTimeMS'] = $options["maxTimeMS"];
}
if ($options["sort"]) {
$options['$orderby'] = $options["sort"];
}
$flags = $this->_opQueryFlags($options);
$options["cursorFlags"] = $flags;
$query = new Query($filter, $options);
return $query;
} /* }}} */
/* }}} */
protected function _writeSingle($filter, $type, array $options = array(), $newobj = array()) { /* {{{ */
$options = array_merge($this->getWriteOptions(), $options);
$batch = new WriteBatch($options["ordered"]);
switch($type) {
case self::INSERT:
$batch->insert($filter);
break;
case self::DELETE:
$batch->delete($filter, $options);
break;
case self::UPDATE:
$batch->update($filter, $newobj, $options);
break;
}
return $this->manager->executeWriteBatch($this->ns, $batch, $this->wc);
} /* }}} */
function getWriteOptions() { /* {{{ */
return array(
"ordered" => false,
"upsert" => false,
"limit" => 1,
);
} /* }}} */
function insertOne(array $filter) { /* {{{ */
return $this->_writeSingle($filter, self::INSERT);
} /* }}} */
function deleteOne(array $filter) { /* {{{ */
return $this->_writeSingle($filter, self::DELETE);
} /* }}} */
function deleteMany(array $filter) { /* {{{ */
return $this->_writeSingle($filter, self::DELETE, array("limit" => 0));
} /* }}} */
function updateOne(array $filter, array $update, array $options = array()) { /* {{{ */
if (key($update)[0] != '$') {
throw new \RuntimeException("First key in \$update must be a \$operator");
}
return $this->_writeSingle($filter, self::UPDATE, $options, $update);
} /* }}} */
function replaceOne(array $filter, array $update, array $options = array()) { /* {{{ */
if (key($update)[0] == '$') {
throw new \RuntimeException("First key in \$update must NOT be a \$operator");
}
return $this->_writeSingle($filter, self::UPDATE, $options, array('$set' => $update));
} /* }}} */
function updateMany(array $filter, $update, array $options = array()) { /* {{{ */
return $this->_writeSingle($filter, self::UPDATE, $options + array("limit" => 0), $update);
} /* }}} */
}
src/MongoDB/Collection.php 0 → 100644
View file @ d337c985
<?php
namespace MongoDB;
/* phongo includes */
use MongoDB\Manager;
use MongoDB\Query;
use MongoDB\ReadPreference;
use MongoDB\WriteBatch;
use MongoDB\QueryFlags;
use MongoDB\CursorType;
class Collection {
const INSERT = 0x01;
const UPDATE = 0x02;
const DELETE = 0x04;
protected $manager;
protected $rp;
protected $wc;
protected $ns;
function __construct(Manager $manager, $ns, WriteConcern $wc = null, ReadPreference $rp = null) {
$this->manager = $manager;
$this->ns = $ns;
$this->wc = $wc;
$this->rp = $rp;
}
function find(array $filter = array(), array $options = array()) { /* {{{ {{{ */
$options = array_merge($this->getFindOptions(), $options);
$query = $this->_buildQuery($filter, $options);
$cursor = $this->manager->executeQuery($this->ns, $query, $this->rp);
return $cursor;
} /* }}} */
function getFindOptions() { /* {{{ */
return array(
/**
* Get partial results from a mongos if some shards are down (instead of throwing an error).
*
* @see http://docs.mongodb.org/meta-driver/latest/legacy/mongodb-wire-protocol/#op-query
*/
"allowPartialResults" => false,
/**
* The number of documents to return per batch.
*
* @see http://docs.mongodb.org/manual/reference/method/cursor.batchSize/
*/
"batchSize" => 101,
/**
* Attaches a comment to the query. If $comment also exists
* in the modifiers document, the comment field overwrites $comment.
*
* @see http://docs.mongodb.org/manual/reference/operator/meta/comment/
*/
"comment" => "",
/**
* Indicates the type of cursor to use. This value includes both
* the tailable and awaitData options.
* The default is NON_TAILABLE.
*
* @see http://docs.mongodb.org/manual/reference/operator/meta/comment/
*/
"cursorType" => CursorType\NON_TAILABLE,
/**
* The maximum number of documents to return.
*
* @see http://docs.mongodb.org/manual/reference/method/cursor.limit/
*/
"limit" => 0,
/**
* The maximum amount of time to allow the query to run. If $maxTimeMS also exists
* in the modifiers document, the maxTimeMS field overwrites $maxTimeMS.
*
* @see http://docs.mongodb.org/manual/reference/operator/meta/maxTimeMS/
*/
"maxTimeMS" => 0,
/**
* Meta-operators modifying the output or behavior of a query.
*
* @see http://docs.mongodb.org/manual/reference/operator/query-modifier/
*/
"modifiers" => array(),
/**
* The server normally times out idle cursors after an inactivity period (10 minutes)
* to prevent excess memory use. Set this option to prevent that.
*
* @see http://docs.mongodb.org/meta-driver/latest/legacy/mongodb-wire-protocol/#op-query
*/
"noCursorTimeout" => false,
/**
* Internal replication use only - driver should not set
*
* @see http://docs.mongodb.org/meta-driver/latest/legacy/mongodb-wire-protocol/#op-query
*/
"oplogReplay" => false,
/**
* Limits the fields to return for all matching documents.
*
* @see http://docs.mongodb.org/manual/tutorial/project-fields-from-query-results/
*/
"projection" => array(),
/**
* The number of documents to skip before returning.
*
* @see http://docs.mongodb.org/manual/reference/method/cursor.skip/
*/
"skip" => 0,
/**
* The order in which to return matching documents. If $orderby also exists
* in the modifiers document, the sort field overwrites $orderby.
*
* @see http://docs.mongodb.org/manual/reference/method/cursor.sort/
*/
"sort" => array(),
);
} /* }}} */
protected function _opQueryFlags($options) { /* {{{ */
$flags = 0;
$flags |= $options["allowPartialResults"] ? QueryFlags\PARTIAL : 0;
$flags |= $options["cursorType"] ? $options["cursorType"] : 0;
$flags |= $options["oplogReplay"] ? QueryFlags\OPLOG_REPLY: 0;
$flags |= $options["noCursorTimeout"] ? QueryFlags\NO_CURSOR_TIMEOUT : 0;
return $flags;
} /* }}} */
protected function _buildQuery($filter, $options) { /* {{{ */
if ($options["comment"]) {
$options["modifiers"]['$comment'] = $options["comment"];
}
if ($options["maxTimeMS"]) {
$options["modifiers"]['$maxTimeMS'] = $options["maxTimeMS"];
}
if ($options["sort"]) {
$options['$orderby'] = $options["sort"];
}
$flags = $this->_opQueryFlags($options);
$options["cursorFlags"] = $flags;
$query = new Query($filter, $options);
return $query;
} /* }}} */
/* }}} */
protected function _writeSingle($filter, $type, array $options = array(), $newobj = array()) { /* {{{ */
$options = array_merge($this->getWriteOptions(), $options);
$batch = new WriteBatch($options["ordered"]);
switch($type) {
case self::INSERT:
$batch->insert($filter);
break;
case self::DELETE:
$batch->delete($filter, $options);
break;
case self::UPDATE:
$batch->update($filter, $newobj, $options);
break;
}
return $this->manager->executeWriteBatch($this->ns, $batch, $this->wc);
} /* }}} */
function getWriteOptions() { /* {{{ */
return array(
"ordered" => false,
"upsert" => false,
"limit" => 1,
);
} /* }}} */
function insertOne(array $filter) { /* {{{ */
return $this->_writeSingle($filter, self::INSERT);
} /* }}} */
function deleteOne(array $filter) { /* {{{ */
return $this->_writeSingle($filter, self::DELETE);
} /* }}} */
function deleteMany(array $filter) { /* {{{ */
return $this->_writeSingle($filter, self::DELETE, array("limit" => 0));
} /* }}} */
function updateOne(array $filter, array $update, array $options = array()) { /* {{{ */
if (key($update)[0] != '$') {
throw new \RuntimeException("First key in \$update must be a \$operator");
}
return $this->_writeSingle($filter, self::UPDATE, $options, $update);
} /* }}} */
function replaceOne(array $filter, array $update, array $options = array()) { /* {{{ */
if (key($update)[0] == '$') {
throw new \RuntimeException("First key in \$update must NOT be a \$operator");
}
return $this->_writeSingle($filter, self::UPDATE, $options, array('$set' => $update));
} /* }}} */
function updateMany(array $filter, $update, array $options = array()) { /* {{{ */
return $this->_writeSingle($filter, self::UPDATE, $options + array("limit" => 0), $update);
} /* }}} */
}
src/MongoDB/CursorType.php 0 → 100644
View file @ d337c985
<?php
namespace MongoDB\CursorType;
const NON_TAILABLE = 0 << 0;
const TAILABLE = \MongoDB\QueryFlags\TAILABLE_CURSOR;
const TAILABLE_AWAIT = \MongoDB\QueryFlags\TAILABLE_CURSOR | \MongoDB\QueryFlags\AWAIT_DATA;
src/MongoDB/QueryFlags.php 0 → 100644
View file @ d337c985
<?php
namespace MongoDB\QueryFlags;
const TAILABLE_CURSOR = 1 << 1;
const SLAVE_OKAY = 1 << 2;
const OPLOG_REPLY = 1 << 3;
const NO_CURSOR_TIMEOUT = 1 << 4;
const AWAIT_DATA = 1 << 5;
const EXHAUST = 1 << 6;
const PARTIAL = 1 << 7;
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment