PHPLIB-153: Add Database::command() helper

src/Database.php

@@ -135,6 +135,31 @@ public function dropCollection($collectionName)
         return $operation->execute($server);
     }
 
+    /**
+     * This is the method to issue database commands.
+     *
+     * @param array|object $command A database command to send
+     * @param ReadPreference|null $readPreference Default read preference to apply
+     * @return Cursor
+     */
+    public function executeCommand($command, ReadPreference $readPreference = null)
+    {
+        if ( ! is_array($command) && ! is_object($command)) {
+            throw new InvalidArgumentTypeException('"command" parameter', $command, 'array or object');
+        }
+
+        if ( ! $command instanceof Command) {
+            $command = new Command($command);
+        }
+
+        if ( ! isset($readPreference)) {
+            $readPreference = $this->readPreference;
+        }
+
+        $server = $this->manager->selectServer($readPreference);
+        return $server->executeCommand($this->databaseName, $command);
+    }
+
     /**
      * Returns the database name.
      *

tests/Database/DatabaseFunctionalTest.php

@@ -6,6 +6,7 @@
 use MongoDB\Driver\BulkWrite;
 use MongoDB\Driver\ReadPreference;
 use MongoDB\Driver\WriteConcern;
+use MongoDB\Driver\Command;
 
 /**
  * Functional tests for the Database class.
@@ -77,6 +78,19 @@ public function testDrop()
         $this->assertCollectionCount($this->getNamespace(), 0);
     }
 
+    public function testCommand()
+    {
+        $command = new Command(['isMaster' => 1]);
+        $readPreference = new ReadPreference(ReadPreference::RP_PRIMARY);
+        $cursor = $this->database->executeCommand($command, $readPreference);
+        $this->assertInstanceOf('MongoDB\Driver\Cursor', $cursor);
+        $cursor->setTypeMap(['root' => 'array', 'document' => 'array']);
+        $document = current($cursor->toArray());
+        $this->assertCommandSucceeded($document);
+        $this->assertArrayHasKey('ismaster', $document);
+        $this->assertTrue($document['ismaster']);
+    }
+
     public function testSelectCollectionInheritsReadPreferenceAndWriteConcern()
     {
         $databaseOptions = [

tests/Database/FunctionalTestCase.php

@@ -10,6 +10,9 @@
  */
 abstract class FunctionalTestCase extends BaseFunctionalTestCase
 {
+    /**
+     * @var $database Database
+     */
     protected $database;
 
     public function setUp()