remove encrypted collections

Author: blink1073

test/asynchronous/unified_format.py

@@ -482,6 +482,7 @@ async def insert_initial_data(self, initial_data):
                 wc = WriteConcern(w="majority")
             else:
                 wc = WriteConcern(w=1)
+
             if documents:
                 if opts:
                     await db.create_collection(coll_name, **opts)
@@ -490,6 +491,12 @@ async def insert_initial_data(self, initial_data):
                 # Ensure collection exists
                 await db.create_collection(coll_name, write_concern=wc, **opts)
 
+            # Remove any encryption collections associated with the collection.
+            collections = await db.list_collection_names()
+            for collection in collections:
+                if collection in [f"nxcol_{coll_name}.esc", "enxcol_{coll_name}.ecoc"]:
+                    await db.drop_collection(collection)
+
     @classmethod
     def setUpClass(cls) -> None:
         # Speed up the tests by decreasing the heartbeat frequency.
@@ -508,6 +515,7 @@ def tearDownClass(cls) -> None:
     async def asyncSetUp(self):
         # super call creates internal client cls.client
         await super().asyncSetUp()
+
         # process file-level runOnRequirements
         run_on_spec = self.TEST_SPEC.get("runOnRequirements", [])
         if not await self.should_run_on(run_on_spec):

test/unified_format.py

@@ -481,6 +481,7 @@ def insert_initial_data(self, initial_data):
                 wc = WriteConcern(w="majority")
             else:
                 wc = WriteConcern(w=1)
+
             if documents:
                 if opts:
                     db.create_collection(coll_name, **opts)
@@ -489,6 +490,12 @@ def insert_initial_data(self, initial_data):
                 # Ensure collection exists
                 db.create_collection(coll_name, write_concern=wc, **opts)
 
+            # Remove any encryption collections associated with the collection.
+            collections = db.list_collection_names()
+            for collection in collections:
+                if collection in [f"nxcol_{coll_name}.esc", "enxcol_{coll_name}.ecoc"]:
+                    db.drop_collection(collection)
+
     @classmethod
     def setUpClass(cls) -> None:
         # Speed up the tests by decreasing the heartbeat frequency.
@@ -507,6 +514,7 @@ def tearDownClass(cls) -> None:
     def setUp(self):
         # super call creates internal client cls.client
         super().setUp()
+
         # process file-level runOnRequirements
         run_on_spec = self.TEST_SPEC.get("runOnRequirements", [])
         if not self.should_run_on(run_on_spec):