diff --git a/order_api.py b/order_api.py deleted file mode 100644 index 45e02d9..0000000 --- a/order_api.py +++ /dev/null @@ -1,47 +0,0 @@ -# 使用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 ) - - - -