This repository was archived by the owner on Aug 19, 2024. It is now read-only.
-
Notifications
You must be signed in to change notification settings - Fork 25
/
Copy pathmain.py
80 lines (55 loc) · 1.91 KB
/
main.py
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
from fastapi import FastAPI,status,HTTPException
from pydantic import BaseModel
from typing import Optional,List
from database import SessionLocal
import models
app=FastAPI()
class Item(BaseModel): #serializer
id:int
name:str
description:str
price:int
on_offer:bool
class Config:
orm_mode=True
db=SessionLocal()
@app.get('/items',response_model=List[Item],status_code=200)
def get_all_items():
items=db.query(models.Item).all()
return items
@app.get('/item/{item_id}',response_model=Item,status_code=status.HTTP_200_OK)
def get_an_item(item_id:int):
item=db.query(models.Item).filter(models.Item.id==item_id).first()
return item
@app.post('/items',response_model=Item,
status_code=status.HTTP_201_CREATED)
def create_an_item(item:Item):
db_item=db.query(models.Item).filter(models.Item.name==item.name).first()
if db_item is not None:
raise HTTPException(status_code=400,detail="Item already exists")
new_item=models.Item(
name=item.name,
price=item.price,
description=item.description,
on_offer=item.on_offer
)
db.add(new_item)
db.commit()
return new_item
@app.put('/item/{item_id}',response_model=Item,status_code=status.HTTP_200_OK)
def update_an_item(item_id:int,item:Item):
item_to_update=db.query(models.Item).filter(models.Item.id==item_id).first()
item_to_update.name=item.name
item_to_update.price=item.price
item_to_update.description=item.description
item_to_update.on_offer=item.on_offer
db.commit()
return item_to_update
@app.delete('/item/{item_id}')
def delete_item(item_id:int):
item_to_delete=db.query(models.Item).filter(models.Item.id==item_id).first()
if item_to_delete is None:
raise HTTPException(status_code=status.HTTP_404_NOT_FOUND,detail="Resource Not Found")
db.delete(item_to_delete)
db.commit()
return item_to_delete