fix: 增加数据库操作示例
This commit is contained in:
parent
51e370d017
commit
6312b41f2c
|
|
@ -9,7 +9,8 @@ from fastapi_sqlalchemy import db
|
||||||
from pydantic import BaseModel
|
from pydantic import BaseModel
|
||||||
from pydantic_sqlalchemy import sqlalchemy_to_pydantic
|
from pydantic_sqlalchemy import sqlalchemy_to_pydantic
|
||||||
|
|
||||||
from models.devices_place import DevicesPlace
|
from src.biz.test import get_user_by_id
|
||||||
|
from src.models.devices_place import DevicesPlace
|
||||||
|
|
||||||
router = APIRouter(prefix="/test")
|
router = APIRouter(prefix="/test")
|
||||||
|
|
||||||
|
|
@ -41,6 +42,9 @@ async def get_current_user(token: str = Depends(oauth2_scheme)):
|
||||||
user = fake_decode_token(token)
|
user = fake_decode_token(token)
|
||||||
return user
|
return user
|
||||||
|
|
||||||
|
@router.get('/user/')
|
||||||
|
async def get_user():
|
||||||
|
return get_user_by_id(27)
|
||||||
|
|
||||||
# 登录验证
|
# 登录验证
|
||||||
@router.get("/users/me")
|
@router.get("/users/me")
|
||||||
|
|
|
||||||
|
|
@ -0,0 +1,6 @@
|
||||||
|
from src.biz import execute_sql
|
||||||
|
|
||||||
|
|
||||||
|
def get_user_by_id(user_id):
|
||||||
|
user = execute_sql("SELECT Id FROM sys_users WHERE Id = :user_id", user_id=user_id).scalar()
|
||||||
|
return user
|
||||||
Loading…
Reference in New Issue