Basic commit

app.py

+from flask import Flask
+
+from scripts.service.mango_service import mongo_inserter
+
+app = Flask(__name__)
+app.register_blueprint(mongo_inserter)
+try:
+    if __name__ == '__main__':
+        app.run(port=9001)
+except Exception as e:
+    print(e)

scripts/handler/displaymongo_data.py

+def display(data):
+    try:
+        # Displaying using find()
+        records = data.find()
+        for data_values in records:
+            print(data_values)
+        # Displaying using find_one()
+        print(data.find_one())
+    except Exception:
+        return Exception("Problem in Displaying")
+
+
+def insert(user_details, data):
+    try:
+        # we can use insert_many for inertion all records at a time.
+        for data_value in data:
+            user_details.insert_one(data_value)
+    except Exception:
+        return "Problem in insertion"
+
+
+def finding(user_details, query):
+    try:
+
+        details = user_details.find(query)
+        for values in details:
+            print(values)
+    except Exception:
+        return "Problem in Searching"
+
+
+def sort(user_details, base_value):
+    try:
+        details = user_details.find().sort(base_value)
+        for values in details:
+            print(values)
+    except Exception:
+        return "Problem in sorting"
+
+
+def delete(user_details, my_query):
+    try:
+        # delete single query at a time
+        user_details.delete_one(my_query)
+        # to Delete all records
+        user_details.delete_many({})
+    except Exception:
+        return "Problem in sorting"

scripts/handler/finding_query.py

+def find_query(user_details):
+    # find the records whose gender is male
+    records = user_details.find({"gender": "Male"})
+    for data_values in records:
+        print(data_values)
+    # find the records whose gender is female
+    records = user_details.find({"gender": "Female"})
+    for data_values in records:
+        print(data_values)
+    # finding whoes first_name starts with A
+    records = user_details.find({'first_name': {'$regex': "^A"}})
+    for data_values in records:
+        print(data_values)
+    # finding whoes first_name ends with n
+    records = user_details.find({'first_name': {'$regex': "n$"}})
+    for data_values in records:
+        print(data_values)
+    # finding whoes last_name starts with B
+    records = user_details.find({'last_name': {'$regex': "$B"}})
+    for data_values in records:
+        print(data_values)
+    # finding whoes last_name ends with y
+    records = user_details.find({'last_name': {'$regex': "y$"}})
+    for data_values in records:
+        print(data_values)
+    # finding whoes email ends with .io
+    records = user_details.find({'email': {'$regex': ".io$"}})
+    for data_values in records:
+        print(data_values)

scripts/handler/mongo_handler.py

+from pymongo import MongoClient
+from scripts.handler.displaymongo_data import display, insert, finding, sort, delete
+from scripts.handler.finding_query import find_query
+
+
+class Mongobd:
+    @staticmethod
+    def connecting_mongodb(data):
+        try:
+            client = MongoClient('143.110.191.155', 37217)
+            database = client.kranthi
+            user_details = database.user_details
+            # insertion
+            insert(user_details, data)
+            # Displaying
+            display(user_details)
+            # searching
+            query = {'email': 'cboardman4@soup.io'}
+            finding(user_details, query)
+            # sorting
+            sort(user_details, 'first_name')
+
+            # delete
+            query = {'email': 'cboardman4@soup.io'}
+            delete(user_details, query)
+            find_query(user_details)
+            return "process is done successfully"
+
+        except Exception:
+            raise Exception("Error in Mongo")

scripts/service/mango_service.py

+from flask import Blueprint
+from flask import request
+from scripts.handler.mongo_handler import Mongobd
+
+mongo_inserter = Blueprint('example_blueprint', __name__)
+
+mongobd_object = Mongobd()
+
+try:
+    @mongo_inserter.route('/mongo', methods=['POST'])
+    def post_request():
+        content = request.get_json()
+        requried_data = mongobd_object.connecting_mongodb(content)
+        return requried_data
+except Exception:
+
+    raise Exception