Merge pull request #563

tests/DocumentationExamplesTest.php

@@ -1230,12 +1230,7 @@ class DocumentationExamplesTest extends FunctionalTestCase
 
     public function testTransactions_intro_example_1()
     {
-        if ($this->getPrimaryServer()->getType() === Server::TYPE_STANDALONE) {
-            $this->markTestSkipped('Transactions are not supported on standalone servers');
-        }
-        if (version_compare($this->getFeatureCompatibilityVersion(), '4.0', '<')) {
-            $this->markTestSkipped('Transactions are only supported on FCV 4.0 or higher');
-        }
+        $this->skipIfTransactionsAreNotSupported();
 
         $client = new Client($this->getUri());
 
@@ -1395,12 +1390,7 @@ class DocumentationExamplesTest extends FunctionalTestCase
 
     public function testTransactions_retry_example_3()
     {
-        if ($this->getPrimaryServer()->getType() === Server::TYPE_STANDALONE) {
-            $this->markTestSkipped('Transactions are not supported on standalone servers');
-        }
-        if (version_compare($this->getFeatureCompatibilityVersion(), '4.0', '<')) {
-            $this->markTestSkipped('Transactions are only supported on FCV 4.0 or higher');
-        }
+        $this->skipIfTransactionsAreNotSupported();
 
         $client = new Client($this->getUri());
 

tests/FunctionalTestCase.php

@@ -6,6 +6,7 @@ use MongoDB\Driver\Command;
 use MongoDB\Driver\Cursor;
 use MongoDB\Driver\Manager;
 use MongoDB\Driver\ReadPreference;
+use MongoDB\Driver\Server;
 use stdClass;
 use UnexpectedValueException;
 
@@ -95,4 +96,41 @@ abstract class FunctionalTestCase extends TestCase
 
         throw new UnexpectedValueException('Could not determine server version');
     }
+
+    protected function getServerStorageEngine(ReadPreference $readPreference = null)
+    {
+        $cursor = $this->manager->executeCommand(
+            $this->getDatabaseName(),
+            new Command(['serverStatus' => 1]),
+            $readPreference ?: new ReadPreference('primary')
+        );
+
+        $result = current($cursor->toArray());
+
+        if (isset($result->storageEngine->name) && is_string($result->storageEngine->name)) {
+            return $result->storageEngine->name;
+        }
+
+        throw new UnexpectedValueException('Could not determine server storage engine');
+    }
+
+    protected function skipIfTransactionsAreNotSupported()
+    {
+        if ($this->getPrimaryServer()->getType() === Server::TYPE_STANDALONE) {
+            $this->markTestSkipped('Transactions are not supported on standalone servers');
+        }
+
+        // TODO: MongoDB 4.2 should support sharded clusters (see: PHPLIB-374)
+        if ($this->getPrimaryServer()->getType() === Server::TYPE_MONGOS) {
+            $this->markTestSkipped('Transactions are not supported on sharded clusters');
+        }
+
+        if (version_compare($this->getFeatureCompatibilityVersion(), '4.0', '<')) {
+            $this->markTestSkipped('Transactions are only supported on FCV 4.0 or higher');
+        }
+
+        if ($this->getServerStorageEngine() !== 'wiredTiger') {
+            $this->markTestSkipped('Transactions require WiredTiger storage engine');
+        }
+    }
 }