FastAPI 结合 SQLModel 和 MySQL 8 是一种现代而高效的 Python 后端开发组合方案，特别适合需要快速构建 API 并与数据库交互的应用程序。下面将详细介绍这三者的集成方式及其优势。 ### FastAPI **特点：** - **异步支持**：原生支持 async/await 异步编程模型，极大提升了 I/O 密集型任务（例如网络请求）的性能。 - **自动生成 OpenAPI 文档**：只需编写路由函数和 Pydantic 模型即可生成详细的 API 文档，并附带测试界面 Swagger UI 或 ReDoc。 - **依赖注入**：通过装饰器轻松注入依赖项到视图函数中，减少了样板代码并提高了模块化的程度。 - **类型提示**：利用 Python 的类型注解特性来进行输入验证，简化了数据校验的过程并且降低了出错的概率。 ### SQLModel **特点：** - **兼容 SQLAlchemy**：SQLModel 基于知名的 ORM 库 SQLAlchemy 构建而成，在保持其强大功能的同时提供了更简洁直观的数据定义语法——直接基于 Pydantic Model 定义表结构。 - **Pydantic 集成**：由于 SQLModel 使用的是 Pydantic 来描述字段属性，因此它能够很好地与其他基于此库的工作流相整合，比如 FastAPI 请求体解析等场景。 - **声明式映射**：以类的形式声明表格信息及关联关系，使得代码组织更为清晰明了；同时也能方便地进行增删改查操作而不必书写冗长复杂的 SQL 查询语句。 ### MySQL 8 作为最流行的开源关系型数据库管理系统之一，MySQL 版本更新到了第八代之后增加了许多新特性和改进： - **增强的安全措施**：引入了更强的身份验证插件、默认启用了 SSL 等安全策略来保护敏感信息免受攻击威胁。 - **更好的 JSON 支持**：新增加了许多针对 JSON 数据类型的优化索引机制和其他实用工具。 - **窗口函数**：允许在一个查询结果集中计算累积聚合值或其他复杂统计指标。 - **不可变空间回收**：优化 InnoDB 存储引擎内部的空间分配算法，提高读取速度降低磁盘占用率。 #### 整合示例 接下来展示一个简单的例子说明如何把这三个组件结合起来使用： ```python # main.py from fastapi import FastAPI, Depends from sqlmodel import Field, Session, select, SQLModel import mysql.connector from typing import List from sqlalchemy.ext.asyncio import create_async_engine, AsyncSession from sqlalchemy.orm import sessionmaker DATABASE_URL = "mysql+asyncmy://username:password@localhost/dbname" engine = create_async_engine(DATABASE_URL) AsyncDBSession = sessionmaker( bind=engine, class_=AsyncSession, expire_on_commit=False, ) class Item(SQLModel, table=True): id: int = Field(default=None, primary_key=True) name: str = Field(index=True) app = FastAPI() @app.on_event("startup") def startup(): # 创建所有表结构 如果不存在的话 engine.sync_engine.connect() SQLModel.metadata.create_all(engine.sync_engine) engine.sync_engine.dispose() @app.post("/items/", response_model=Item) async def add_item(item: Item, db_session: AsyncSession = Depends(AsyncDBSession)): db_session.add(item) await db_session.commit() return item @app.get("/items/", response_model=List[Item]) async def read_items(db_session: AsyncSession = Depends(AsyncDBSession)): items = await db_session.execute(select(Item)) return items.scalars().all() ``` 在这个示例中我们首先安装好 `fastapi` 及相关依赖包 (`pip install fastapi uvicorn`) ，然后连接到 MySQL 数据库实例并通过 SQLModel 动态创建相应的表结构。最后实现了两个 RESTful 接口分别用于添加商品条目和获取全部记录列表的功能。 ---