diff --git a/packages/datasource-mongo/test/create.integration.test.ts b/packages/datasource-mongo/test/create.integration.test.ts
index 443d087c1e..05a8a799f8 100644
--- a/packages/datasource-mongo/test/create.integration.test.ts
+++ b/packages/datasource-mongo/test/create.integration.test.ts
@@ -10,11 +10,12 @@ describe('create', () => {
       'mongodb://forest:secret@127.0.0.1:27017/movies?authSource=admin',
     );
 
-    connection.dropDatabase();
+    await connection.dropDatabase();
 
     try {
       const movieSchema = new Schema({ title: String });
       const Movie = connection.model('Movies', movieSchema);
+      await Movie.createCollection();
       await new Movie({ title: 'Inception' }).save();
     } finally {
       await connection.close(true);
diff --git a/packages/datasource-mongo/test/index.ssh.integration.test.ts b/packages/datasource-mongo/test/index.ssh.integration.test.ts
index 7bd7a5b0b9..44c3554f7f 100644
--- a/packages/datasource-mongo/test/index.ssh.integration.test.ts
+++ b/packages/datasource-mongo/test/index.ssh.integration.test.ts
@@ -12,11 +12,12 @@ describe('Datasource Mongo', () => {
         'mongodb://forest:secret@127.0.0.1:27017/movies-ssh?authSource=admin',
       );
 
-      connection.dropDatabase();
+      await connection.dropDatabase();
 
       try {
         const movieSchema = new Schema({ title: String });
         const Movie = connection.model('Movies', movieSchema);
+        await Movie.createCollection();
         await new Movie({ title: 'Inception' }).save();
       } finally {
         await connection.close(true);