1.schemas/users.py
# 更新用户信息的模型类 class UserUpdateRequest(BaseModel): nickname: str = None avatar: str = None gender: str = None bio: str = None phone: str = None
2.crud/users.py
# 更新用户信息：update更新 -> 检查是否命中 -> 获取更新后的用户返回 async def update_user(db: AsyncSession, username: str, user_data: UserUpdateRequest): # update(User).where(User.username == username).values(字段=值，字段=值) # user_data 是一个 Pydantic 类型，得到字典 -> ** 解包 # 没有设置值的不更新 query = update(User).where(User.username == username).values(**user_data.model_dump( exclude_unset=True, exclude_none=True )) result = await db.execute(query) await db.commit() # 检查更新 if result.rowcount == 0: raise HTTPException(status_code=404, detail="用户不存在") # 获取一下更新后的用户 updated_user = await get_user_by_username(db, username) return updated_user
3.routers/users.py
# 修改用户信息：验证Token -> 更新（用户输入数据 put提交 -> 请求体参数 -> 定义Pydantic模型类） -> 响应结果 # 参数：用户输入的 + 验证Token的 + db（调用更新的方法） @router.put("/update") async def update_user_info( user_data: UserUpdateRequest, user: User = Depends(get_current_user), db: AsyncSession = Depends(get_db) ): user = await users.update_user(db, user.username, user_data) return success_response( message="更新用户信息成功", data=UserInfoResponse.model_validate(user) )
