Update unit tests

framework/src/Volo.Abp.MongoDB/Volo/Abp/Domain/Repositories/MongoDB/MongoDbRepository.cs

@@ -111,6 +111,8 @@ namespace Volo.Abp.Domain.Repositories.MongoDB
                     entity,
                     cancellationToken: GetCancellationToken(cancellationToken)
                 );
+
+
             }
             else
             {
@@ -248,9 +250,7 @@ namespace Volo.Abp.Domain.Repositories.MongoDB
 
         public virtual IMongoQueryable<TEntity> GetMongoQueryable()
         {
-            return ApplyDataFilters(
-                Collection.AsQueryable()
-            );
+            return ApplyDataFilters(SessionHandle != null ? Collection.AsQueryable(SessionHandle) : Collection.AsQueryable());
         }
         protected virtual bool IsHardDeleted(TEntity entity)
         {

framework/src/Volo.Abp.MongoDB/Volo/Abp/MongoDB/AbpMongoDbContext.cs

@@ -26,8 +26,6 @@ namespace Volo.Abp.MongoDB
 
         public virtual IMongoCollection<T> Collection<T>()
         {
-            CreateCollectionIfNotExists<T>();
-
             return Database.GetCollection<T>(GetCollectionName<T>());
         }
 
@@ -47,23 +45,5 @@ namespace Volo.Abp.MongoDB
 
             return model;
         }
-
-        protected virtual void CreateCollectionIfNotExists<T>()
-        {
-            var collectionName = GetCollectionName<T>();
-
-            if (!CollectionExists(collectionName))
-            {
-                Database.CreateCollection(collectionName);
-            }
-        }
-
-        protected virtual bool CollectionExists(string collectionName)
-        {
-            var filter = new BsonDocument("name", collectionName);
-            var options = new ListCollectionNamesOptions { Filter = filter };
-
-            return Database.ListCollectionNames(options).Any();
-        }
     }
 }

framework/test/Volo.Abp.MongoDB.Tests/Volo/Abp/MongoDB/MongoClientExtension.cs → framework/src/Volo.Abp.MongoDB/Volo/Abp/MongoDB/MongoClientExtension.cs

@@ -7,7 +7,7 @@ namespace Volo.Abp.MongoDB
     /// <summary>
     /// TODO It can be removed, when Mongo2Go solves this issue : https://github.com/Mongo2Go/Mongo2Go/issues/89
     /// </summary>
-     internal static class MongoClientExtension
+    public static class MongoClientExtension
     {
         private static readonly TimeSpan InitialDelay = TimeSpan.FromMilliseconds(500);
         private static readonly TimeSpan MaxDelay = TimeSpan.FromSeconds(5000);
@@ -37,9 +37,12 @@ namespace Volo.Abp.MongoDB
                         {
                             session.Dispose();
                         }
+
                         break;
                     }
-                    catch (NotSupportedException) { }
+                    catch (NotSupportedException)
+                    {
+                    }
 
                     Thread.Sleep(delay);
                     delay = Min(Double(delay), MaxDelay);

framework/src/Volo.Abp.MongoDB/Volo/Abp/MongoDB/MongoModelBuilder.cs

@@ -3,6 +3,8 @@ using System;
 using System.Collections.Generic;
 using System.Collections.Immutable;
 using System.Linq;
+using MongoDB.Bson;
+using MongoDB.Driver;
 using Volo.Abp.Domain.Entities;
 
 namespace Volo.Abp.MongoDB
@@ -18,7 +20,7 @@ namespace Volo.Abp.MongoDB
             _entityModelBuilders = new Dictionary<Type, object>();
         }
 
-        public MongoDbContextModel Build()
+        public MongoDbContextModel Build(AbpMongoDbContext dbContext)
         {
             lock (SyncObj)
             {
@@ -38,6 +40,8 @@ namespace Volo.Abp.MongoDB
                     }
 
                     baseClasses.AddRange(entityModel.EntityType.GetBaseClasses(includeObject: false));
+
+                    CreateCollectionIfNotExists(dbContext, entityModel.CollectionName);
                 }
 
                 baseClasses = baseClasses.Distinct().ToList();
@@ -84,5 +88,16 @@ namespace Volo.Abp.MongoDB
         {
             return _entityModelBuilders.Values.Cast<IMongoEntityModel>().ToImmutableList();
         }
+
+        protected virtual void CreateCollectionIfNotExists(AbpMongoDbContext dbContext, string collectionName)
+        {
+            var filter = new BsonDocument("name", collectionName);
+            var options = new ListCollectionNamesOptions { Filter = filter };
+
+            if (!dbContext.Database.ListCollectionNames(options).Any())
+            {
+                dbContext.Database.CreateCollection(collectionName);
+            }
+        }
     }
-}
+}

framework/src/Volo.Abp.MongoDB/Volo/Abp/MongoDB/MongoModelSource.cs

@@ -12,7 +12,7 @@ namespace Volo.Abp.MongoDB
     public class MongoModelSource : IMongoModelSource, ISingletonDependency
     {
         protected readonly ConcurrentDictionary<Type, MongoDbContextModel> ModelCache = new ConcurrentDictionary<Type, MongoDbContextModel>();
-        
+
         public virtual MongoDbContextModel GetModel(AbpMongoDbContext dbContext)
         {
             return ModelCache.GetOrAdd(
@@ -26,7 +26,7 @@ namespace Volo.Abp.MongoDB
             var modelBuilder = CreateModelBuilder();
             BuildModelFromDbContextType(modelBuilder, dbContext.GetType());
             BuildModelFromDbContextInstance(modelBuilder, dbContext);
-            return modelBuilder.Build();
+            return modelBuilder.Build(dbContext);
         }
 
         protected virtual MongoModelBuilder CreateModelBuilder()
@@ -65,4 +65,4 @@ namespace Volo.Abp.MongoDB
             dbContext.CreateModel(modelBuilder);
         }
     }
-}
+}

framework/test/Volo.Abp.MongoDB.Tests/Volo/Abp/MongoDB/MongoDbFixture.cs

@@ -1,6 +1,7 @@
 using System;
 using Mongo2Go;
 using MongoDB.Driver;
+using Volo.Abp.MongoDB;
 
 namespace Volo.Abp.MongoDB
 {

modules/audit-logging/test/Volo.Abp.AuditLogging.MongoDB.Tests/Volo/Abp/AuditLogging/MongoDB/AbpAuditLoggingMongoDbTestModule.cs

@@ -12,9 +12,11 @@ namespace Volo.Abp.AuditLogging.MongoDB
     {
         public override void ConfigureServices(ServiceConfigurationContext context)
         {
-            var connectionString = MongoDbFixture.ConnectionString.EnsureEndsWith('/') +
+            var stringArray = MongoDbFixture.ConnectionString.Split('?');
+
+            var connectionString = stringArray[0].EnsureEndsWith('/') +
                                    "Db_" +
-                                    Guid.NewGuid().ToString("N");
+                                   Guid.NewGuid().ToString("N") + "/?" + stringArray[1];
 
             Configure<AbpDbConnectionOptions>(options =>
             {
@@ -22,4 +24,4 @@ namespace Volo.Abp.AuditLogging.MongoDB
             });
         }
     }
-}
+}

modules/audit-logging/test/Volo.Abp.AuditLogging.MongoDB.Tests/Volo/Abp/AuditLogging/MongoDB/MongoDbFixture.cs

@@ -1,5 +1,7 @@
 using System;
 using Mongo2Go;
+using MongoDB.Driver;
+using Volo.Abp.MongoDB;
 
 namespace Volo.Abp.AuditLogging.MongoDB
 {
@@ -10,8 +12,12 @@ namespace Volo.Abp.AuditLogging.MongoDB
 
         static MongoDbFixture()
         {
-            MongoDbRunner = MongoDbRunner.Start();
+            MongoDbRunner = MongoDbRunner.Start(singleNodeReplSet: true, singleNodeReplSetWaitTimeout: 10);
             ConnectionString = MongoDbRunner.ConnectionString;
+
+            //TODO It can be removed, when Mongo2Go solves this issue : https://github.com/Mongo2Go/Mongo2Go/issues/89
+            var client = new MongoClient(MongoDbRunner.ConnectionString);
+            client.EnsureReplicationSetReady();
         }
 
         public void Dispose()

modules/background-jobs/test/Volo.Abp.BackgroundJobs.MongoDB.Tests/Volo/Abp/BackgroundJobs/MongoDB/AbpBackgroundJobsMongoDbTestModule.cs

@@ -12,9 +12,11 @@ namespace Volo.Abp.BackgroundJobs.MongoDB
     {
         public override void ConfigureServices(ServiceConfigurationContext context)
         {
-            var connectionString = MongoDbFixture.ConnectionString.EnsureEndsWith('/') +
-                                   "Db_" +
-                                    Guid.NewGuid().ToString("N");
+            var stringArray = MongoDbFixture.ConnectionString.Split('?');
+
+                        var connectionString = stringArray[0].EnsureEndsWith('/') +
+                                               "Db_" +
+                                               Guid.NewGuid().ToString("N") + "/?" + stringArray[1];
 
             Configure<AbpDbConnectionOptions>(options =>
             {
@@ -22,4 +24,4 @@ namespace Volo.Abp.BackgroundJobs.MongoDB
             });
         }
     }
-}
+}

modules/background-jobs/test/Volo.Abp.BackgroundJobs.MongoDB.Tests/Volo/Abp/BackgroundJobs/MongoDB/MongoDbFixture.cs

@@ -1,5 +1,7 @@
 using System;
 using Mongo2Go;
+using MongoDB.Driver;
+using Volo.Abp.MongoDB;
 
 namespace Volo.Abp.BackgroundJobs.MongoDB
 {
@@ -10,8 +12,12 @@ namespace Volo.Abp.BackgroundJobs.MongoDB
 
         static MongoDbFixture()
         {
-            MongoDbRunner = MongoDbRunner.Start();
+            MongoDbRunner = MongoDbRunner.Start(singleNodeReplSet: true, singleNodeReplSetWaitTimeout: 10);
             ConnectionString = MongoDbRunner.ConnectionString;
+
+            //TODO It can be removed, when Mongo2Go solves this issue : https://github.com/Mongo2Go/Mongo2Go/issues/89
+            var client = new MongoClient(MongoDbRunner.ConnectionString);
+            client.EnsureReplicationSetReady();
         }
 
         public void Dispose()

modules/blob-storing-database/test/Volo.Abp.BlobStoring.Database.MongoDB.Tests/MongoDB/BlobStoringDatabaseMongoDbTestModule.cs

@@ -12,9 +12,11 @@ namespace Volo.Abp.BlobStoring.Database.MongoDB
     {
         public override void ConfigureServices(ServiceConfigurationContext context)
         {
-            var connectionString = MongoDbFixture.ConnectionString.EnsureEndsWith('/') +
+            var stringArray = MongoDbFixture.ConnectionString.Split('?');
+
+            var connectionString = stringArray[0].EnsureEndsWith('/') +
                                    "Db_" +
-                                    Guid.NewGuid().ToString("N");
+                                   Guid.NewGuid().ToString("N") + "/?" + stringArray[1];
 
             Configure<AbpDbConnectionOptions>(options =>
             {
@@ -22,4 +24,4 @@ namespace Volo.Abp.BlobStoring.Database.MongoDB
             });
         }
     }
-}
+}

modules/blob-storing-database/test/Volo.Abp.BlobStoring.Database.MongoDB.Tests/MongoDB/MongoDbFixture.cs

@@ -1,5 +1,7 @@
 using System;
 using Mongo2Go;
+using MongoDB.Driver;
+using Volo.Abp.MongoDB;
 
 namespace Volo.Abp.BlobStoring.Database.MongoDB
 {
@@ -10,8 +12,12 @@ namespace Volo.Abp.BlobStoring.Database.MongoDB
 
         static MongoDbFixture()
         {
-            MongoDbRunner = MongoDbRunner.Start();
+            MongoDbRunner = MongoDbRunner.Start(singleNodeReplSet: true, singleNodeReplSetWaitTimeout: 10);
             ConnectionString = MongoDbRunner.ConnectionString;
+
+            //TODO It can be removed, when Mongo2Go solves this issue : https://github.com/Mongo2Go/Mongo2Go/issues/89
+            var client = new MongoClient(MongoDbRunner.ConnectionString);
+            client.EnsureReplicationSetReady();
         }
 
         public void Dispose()

modules/blogging/test/Volo.Blogging.MongoDB.Tests/Volo/Blogging/MongoDB/BloggingMongoDBTestModule.cs

@@ -12,9 +12,11 @@ namespace Volo.Blogging.MongoDB
     {
         public override void ConfigureServices(ServiceConfigurationContext context)
         {
-            var connectionString = MongoDbFixture.ConnectionString.EnsureEndsWith('/') +
+            var stringArray = MongoDbFixture.ConnectionString.Split('?');
+
+            var connectionString = stringArray[0].EnsureEndsWith('/') +
                                    "Db_" +
-                                    Guid.NewGuid().ToString("N");
+                                   Guid.NewGuid().ToString("N") + "/?" + stringArray[1];
 
             Configure<AbpDbConnectionOptions>(options =>
             {

modules/blogging/test/Volo.Blogging.MongoDB.Tests/Volo/Blogging/MongoDB/MongoDbFixture.cs

@@ -1,5 +1,7 @@
 using System;
 using Mongo2Go;
+using MongoDB.Driver;
+using Volo.Abp.MongoDB;
 
 namespace Volo.Blogging.MongoDB
 {
@@ -10,8 +12,12 @@ namespace Volo.Blogging.MongoDB
 
         static MongoDbFixture()
         {
-            MongoDbRunner = MongoDbRunner.Start();
+            MongoDbRunner = MongoDbRunner.Start(singleNodeReplSet: true, singleNodeReplSetWaitTimeout: 10);
             ConnectionString = MongoDbRunner.ConnectionString;
+
+            //TODO It can be removed, when Mongo2Go solves this issue : https://github.com/Mongo2Go/Mongo2Go/issues/89
+            var client = new MongoClient(MongoDbRunner.ConnectionString);
+            client.EnsureReplicationSetReady();
         }
 
         public void Dispose()

modules/cms-kit/test/Volo.CmsKit.MongoDB.Tests/MongoDB/CmsKitMongoDbTestModule.cs

@@ -12,9 +12,11 @@ namespace Volo.CmsKit.MongoDB
     {
         public override void ConfigureServices(ServiceConfigurationContext context)
         {
-            var connectionString = MongoDbFixture.ConnectionString.EnsureEndsWith('/') +
+            var stringArray = MongoDbFixture.ConnectionString.Split('?');
+
+            var connectionString = stringArray[0].EnsureEndsWith('/') +
                                    "Db_" +
-                                    Guid.NewGuid().ToString("N");
+                                   Guid.NewGuid().ToString("N") + "/?" + stringArray[1];
 
             Configure<AbpDbConnectionOptions>(options =>
             {

modules/cms-kit/test/Volo.CmsKit.MongoDB.Tests/MongoDB/MongoDbFixture.cs

@@ -1,5 +1,7 @@
 using System;
 using Mongo2Go;
+using MongoDB.Driver;
+using Volo.Abp.MongoDB;
 
 namespace Volo.CmsKit.MongoDB
 {
@@ -10,8 +12,12 @@ namespace Volo.CmsKit.MongoDB
 
         static MongoDbFixture()
         {
-            MongoDbRunner = MongoDbRunner.Start();
+            MongoDbRunner = MongoDbRunner.Start(singleNodeReplSet: true, singleNodeReplSetWaitTimeout: 10);
             ConnectionString = MongoDbRunner.ConnectionString;
+
+            //TODO It can be removed, when Mongo2Go solves this issue : https://github.com/Mongo2Go/Mongo2Go/issues/89
+            var client = new MongoClient(MongoDbRunner.ConnectionString);
+            client.EnsureReplicationSetReady();
         }
 
         public void Dispose()

modules/docs/test/Volo.Docs.MongoDB.Tests/Volo/Docs/MongoDB/DocsMongoDBTestModule.cs

@@ -12,9 +12,11 @@ namespace Volo.Docs.MongoDB
     {
         public override void ConfigureServices(ServiceConfigurationContext context)
         {
-            var connectionString = MongoDbFixture.ConnectionString.EnsureEndsWith('/') +
+            var stringArray = MongoDbFixture.ConnectionString.Split('?');
+
+            var connectionString = stringArray[0].EnsureEndsWith('/') +
                                    "Db_" +
-                                    Guid.NewGuid().ToString("N");
+                                   Guid.NewGuid().ToString("N") + "/?" + stringArray[1];
 
             Configure<AbpDbConnectionOptions>(options =>
             {

modules/docs/test/Volo.Docs.MongoDB.Tests/Volo/Docs/MongoDB/MongoDbFixture.cs

@@ -1,5 +1,7 @@
 using System;
 using Mongo2Go;
+using MongoDB.Driver;
+using Volo.Abp.MongoDB;
 
 namespace Volo.Docs.MongoDB
 {
@@ -10,8 +12,12 @@ namespace Volo.Docs.MongoDB
 
         static MongoDbFixture()
         {
-            MongoDbRunner = MongoDbRunner.Start();
+            MongoDbRunner = MongoDbRunner.Start(singleNodeReplSet: true, singleNodeReplSetWaitTimeout: 10);
             ConnectionString = MongoDbRunner.ConnectionString;
+
+            //TODO It can be removed, when Mongo2Go solves this issue : https://github.com/Mongo2Go/Mongo2Go/issues/89
+            var client = new MongoClient(MongoDbRunner.ConnectionString);
+            client.EnsureReplicationSetReady();
         }
 
         public void Dispose()

modules/feature-management/test/Volo.Abp.FeatureManagement.MongoDB.Tests/Volo/Abp/FeatureManagement/MongoDB/AbpFeatureManagementMongoDbTestModule.cs

@@ -12,9 +12,11 @@ namespace Volo.Abp.FeatureManagement.MongoDB
     {
         public override void ConfigureServices(ServiceConfigurationContext context)
         {
-            var connectionString = MongoDbFixture.ConnectionString.EnsureEndsWith('/') +
+            var stringArray = MongoDbFixture.ConnectionString.Split('?');
+
+            var connectionString = stringArray[0].EnsureEndsWith('/') +
                                    "Db_" +
-                                    Guid.NewGuid().ToString("N");
+                                   Guid.NewGuid().ToString("N") + "/?" + stringArray[1];
 
             Configure<AbpDbConnectionOptions>(options =>
             {

modules/feature-management/test/Volo.Abp.FeatureManagement.MongoDB.Tests/Volo/Abp/FeatureManagement/MongoDB/MongoDbFixture.cs

@@ -1,5 +1,7 @@
 using System;
 using Mongo2Go;
+using MongoDB.Driver;
+using Volo.Abp.MongoDB;
 
 namespace Volo.Abp.FeatureManagement.MongoDB
 {
@@ -10,8 +12,12 @@ namespace Volo.Abp.FeatureManagement.MongoDB
 
         static MongoDbFixture()
         {
-            MongoDbRunner = MongoDbRunner.Start();
+            MongoDbRunner = MongoDbRunner.Start(singleNodeReplSet: true, singleNodeReplSetWaitTimeout: 10);
             ConnectionString = MongoDbRunner.ConnectionString;
+
+            //TODO It can be removed, when Mongo2Go solves this issue : https://github.com/Mongo2Go/Mongo2Go/issues/89
+            var client = new MongoClient(MongoDbRunner.ConnectionString);
+            client.EnsureReplicationSetReady();
         }
 
         public void Dispose()

modules/identity/test/Volo.Abp.Identity.MongoDB.Tests/Volo/Abp/Identity/MongoDB/AbpIdentityMongoDbTestModule.cs

@@ -2,6 +2,7 @@
 using Volo.Abp.Data;
 using Volo.Abp.Modularity;
 using Volo.Abp.PermissionManagement.MongoDB;
+using Volo.Abp.Uow;
 
 namespace Volo.Abp.Identity.MongoDB
 {
@@ -14,14 +15,17 @@ namespace Volo.Abp.Identity.MongoDB
     {
         public override void ConfigureServices(ServiceConfigurationContext context)
         {
-            var connectionString = MongoDbFixture.ConnectionString.EnsureEndsWith('/') +
+            var stringArray = MongoDbFixture.ConnectionString.Split('?');
+
+            var connectionString = stringArray[0].EnsureEndsWith('/') +
                                    "Db_" +
-                                    Guid.NewGuid().ToString("N");
+                                   Guid.NewGuid().ToString("N") + "/?" + stringArray[1];
 
             Configure<AbpDbConnectionOptions>(options =>
             {
                 options.ConnectionStrings.Default = connectionString;
             });
+
         }
     }
 }

modules/identity/test/Volo.Abp.Identity.MongoDB.Tests/Volo/Abp/Identity/MongoDB/MongoDbFixture.cs

@@ -1,5 +1,7 @@
 using System;
 using Mongo2Go;
+using MongoDB.Driver;
+using Volo.Abp.MongoDB;
 
 namespace Volo.Abp.Identity.MongoDB
 {
@@ -10,8 +12,12 @@ namespace Volo.Abp.Identity.MongoDB
 
         static MongoDbFixture()
         {
-            MongoDbRunner = MongoDbRunner.Start();
+            MongoDbRunner = MongoDbRunner.Start(singleNodeReplSet: true, singleNodeReplSetWaitTimeout: 10);
             ConnectionString = MongoDbRunner.ConnectionString;
+
+            //TODO It can be removed, when Mongo2Go solves this issue : https://github.com/Mongo2Go/Mongo2Go/issues/89
+            var client = new MongoClient(MongoDbRunner.ConnectionString);
+            client.EnsureReplicationSetReady();
         }
 
         public void Dispose()

modules/identityserver/test/Volo.Abp.IdentityServer.MongoDB.Tests/Volo/Abp/IdentityServer/AbpIdentityServerMongoDbTestModule.cs

@@ -16,9 +16,11 @@ namespace Volo.Abp.IdentityServer
     {
         public override void ConfigureServices(ServiceConfigurationContext context)
         {
-            var connectionString = MongoDbFixture.ConnectionString.EnsureEndsWith('/') +
+            var stringArray = MongoDbFixture.ConnectionString.Split('?');
+
+            var connectionString = stringArray[0].EnsureEndsWith('/') +
                                    "Db_" +
-                                   Guid.NewGuid().ToString("N");
+                                   Guid.NewGuid().ToString("N") + "/?" + stringArray[1];
 
             Configure<AbpDbConnectionOptions>(options =>
             {

modules/identityserver/test/Volo.Abp.IdentityServer.MongoDB.Tests/Volo/Abp/IdentityServer/MongoDbFixture.cs

@@ -1,5 +1,7 @@
 using System;
 using Mongo2Go;
+using MongoDB.Driver;
+using Volo.Abp.MongoDB;
 
 namespace Volo.Abp.IdentityServer
 {
@@ -10,8 +12,12 @@ namespace Volo.Abp.IdentityServer
 
         static MongoDbFixture()
         {
-            MongoDbRunner = MongoDbRunner.Start();
+            MongoDbRunner = MongoDbRunner.Start(singleNodeReplSet: true, singleNodeReplSetWaitTimeout: 10);
             ConnectionString = MongoDbRunner.ConnectionString;
+
+            //TODO It can be removed, when Mongo2Go solves this issue : https://github.com/Mongo2Go/Mongo2Go/issues/89
+            var client = new MongoClient(MongoDbRunner.ConnectionString);
+            client.EnsureReplicationSetReady();
         }
 
         public void Dispose()

modules/permission-management/test/Volo.Abp.PermissionManagement.MongoDB.Tests/Volo/Abp/PermissionManagement/MongoDb/AbpPermissionManagementMongoDbTestModule.cs

@@ -11,9 +11,11 @@ namespace Volo.Abp.PermissionManagement.MongoDB
     {
         public override void ConfigureServices(ServiceConfigurationContext context)
         {
-            var connectionString = MongoDbFixture.ConnectionString.EnsureEndsWith('/') +
-                                    "Db_" +									
-                                    Guid.NewGuid().ToString("N");
+            var stringArray = MongoDbFixture.ConnectionString.Split('?');
+
+            var connectionString = stringArray[0].EnsureEndsWith('/') +
+                                   "Db_" +
+                                   Guid.NewGuid().ToString("N") + "/?" + stringArray[1];
 
             Configure<AbpDbConnectionOptions>(options =>
             {

modules/permission-management/test/Volo.Abp.PermissionManagement.MongoDB.Tests/Volo/Abp/PermissionManagement/MongoDb/MongoDbFixture.cs

@@ -1,5 +1,7 @@
 using System;
 using Mongo2Go;
+using MongoDB.Driver;
+using Volo.Abp.MongoDB;
 
 namespace Volo.Abp.PermissionManagement.MongoDB
 {
@@ -10,8 +12,12 @@ namespace Volo.Abp.PermissionManagement.MongoDB
 
         static MongoDbFixture()
         {
-            MongoDbRunner = MongoDbRunner.Start();
+            MongoDbRunner = MongoDbRunner.Start(singleNodeReplSet: true, singleNodeReplSetWaitTimeout: 10);
             ConnectionString = MongoDbRunner.ConnectionString;
+
+            //TODO It can be removed, when Mongo2Go solves this issue : https://github.com/Mongo2Go/Mongo2Go/issues/89
+            var client = new MongoClient(MongoDbRunner.ConnectionString);
+            client.EnsureReplicationSetReady();
         }
 
         public void Dispose()

modules/setting-management/test/Volo.Abp.SettingManagement.MongoDB.Tests/Volo/Abp/SettingManagement/MongoDB/AbpSettingManagementMongoDbTestModule.cs

@@ -12,9 +12,11 @@ namespace Volo.Abp.SettingManagement.MongoDB
     {
         public override void ConfigureServices(ServiceConfigurationContext context)
         {
-            var connectionString = MongoDbFixture.ConnectionString.EnsureEndsWith('/') +
+            var stringArray = MongoDbFixture.ConnectionString.Split('?');
+
+            var connectionString = stringArray[0].EnsureEndsWith('/') +
                                    "Db_" +
-                                    Guid.NewGuid().ToString("N");
+                                   Guid.NewGuid().ToString("N") + "/?" + stringArray[1];
 
             Configure<AbpDbConnectionOptions>(options =>
             {

modules/setting-management/test/Volo.Abp.SettingManagement.MongoDB.Tests/Volo/Abp/SettingManagement/MongoDB/MongoDbFixture.cs

@@ -1,5 +1,7 @@
 using System;
 using Mongo2Go;
+using MongoDB.Driver;
+using Volo.Abp.MongoDB;
 
 namespace Volo.Abp.SettingManagement.MongoDB
 {
@@ -10,8 +12,12 @@ namespace Volo.Abp.SettingManagement.MongoDB
 
         static MongoDbFixture()
         {
-            MongoDbRunner = MongoDbRunner.Start();
+            MongoDbRunner = MongoDbRunner.Start(singleNodeReplSet: true, singleNodeReplSetWaitTimeout: 10);
             ConnectionString = MongoDbRunner.ConnectionString;
+
+            //TODO It can be removed, when Mongo2Go solves this issue : https://github.com/Mongo2Go/Mongo2Go/issues/89
+            var client = new MongoClient(MongoDbRunner.ConnectionString);
+            client.EnsureReplicationSetReady();
         }
 
         public void Dispose()

modules/tenant-management/test/Volo.Abp.TenantManagement.MongoDB.Tests/Volo/Abp/TenantManagement/MongoDb/AbpTenantManagementMongoDbTestModule.cs

@@ -12,9 +12,11 @@ namespace Volo.Abp.TenantManagement.MongoDB
     {
         public override void ConfigureServices(ServiceConfigurationContext context)
         {
-            var connectionString = MongoDbFixture.ConnectionString.EnsureEndsWith('/') +
+            var stringArray = MongoDbFixture.ConnectionString.Split('?');
+
+            var connectionString = stringArray[0].EnsureEndsWith('/') +
                                    "Db_" +
-                                    Guid.NewGuid().ToString("N");
+                                   Guid.NewGuid().ToString("N") + "/?" + stringArray[1];
 
             Configure<AbpDbConnectionOptions>(options =>
             {

modules/tenant-management/test/Volo.Abp.TenantManagement.MongoDB.Tests/Volo/Abp/TenantManagement/MongoDb/MongoDbFixture.cs

@@ -1,5 +1,7 @@
 using System;
 using Mongo2Go;
+using MongoDB.Driver;
+using Volo.Abp.MongoDB;
 
 namespace Volo.Abp.TenantManagement.MongoDB
 {
@@ -10,8 +12,12 @@ namespace Volo.Abp.TenantManagement.MongoDB
 
         static MongoDbFixture()
         {
-            MongoDbRunner = MongoDbRunner.Start();
+            MongoDbRunner = MongoDbRunner.Start(singleNodeReplSet: true, singleNodeReplSetWaitTimeout: 10);
             ConnectionString = MongoDbRunner.ConnectionString;
+
+            //TODO It can be removed, when Mongo2Go solves this issue : https://github.com/Mongo2Go/Mongo2Go/issues/89
+            var client = new MongoClient(MongoDbRunner.ConnectionString);
+            client.EnsureReplicationSetReady();
         }
 
         public void Dispose()

templates/app/aspnet-core/test/MyCompanyName.MyProjectName.MongoDB.Tests/MongoDb/MyProjectNameMongoDbFixture.cs

@@ -1,5 +1,7 @@
 using System;
 using Mongo2Go;
+using MongoDB.Driver;
+using Volo.Abp.MongoDB;
 
 namespace MyCompanyName.MyProjectName.MongoDB
 {
@@ -10,8 +12,11 @@ namespace MyCompanyName.MyProjectName.MongoDB
 
         static MyProjectNameMongoDbFixture()
         {
-            MongoDbRunner = MongoDbRunner.Start();
+            MongoDbRunner = MongoDbRunner.Start(singleNodeReplSet: true, singleNodeReplSetWaitTimeout: 10);
             ConnectionString = MongoDbRunner.ConnectionString;
+
+            var client = new MongoClient(MongoDbRunner.ConnectionString);
+            client.EnsureReplicationSetReady();
         }
 
         public void Dispose()

templates/app/aspnet-core/test/MyCompanyName.MyProjectName.MongoDB.Tests/MongoDb/MyProjectNameMongoDbTestModule.cs

@@ -12,9 +12,11 @@ namespace MyCompanyName.MyProjectName.MongoDB
     {
         public override void ConfigureServices(ServiceConfigurationContext context)
         {
-            var connectionString = MyProjectNameMongoDbFixture.ConnectionString.EnsureEndsWith('/') +
+            var stringArray = MyProjectNameMongoDbFixture.ConnectionString.Split('?');
+
+            var connectionString = stringArray[0].EnsureEndsWith('/') +
                                    "Db_" +
-                                   Guid.NewGuid().ToString("N");
+                                   Guid.NewGuid().ToString("N") + "/?" + stringArray[1];
 
             Configure<AbpDbConnectionOptions>(options =>
             {

templates/module/aspnet-core/test/MyCompanyName.MyProjectName.MongoDB.Tests/MongoDB/MongoDbFixture.cs

@@ -1,5 +1,7 @@
 using System;
 using Mongo2Go;
+using MongoDB.Driver;
+using Volo.Abp.MongoDB;
 
 namespace MyCompanyName.MyProjectName.MongoDB
 {
@@ -10,8 +12,12 @@ namespace MyCompanyName.MyProjectName.MongoDB
 
         static MongoDbFixture()
         {
-            MongoDbRunner = MongoDbRunner.Start();
+            MongoDbRunner = MongoDbRunner.Start(singleNodeReplSet: true, singleNodeReplSetWaitTimeout: 10);
             ConnectionString = MongoDbRunner.ConnectionString;
+
+            //TODO It can be removed, when Mongo2Go solves this issue : https://github.com/Mongo2Go/Mongo2Go/issues/89
+            var client = new MongoClient(MongoDbRunner.ConnectionString);
+            client.EnsureReplicationSetReady();
         }
 
         public void Dispose()

templates/module/aspnet-core/test/MyCompanyName.MyProjectName.MongoDB.Tests/MongoDB/MyProjectNameMongoDbTestModule.cs

@@ -12,9 +12,11 @@ namespace MyCompanyName.MyProjectName.MongoDB
     {
         public override void ConfigureServices(ServiceConfigurationContext context)
         {
-            var connectionString = MongoDbFixture.ConnectionString.EnsureEndsWith('/') +
+            var stringArray = MongoDbFixture.ConnectionString.Split('?');
+
+            var connectionString = stringArray[0].EnsureEndsWith('/') +
                                    "Db_" +
-                                    Guid.NewGuid().ToString("N");
+                                   Guid.NewGuid().ToString("N") + "/?" + stringArray[1];
 
             Configure<AbpDbConnectionOptions>(options =>
             {
@@ -22,4 +24,4 @@ namespace MyCompanyName.MyProjectName.MongoDB
             });
         }
     }
-}
+}