CSHARP-2418: Add test that reads ignore db/collection readConcern in transaction

Author: vincentkam

tests/MongoDB.Driver.Tests/JsonDrivenTests/JsonDrivenBulkWriteTest.cs

@@ -106,6 +106,10 @@ private void AssertResultAspect(string name, BsonValue expectedValue)
                 case "insertedIds":
                     _result.InsertedCount.Should().Be(expectedValue.AsBsonDocument.ElementCount);
                     break;
+                
+                case "insertedCount":
+                    _result.InsertedCount.Should().Be(expectedValue.ToInt64());
+                    break;
 
                 case "matchedCount":
                     _result.MatchedCount.Should().Be(expectedValue.ToInt64());

tests/MongoDB.Driver.Tests/JsonDrivenTests/JsonDrivenRunCommandTest.cs

@@ -27,6 +27,7 @@ public sealed class JsonDrivenRunCommandTest : JsonDrivenDatabaseTest
     {
         // private fields
         private BsonDocument _command;
+        private ReadConcern _readConcern = new ReadConcern();
         private ReadPreference _readPreference;
         private BsonDocument _result;
         private IClientSessionHandle _session;
@@ -40,7 +41,8 @@ public JsonDrivenRunCommandTest(IMongoDatabase database, Dictionary<string, obje
         // public methods
         public override void Arrange(BsonDocument document)
         {
-            JsonDrivenHelper.EnsureAllFieldsAreValid(document, "name", "object", "command_name", "arguments", "result");
+            var expectedNames = new[] {"name", "object", "command_name", "arguments", "result", "databaseOptions"};
+            JsonDrivenHelper.EnsureAllFieldsAreValid(document, expectedNames);
             base.Arrange(document);
 
             if (document.Contains("command_name"))
@@ -65,23 +67,31 @@ protected override void CallMethod(CancellationToken cancellationToken)
         {
             if (_session == null)
             {
-                _result = _database.RunCommand<BsonDocument>(_command, _readPreference, cancellationToken);
+                _result = _database
+                    .WithReadConcern(_readConcern)
+                    .RunCommand<BsonDocument>(_command, _readPreference, cancellationToken);
             }
             else
             {
-                _result = _database.RunCommand<BsonDocument>(_session, _command, _readPreference, cancellationToken);
+                _result = _database
+                    .WithReadConcern(_readConcern)
+                    .RunCommand<BsonDocument>(_session, _command, _readPreference, cancellationToken);
             }
         }
 
         protected override async Task CallMethodAsync(CancellationToken cancellationToken)
         {
             if (_session == null)
             {
-                _result = await _database.RunCommandAsync<BsonDocument>(_command, _readPreference, cancellationToken);
+                _result = await _database
+                    .WithReadConcern(_readConcern)
+                    .RunCommandAsync<BsonDocument>(_command, _readPreference, cancellationToken).ConfigureAwait(false);
             }
             else
             {
-                _result = await _database.RunCommandAsync<BsonDocument>(_session, _command, _readPreference, cancellationToken);
+                _result = await _database
+                    .WithReadConcern(_readConcern)
+                    .RunCommandAsync<BsonDocument>(_session, _command, _readPreference, cancellationToken).ConfigureAwait(false);
             }
         }
 
@@ -92,6 +102,13 @@ protected override void SetArgument(string name, BsonValue value)
                 case "command":
                     _command = value.AsBsonDocument;
                     return;
+                
+                case "databaseOptions":
+                    if (value.AsBsonDocument.TryGetValue("readConcern", out var readConcernValue))
+                    {
+                        _readConcern = ReadConcern.FromBsonDocument(readConcernValue.AsBsonDocument);
+                    }
+                    return;
 
                 case "readPreference":
                     _readPreference = ReadPreference.FromBsonDocument(value.AsBsonDocument);

tests/MongoDB.Driver.Tests/Specifications/transactions/tests/bulk.json

@@ -184,6 +184,7 @@
           },
           "result": {
             "deletedCount": 4,
+            "insertedCount": 6,
             "insertedIds": {
               "0": 1,
               "3": 3,

tests/MongoDB.Driver.Tests/Specifications/transactions/tests/bulk.yml

@@ -84,6 +84,7 @@ tests:
                 filter: {_id: {$gte: 6}}
         result:
           deletedCount: 4
+          insertedCount: 6
           insertedIds: {0: 1, 3: 3, 4: 4, 5: 5, 6: 6, 7: 7}
           matchedCount: 7
           modifiedCount: 7