48 lines
2.3 KiB
Python
48 lines
2.3 KiB
Python
# 使用orm结合fastapi接口对数据库的订单表进行增删改查
|
|
# ① 连接数据库，定义数据库表模型，以及数据库会话工具
|
|
# ② 定义请求体模型，编写post接口对数据库的订单表插入数据
|
|
# ③ 编写put接口对订单进行更新操作
|
|
# ④ 编写get接口对订单进行查询操作
|
|
# ⑤ 编写delete接口对订单进行删除操作
|
|
# ① api目录里编写一个文件order_api.py ,利用api路由分发，存放编写好的以上四个订单增删改查接口
|
|
from fastapi import APIRouter, Depends, HTTPException
|
|
from homework.day23.schema.order_schema import *
|
|
from homework.day23.database import get_db
|
|
from homework.day23.dao.order_dao import *
|
|
|
|
OrderAPI = APIRouter()
|
|
|
|
@OrderAPI.post("",summary="订单新增接口",response_model=OrderResponse)
|
|
def add_order(ord:list[OrderRequest],db=Depends(get_db)):
|
|
for i in ord:
|
|
d = i.model_dump()
|
|
r = add_order_dao(o=d,db=db)
|
|
if not r:
|
|
raise HTTPException(status_code=500,detail='添加失败！请稍后在添加！')
|
|
return OrderResponse(detail='添加成功！',total=len(ord))
|
|
|
|
@OrderAPI.put("/{order_id}",summary="订单更新接口",response_model=OrderResponse)
|
|
def update_order(order_id:int, ord:OrderRequest,db=Depends(get_db)):
|
|
rows = update_order_dao(id=order_id,o=ord,db=db)
|
|
if not rows:
|
|
raise HTTPException(status_code=500, detail='更新失败！')
|
|
return OrderResponse(detail='更新成功！',total= rows )
|
|
|
|
@OrderAPI.get("",summary="订单查询接口",response_model=OrderResponse)
|
|
def get_order(order_title:str|None = None,order_id:int|None = None,page:int=1,page_size:int=10,db=Depends(get_db)):
|
|
r = get_order_dao(id = order_id,title=order_title,p=page,pz=page_size,db=db)
|
|
if r:
|
|
return OrderResponse(detail='更新成功！',total=len(r),data=r )
|
|
raise HTTPException(status_code=404, detail='订单不存在！')
|
|
|
|
@OrderAPI.delete("/{order_id}",summary="订单删除接口",response_model=OrderResponse)
|
|
def delete_order(order_id:int,db=Depends(get_db)):
|
|
rows = del_order_dao(id=order_id,db=db)
|
|
if not rows:
|
|
raise HTTPException(status_code=500, detail='删除异常！')
|
|
return OrderResponse(detail='删除成功！',total= rows )
|
|
|
|
|
|
|
|
|