iK >UdZddlmZddlmZmZmZmZddlm Z ddl m Z Gdde Z e jjdZd d iZeed <esej'd d dee jfieZeed<eeed d Zeeed<deedffdZy)u 資料庫連線管理(SQLAlchemy 2.0 async)。 設計重點: 1. 使用 async 引擎,FastAPI 是 async 框架,不用 async 等於浪費效能。 2. AsyncSession 透過 FastAPI dependency injection 注入到 endpoint。 3. 每個請求一個 session,請求結束自動關閉。 )AsyncGenerator) AsyncEngine AsyncSessionasync_sessionmakercreate_async_engine)DeclarativeBase)settingsceZdZdZy)BaseuSQLAlchemy 的 declarative base。 所有資料表 Model(例如 User)都繼承 Base, Alembic 會用 Base.metadata 自動偵測資料表變化、產生 migration。 N)__name__ __module__ __qualname____doc__0/volume1/homes/robertsu/coba/app/app/database.pyr r s   rr sqliteechoF_engine_kwargsT ) pool_pre_ping pool_size max_overflowengine)bindclass_expire_on_commit autoflushAsyncSessionLocalreturnNcKt4d{} |dddd{y7#t$r|jd{7wxYw7.#1d{7swYyxYww)u提供 AsyncSession 給 endpoint 使用。 用法(在 endpoint 函式參數): async def some_endpoint(db: AsyncSession = Depends(get_db)): ... yield 後面的 async with 自動處理 commit/rollback/close。 N)r Exceptionrollback)sessions rget_dbr&>s]!""g M#"" ""$ $ $  #"""s[A--A-A/ A-AA-A A AAA-A*A! A*&A-)rtypingrsqlalchemy.ext.asynciorrrrsqlalchemy.ormr app.configr r DATABASE_URL startswith _is_sqliterdict__annotations__updaterr r&rrrr1s"ee*  ?  " " - -h 7  E *(*?*?R>R R 7I   7%l3n\4%78r