blog_api/routers/blogmanage.py

from fastapi import Depends,APIRouter,status
from internal.models import *
from dependencies import get_current_active_user,execute_query

router=APIRouter(
    prefix="/blogs",
    tags=['博客管理']
)
@router.post('/add',response_model=BlogResponse)
async def blog_add(blog:Blog,_:User=Depends(get_current_active_user)):
    select_query="INSERT INTO blogs (blogtitle,blogcontent,typeid,descr) VALUES (%s,%s,%s,%s)"
    blog_data=(blog.blogtitle,blog.blogcontent,blog.typeid,blog.descr)
    execute_query(select_query,blog_data)
    return {
        'status':status.HTTP_200_OK,
        'message':'blog create successfully!',
        'blog':blog
    }