Update db_operations/db_operations.py

db_operations/db_operations.py

@@ -19,6 +19,7 @@ class DBOperations:
             _ = self.__client.list_database_names()
         except Exception as conn_exception:
             self.__error = 1
+            self.__close_connection()
             self.__client = None
             raise
 
@@ -31,6 +32,7 @@ class DBOperations:
             coll.insert_many(documents=documents)
         except Exception as insert_err:
             self.__error = 1
+            self.__close_connection()
             raise
 
     def __close_connection(self):