Basic Commit

scripts/core/mango_service.py

+from scripts.core.mongo_handler import Mongo_utility
+
+mongo_utility_object = Mongo_utility()
+
+
+class Mongobd:
+    @staticmethod
+    def connecting_mongodb():
+        try:
+            # Displaying
+            mongo_utility_object.display("kranthi", "user_details")
+            # searching
+            query = {'email': 'cboardman4@soup.io'}
+            details = mongo_utility_object.find("kranthi", "user_details", query)
+            for values in details:
+                print(values)
+            # Update
+            query = {"last_name": "Hefferon"}, {'$set': {'last_name': "Ingra"}}
+            mongo_utility_object.update("kranthi", "user_details", query)
+            # delete
+            query = {'email': 'cboardman4@soup.io'}
+            mongo_utility_object.delete("kranthi", "user_details", query)
+            return "process is done successfully"
+
+        except Exception as e:
+            print(e)
+
+
+Mongobd.connecting_mongodb()

scripts/core/mongo_handler.py

+from pymongo import MongoClient
+
+
+class Mongo_utility:
+    @staticmethod
+    def display(database_name, collection_name):
+        try:
+            client = MongoClient('143.110.191.155', 37217)
+            database = client[database_name]
+            user_details = database[collection_name]
+            # Displaying using find()
+            records = user_details.find()
+            for data_values in records:
+                print(data_values)
+            # Displaying using find_one()
+            print(user_details.find_one())
+        except Exception:
+            return Exception("Problem in Displaying")
+
+    @staticmethod
+    def find(database_name, collection_name, query):
+        try:
+            client = MongoClient('143.110.191.155', 37217)
+            database = client[database_name]
+            user_details = database[collection_name]
+            return user_details.find(query)
+        except Exception:
+            return "Problem in Searching"
+
+    @staticmethod
+    def update(database_name, collection_name, query):
+        try:
+            client = MongoClient('143.110.191.155', 37217)
+            database = client[database_name]
+            user_details = database[collection_name]
+            # Updateing one record
+            user_details.update(query[0], query[1])
+            # we can Update monay records at a time by useing updateMany
+
+        except Exception:
+            return "Problem in Updateing"
+
+    @staticmethod
+    def delete(database_name, collection_name, query):
+        try:
+            client = MongoClient('143.110.191.155', 37217)
+            database = client[database_name]
+            user_details = database[collection_name]
+            # delete single query at a time
+            user_details.delete_one(query)
+            # We can Delete all records by useing (user_details.delete_many({}))
+        except Exception:
+            return "Problem in deleteing"