WIP: PHPLIB-58: CRUD spec functional tests

Author: jmikola

tests/Collection/CrudSpecFunctionalTest.php

@@ -0,0 +1,78 @@
+<?php
+
+namespace MongoDB\Tests\Collection;
+
+use MongoDB\Collection;
+use MongoDB\Driver\Manager;
+use MongoDB\Tests\FunctionalTestCase;
+
+/**
+ * Functional tests from the CRUD specification.
+ *
+ * @see https://github.com/mongodb/specifications/tree/master/source/crud/tests
+ */
+class CrudSpecFunctionalTest extends FunctionalTestCase
+{
+    private $collection;
+
+    public function setUp()
+    {
+        parent::setUp();
+
+        $this->collection = new Collection($this->manager, $this->getNamespace());
+        $this->collection->deleteMany(array());
+    }
+
+    public function testAggregateWithMultipleStages()
+    {
+        $this->collection->insertMany(array(
+            array('_id' => 1, 'x' => 11),
+            array('_id' => 2, 'x' => 22),
+            array('_id' => 3, 'x' => 33),
+        ));
+
+        $result = $this->collection->aggregate(
+            array(
+                array('$sort' => array('x' => 1)),
+                array('$match' => array('_id' => array('$gt' => 1))),
+            ),
+            array('batchSize' => 2)
+        );
+
+        $expected = array(
+            array('_id' => 2, 'x' => 22),
+            array('_id' => 3, 'x' => 33),
+        );
+
+        $this->assertEquals($expected, iterator_to_array($result));
+    }
+
+    public function testAggregateWithOut()
+    {
+        $this->collection->insertMany(array(
+            array('_id' => 1, 'x' => 11),
+            array('_id' => 2, 'x' => 22),
+            array('_id' => 3, 'x' => 33),
+        ));
+
+        $outputCollection = new Collection($this->manager, $this->getNamespace() . '_output');
+        $outputCollection->deleteMany(array());
+
+        $result = $this->collection->aggregate(
+            array(
+                array('$sort' => array('x' => 1)),
+                array('$match' => array('_id' => array('$gt' => 1))),
+                array('$out' => $outputCollection->getCollectionName()),
+            ),
+            array('batchSize' => 2)
+        );
+
+        $expected = array(
+            array('_id' => 2, 'x' => 22),
+            array('_id' => 3, 'x' => 33),
+        );
+
+        $this->assertEquals($expected, iterator_to_array($outputCollection->find()));
+    }
+}
+