diff --git a/src/Operation/Count.php b/src/Operation/Count.php index 137fd47d99a35fe034344f544443ba40207ebb6e..c989761cb62e0ad3344e2ae02ac9f323176eaa39 100644 --- a/src/Operation/Count.php +++ b/src/Operation/Count.php @@ -85,6 +85,7 @@ class Count implements Executable public function execute(Server $server) { $cursor = $server->executeCommand($this->databaseName, $this->createCommand()); + $cursor->setTypeMap(array('document' => 'array')); $result = current($cursor->toArray()); if (empty($result['ok'])) { diff --git a/src/Operation/CreateCollection.php b/src/Operation/CreateCollection.php index 8b71d388cbad84dd501e9e5f95ced74dfdbb9c10..b7b082f9502bd2b4b02f428ec477e45b4927c442 100644 --- a/src/Operation/CreateCollection.php +++ b/src/Operation/CreateCollection.php @@ -106,6 +106,7 @@ class CreateCollection implements Executable public function execute(Server $server) { $cursor = $server->executeCommand($this->databaseName, $this->createCommand()); + $cursor->setTypeMap(array('document' => 'array')); $result = current($cursor->toArray()); if (empty($result['ok'])) { diff --git a/src/Operation/Distinct.php b/src/Operation/Distinct.php index 576627054950d47942d7ad7f8b17a796e637a16c..489e26a9a8b470e2dc5e28b9cb9b428724a351ea 100644 --- a/src/Operation/Distinct.php +++ b/src/Operation/Distinct.php @@ -62,6 +62,7 @@ class Distinct implements Executable public function execute(Server $server) { $cursor = $server->executeCommand($this->databaseName, $this->createCommand()); + $cursor->setTypeMap(array('document' => 'array')); $result = current($cursor->toArray()); if (empty($result['ok'])) { diff --git a/src/Operation/DropCollection.php b/src/Operation/DropCollection.php index 437ccfcb16983ce792a1a06bf0605e5c06623091..cd5af3215c2611889bd592e07b8f6f449fb58a6d 100644 --- a/src/Operation/DropCollection.php +++ b/src/Operation/DropCollection.php @@ -41,6 +41,7 @@ class DropCollection implements Executable public function execute(Server $server) { $cursor = $server->executeCommand($this->databaseName, new Command(array('drop' => $this->collectionName))); + $cursor->setTypeMap(array('document' => 'array')); $result = current($cursor->toArray()); if (empty($result['ok'])) { diff --git a/src/Operation/DropDatabase.php b/src/Operation/DropDatabase.php index 4c4313d3e7dbaaee0f755daac463299c45d389a9..f453b6a0e549f0fa6a72cf759cef81306f9c8e39 100644 --- a/src/Operation/DropDatabase.php +++ b/src/Operation/DropDatabase.php @@ -39,6 +39,7 @@ class DropDatabase implements Executable public function execute(Server $server) { $cursor = $server->executeCommand($this->databaseName, new Command(array('dropDatabase' => 1))); + $cursor->setTypeMap(array('document' => 'array')); $result = current($cursor->toArray()); if (empty($result['ok'])) { diff --git a/src/Operation/FindAndModify.php b/src/Operation/FindAndModify.php index 0c288b058750091a520476eaf6eb1e3c79377825..d2ef79394e1d82d5e3ff435ce7ca4f6849783273 100644 --- a/src/Operation/FindAndModify.php +++ b/src/Operation/FindAndModify.php @@ -118,6 +118,7 @@ class FindAndModify implements Executable public function execute(Server $server) { $cursor = $server->executeCommand($this->databaseName, $this->createCommand()); + $cursor->setTypeMap(array('document' => 'array')); $result = current($cursor->toArray()); if (empty($result['ok'])) {