data.model.database

Async SQLAlchemy 引擎与会话管理。

Attributes

SKIP_DB
engine
async_session

Classes

Base	SQLAlchemy ORM 声明式基类，所有数据模型继承此类。

Functions

get_session(...)	获取异步数据库会话，用于 FastAPI Depends 注入。
init_db()	创建所有 ORM 模型对应的数据库表（幂等，CREATE TABLE IF NOT EXISTS）。
close_db()	关闭数据库连接池，释放所有连接。

Module Contents

data.model.database.SKIP_DB

data.model.database.engine

data.model.database.async_session

class data.model.database.Base

Bases: sqlalchemy.orm.DeclarativeBase

SQLAlchemy ORM 声明式基类，所有数据模型继承此类。

async data.model.database.get_session() → collections.abc.AsyncGenerator[sqlalchemy.ext.asyncio.AsyncSession, None]

获取异步数据库会话，用于 FastAPI Depends 注入。

async data.model.database.init_db()

创建所有 ORM 模型对应的数据库表（幂等，CREATE TABLE IF NOT EXISTS）。

async data.model.database.close_db()

关闭数据库连接池，释放所有连接。