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

Author: tuyakhov

src/Database.php

@@ -92,6 +92,32 @@ public function __toString()
         return $this->databaseName;
     }
 
+    /**
+     * Execute a command on this database.
+     *
+     * @param array|object        $command        Command document
+     * @param ReadPreference|null $readPreference Read preference
+     * @return Cursor
+     */
+    public function command($command, ReadPreference $readPreference = null)
+    {
+        if ( ! is_array($command) && ! is_object($command)) {
+            throw new InvalidArgumentTypeException('$command', $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);
+    }
+
     /**
      * Create a new collection explicitly.
      *

tests/Database/DatabaseFunctionalTest.php

@@ -64,6 +64,29 @@ public function getGetDatabaseName()
         $this->assertEquals($this->getDatabaseName(), $this->database->getDatabaseName());
     }
 
+    public function testCommand()
+    {
+        $command = ['isMaster' => 1];
+        $readPreference = new ReadPreference(ReadPreference::RP_PRIMARY);
+        $cursor = $this->database->command($command, $readPreference);
+
+        $this->assertInstanceOf('MongoDB\Driver\Cursor', $cursor);
+        $commandResult = current($cursor->toArray());
+
+        $this->assertCommandSucceeded($commandResult);
+        $this->assertTrue(isset($commandResult->ismaster));
+        $this->assertTrue($commandResult->ismaster);
+    }
+
+    /**
+     * @expectedException MongoDB\Exception\InvalidArgumentTypeException
+     * @dataProvider provideInvalidDocumentValues
+     */
+    public function testCommandCommandArgumentTypeCheck($command)
+    {
+        $this->database->command($command);
+    }
+
     public function testDrop()
     {
         $bulkWrite = new BulkWrite();