Commit 3ec4ca27 by adith.s

Add new file

parent fd9cceae
from flask import Response, request
import pymongo
import json
from bson.objectid import ObjectId
from flask import Blueprint
Second = Blueprint("Second", __name__)
try:
mongo = pymongo.MongoClient(
host="localhost",
port=27017,
serverSelectionTimeoutMS=1000
)
db = mongo.company
except:
print("Error cannot connect to db")
@Second.route("/users", methods=["GET"])
def get_some_users():
try:
data = list(db.users.find())
for user in data:
user["_id"] = str(user["_id"])
print(data)
return Response(response=json.dumps(
[{"id": 1}, {"id": 2}]),
status=500,
mimetype="application/json"
)
except Exception as ex:
print(ex)
return Response(response=json.dumps(
{"message": "Cannot Read Users"}),
status=500,
mimetype="application/json"
)
@Second.route("/users", methods=["POST"])
def create_user():
try:
user = {"name": request.form["name"],
"LastName": request.form["LastName"]}
dbResponse = db.users.insert_one(user)
print(dbResponse.inserted_id)
# for attr in dir(dbResponse):
# print(attr)
return Response(
response=json.dumps(
{"message": "User created", "id": f"{dbResponse.inserted_id}"}),
status=200,
mimetype="application/json"
)
except Exception as ex:
print(ex)
@Second.route("/users/<id>", methods=["PATCH"])
def update_user(id):
try:
dbResponse = db.users.update_one(
{"_id": ObjectId(id)},
{"&set": {"name": request.form["name"]}}
)
for attr in dir(dbResponse):
print(f"****{attr}***")
return Response(
response=json.dumps(
{"message": "Updated User", "id": f"{dbResponse.inserted_id}"}),
status=200,
mimetype="application/json"
)
except Exception as ex:
print("#########")
print(ex)
return Response(
response=json.dumps(
{"message": "Sorry cannot update user", "id": f"{dbResponse.inserted_id}"}),
status=500,
mimetype="application/json"
)
if __name__ == "__main__":
Second.run(port=80, debug=True)
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment