File tree Expand file tree Collapse file tree 2 files changed +7
-3
lines changed Expand file tree Collapse file tree 2 files changed +7
-3
lines changed Original file line number Diff line number Diff line change 18
18
from backend .common .log import set_custom_logfile , setup_logging
19
19
from backend .core .conf import settings
20
20
from backend .core .path_conf import STATIC_DIR , UPLOAD_DIR
21
- from backend .database .db import create_table
21
+ from backend .database .db import create_tables
22
22
from backend .database .redis import redis_client
23
23
from backend .middleware .access_middleware import AccessMiddleware
24
24
from backend .middleware .jwt_auth_middleware import JwtAuthMiddleware
@@ -40,7 +40,7 @@ async def register_init(app: FastAPI) -> AsyncGenerator[None, None]:
40
40
:return:
41
41
"""
42
42
# 创建数据库表
43
- await create_table ()
43
+ await create_tables ()
44
44
# 初始化 limiter
45
45
await FastAPILimiter .init (
46
46
redis = redis_client ,
Original file line number Diff line number Diff line change @@ -75,7 +75,7 @@ async def get_db() -> AsyncGenerator[AsyncSession, None]:
75
75
yield session
76
76
77
77
78
- async def create_table () -> None :
78
+ async def create_tables () -> None :
79
79
"""创建数据库表"""
80
80
async with async_engine .begin () as coon :
81
81
await coon .run_sync (MappedBase .metadata .create_all )
@@ -86,7 +86,11 @@ def uuid4_str() -> str:
86
86
return str (uuid4 ())
87
87
88
88
89
+ # SQLA 数据库链接
89
90
SQLALCHEMY_DATABASE_URL = create_database_url ()
91
+
92
+ # SALA 异步引擎和会话
90
93
async_engine , async_db_session = create_async_engine_and_session (SQLALCHEMY_DATABASE_URL )
94
+
91
95
# Session Annotated
92
96
CurrentSession = Annotated [AsyncSession , Depends (get_db )]
You can’t perform that action at this time.
0 commit comments