### 使用 Python FastAPI 和 SQLAlchemy 连接 MySQL 数据库构建 Web 应用程序 #### 安装必要的依赖包 为了使 FastAPI 能够通过 SQLAlchemy 访问 MySQL 数据库，需要安装几个重要的软件包。这包括 `fastapi` 本身、用于运行应用的 ASGI 服务器 `uvicorn`、对象关系映射器 `sqlalchemy` 及其驱动程序 `pymysql` 来建立到 MySQL 的连接[^2]。 ```bash pip install fastapi uvicorn sqlalchemy pymysql ``` #### 配置数据库连接字符串 在 FastAPI 中设置数据库连接涉及创建一个包含适当参数的 URL 字符串，该字符串指定了要使用的数据库类型（这里是 MySQL）、用户名、密码、主机地址和其他必要选项。此字符串随后被传递给 SQLAlchemy 的 `create_engine()` 函数来初始化引擎实例[^4]。 ```python from sqlalchemy import create_engine, MetaData from sqlalchemy.ext.declarative import declarative_base from sqlalchemy.orm import sessionmaker DATABASE_URL = "mysql+pymysql://username:password@localhost/dbname" engine = create_engine(DATABASE_URL) SessionLocal = sessionmaker(autocommit=False, autoflush=False, bind=engine) Base = declarative_base() metadata = MetaData(bind=engine) ``` #### 设计数据模型并定义表结构 利用 SQLAlchemy 提供的功能可以轻松地将 Python 类转换成 SQL 表格表示形式。每一个类代表一张表格；属性则对应于列。这种做法简化了对持久化实体的操作过程[^1]。 ```python from datetime import datetime from sqlalchemy import Column, Integer, String, DateTime class User(Base): __tablename__ = 'users' id = Column(Integer, primary_key=True, index=True) name = Column(String(50), nullable=False) email = Column(String(100), unique=True, nullable=False) created_at = Column(DateTime, default=datetime.utcnow) ``` #### 实现CRUD功能 一旦完成了上述准备工作之后就可以着手编写业务逻辑代码了——即增删改查等基本操作。下面展示了一个简单的例子说明怎样在一个路由处理器内部调用 Session 对象来进行查询工作[^3]。 ```python from fastapi import Depends, FastAPI, HTTPException from sqlalchemy.orm import Session app = FastAPI() def get_db(): db = SessionLocal() try: yield db finally: db.close() @app.get("/users/{user_id}") async def read_user(user_id: int, db: Session = Depends(get_db)): user = db.query(User).filter(User.id == user_id).first() if not user: raise HTTPException(status_code=404, detail="User not found") return {"id": user.id, "name": user.name, "email": user.email} ``` 以上就是使用 Python FastAPI 结合 SQLAlchemy ORM 工具与 MySQL 数据库交互的主要步骤概述。希望这些信息能帮助理解整个流程，并为实际项目的开发打下坚实的基础。