Merge pull request #1 from bjori/split-crud

Split and modify CRUD examples

Author: bjori

docs/examples/crud.php

@@ -0,0 +1,26 @@
+<?php
+
+$ordered = true;
+
+$insertBatch = new \MongoDB\Batch\InsertBatch($ordered);
+$insertBatch
+    ->add($hannes)
+    ->add($hayley);
+
+$w = 'majority';
+$w = 500;
+
+$writeConcern = new \MongoDB\WriteConcern($w, $wtimeout);
+
+$mm = new \MongoDB\Manager("mongodb://server1,server2/?replicaSet=FOOBAR");
+
+$result = $mm->executeWrite("db.collection", $insertBatch, $writeConcern);
+
+assert($result instanceof \MongoDB\WriteResult);
+
+printf(
+    "Inserted %d documents %s in %d msec\n",
+    $result->getOpCount(),
+    $result->getServer()->getHostname(),
+    $result->getTimer()
+);

docs/examples/insert.php

@@ -0,0 +1,62 @@
+<?php
+
+class Person implements BsonSerializable {
+    protected $name;
+    protected $nick;
+    protected $addresses = array();
+
+    function __construct($name, $nick, array $addresses) {
+        $this->name = $name;
+        $this->nick = $nick;
+        foreach($addresses as $address) {
+            if ($address instanceof Address) {
+                $this->addresses[] = $address;
+            }
+        }
+    }
+
+    function getAddresses() {
+        return $this->addresses;
+    }
+}
+
+class Address implements BsonSerializable {
+    protected $address;
+    protected $country;
+
+    function __construct($address, Country $country) {
+        $this->address = $address;
+        $this->country = $country;
+    }
+
+    function getCountry() {
+        return $this->country;
+    }
+}
+
+class Country implements BsonSerializable {
+    protected $name;
+
+    function __construct($name) {
+        $this->name;
+    }
+
+    function getName() {
+        return $name;
+    }
+}
+
+$norway  = new Country("Norway");
+$iceland = new Country("Iceland");
+$usa     = new Country("USA");
+
+$menlo   = new Address("22 Coleman Pl", $usa);
+
+$addresses = array(
+    new Address("Dynekilgata 15", $norway),
+    new Address("Mánabraut 4", $iceland),
+    $menlo,
+);
+
+$hannes = new Person("Hannes", "bjori", $addresses);
+$hayley = new Person("Hayley", "Ninja", array($menlo));

docs/examples/model.php

@@ -0,0 +1,39 @@
+<?php
+
+// Corresponds to "query object" in http://docs.mongodb.org/meta-driver/latest/legacy/mongodb-wire-protocol/#op-query
+$queryObj = array(
+    '$query' => array("name" => "Hannes"),
+    '$orderBy' => array('name' => 1),
+    '$comment' => 'More special stuff',
+);
+
+$query = new \MongoDB\Query($queryObj);
+$query
+    ->setSelector(array('fieldname' => 1, 'fieldname.two' => 1))
+    ->setLimit(-3) // Kill server cursor after 3 documents
+    ->setSkip(0)   // Don't skip any documents
+    ->setFlags(EXHAUST | NO_CURSOR_TIMEOUT);
+
+$tags = array(
+    array("dc:eu", "cpu:fast"),
+    array("dc:eu", "cc:is"),
+    array(""),
+);
+
+$readPreference = new \MongoDB\ReadPreference('secondaryPreferred', $tags);
+
+$mm = new \MongoDB\Manager("mongodb://server1,server2/?replicaSet=FOOBAR");
+
+$result = $mm->executeQuery("db.collection", $query, $readPreference);
+
+assert($result instanceof \MongoDB\QueryResult);
+assert($result instanceof \IteratorAggregate);
+assert($result->getIterator() instanceof \MongoDB\Cursor);
+
+foreach($result as $person) {
+    printf(
+        "%s has lived in %s\n",
+        $person->getName(),
+        $person->getAddresses()[0]->getCountry()->getName()
+    );
+}