Getting Started With MongoDB and Starlette

1
git clone git@github.com:mongodb-developer/mongodb-with-starlette.git

1
cd mongodb-with-starlette
2
pip install -r requirements.txt

1
export MONGODB_URL="mongodb+srv://<username>:<password>@<url>/<db>?retryWrites=true&w=majority"

1
uvicorn app:app --reload

1
curl -X "POST" "http://localhost:8000/" \
2
    -H 'Accept: application/json' \
3
    -H 'Content-Type: application/json; charset=utf-8' \
4
    -d '{
5
        "name": "Jane Doe",
6
        "email": "jdoe@example.com",
7
        "gpa": "3.9"
8
    }'

1
client = motor.motor_asyncio.AsyncIOMotorClient(os.environ["MONGODB_URL"])
2
db = client.college

1
async def create_student(request):
2
    student = await request.json()
3
    student["_id"] = str(ObjectId())
4
    new_student = await db["students"].insert_one(student)
5
    created_student = await db["students"].find_one({"_id": new_student.inserted_id})
6
    return JSONResponse(status_code=201, content=created_student)

1
async def list_students(request):
2
    students = await db["students"].find().to_list(1000)
3
    return JSONResponse(students)

1
async def show_student(request):
2
    id = request.path_params["id"]
3
    if (student := await db["students"].find_one({"_id": id})) is not None:
4
        return JSONResponse(student)
5
6
    raise HTTPException(status_code=404, detail=f"Student {id} not found")

1
async def update_student(request):
2
    id = request.path_params["id"]
3
    student = await request.json()
4
    update_result = await db["students"].update_one({"_id": id}, {"$set": student})
5
6
    if update_result.modified_count == 1:
7
        if (updated_student := await db["students"].find_one({"_id": id})) is not None:
8
            return JSONResponse(updated_student)
9
10
    if (existing_student := await db["students"].find_one({"_id": id})) is not None:
11
        return JSONResponse(existing_student)
12
13
    raise HTTPException(status_code=404, detail=f"Student {id} not found")

1
async def delete_student(request):
2
    id = request.path_params["id"]
3
    delete_result = await db["students"].delete_one({"_id": id})
4
5
    if delete_result.deleted_count == 1:
6
        return JSONResponse(status_code=204)
7
8
    raise HTTPException(status_code=404, detail=f"Student {id} not found")

1
app = Starlette(
2
    debug=True,
3
    routes=[
4
        Route("/", create_student, methods=["POST"]),
5
        Route("/", list_students, methods=["GET"]),
6
        Route("/{id}", show_student, methods=["GET"]),
7
        Route("/{id}", update_student, methods=["PUT"]),
8
        Route("/{id}", delete_student, methods=["DELETE"]),
9
    ],
10
)