如何使用Python和SQLAlchemy实现对MySQL数据库的ORM操作？-Python教程-PHP中文网

sqlalchemy 2.0+ 推荐使用 declarativebase + mapped 类型注解定义模型，配合 select() 和 session 进行 crud；需显式指定 __tablename__、字段长度及 nullable，连接 mysql 必须用 mysql+pymysql:// 协议并安装 pymysql，base.metadata.create_all() 不修改已有表结构，所有操作须 commit() 才生效。

如何使用python和sqlalchemy实现对mysql数据库的orm操作？

直接上结论：SQLAlchemy 2.0+ 的 declarative_base() + Session + select() 是当前最稳妥的 ORM 写法，旧版 session.query(Model).filter(...) 已弃用，硬用会报 AttributeError: 'Session' object has no attribute 'query'。

怎么定义模型并映射到 MySQL 表

别再手动写 __table__ 或一堆 Column(...) 参数堆砌。用现代声明式风格，配合 Mapped 类型注解，让 IDE 和类型检查器能真正起作用：

from sqlalchemy import String, Integer, create_engine
from sqlalchemy.orm import DeclarativeBase, Mapped, mapped_column, Session
<p>class Base(DeclarativeBase):
pass</p><p>class User(Base):
<strong>tablename</strong> = "users"
id: Mapped[int] = mapped_column(Integer, primary_key=True)
name: Mapped[str] = mapped_column(String(50))
email: Mapped[str] = mapped_column(String(100), unique=True)</p>

注意点：

__tablename__ 必须显式指定，不设会默认用类名小写（user），但多数 MySQL 表名是复数或带下划线，比如 user_profiles
String(50) 中的长度必须写，MySQL 不支持无长度的 VARCHAR；若字段允许 NULL，加 nullable=True（默认是 False）
别在模型里写 __init__ —— SQLAlchemy 会自动处理实例化，手写容易破坏 ORM 的属性跟踪逻辑

如何连接 MySQL 并创建表

连接字符串格式错一个字符就报 ModuleNotFoundError: No module named 'mysql' 或 sqlalchemy.exc.NoSuchModuleError：

engine = create_engine(
    "mysql+pymysql://root:password@127.0.0.1:3306/testdb",
    echo=True,  # 开启后 SQL 语句会打印到 stdout，调试必备
)

关键细节：

Python 3.14.2

Python 3.14.2是Python编程语言在2025年12月5日发布的稳定版本，属于3.14系列的第二个维护更新。该版本包含了18项修复，重点解决了多进程、数据类及正则表达式等模块的回归问题，并修复了CVE-2025-12084等安全漏洞。此版本标志着自由线程模式（移除GIL）正式获得官方支持，是Python发展的重要里程碑。

下载

必须安装对应驱动：pymysql（纯 Python，推荐）或 mysqlclient（C 扩展，稍快但编译麻烦）；只装 sqlalchemy 不行
协议前缀必须是 mysql+pymysql，不是 mysql:// 或 mysql://pymysql —— 后者会直接报错
Base.metadata.create_all(engine) 只建不存在的表，不会修改已有表结构；改字段要靠 Alembic，别指望它自动 ALTER

怎么查、增、删、改数据（用 2.0+ 新语法）

所有操作都走 Session，不再用 session.query(User).filter(...)。这是最容易踩坑的地方：

with Session(engine) as session:
    # 查询：用 select() 构造语句，然后 execute().scalars().all()
    stmt = select(User).where(User.name == "Alice")
    users = session.execute(stmt).scalars().all()
<pre class="brush:python;toolbar:false;"># 插入：add() 后必须 commit()
new_user = User(name="Bob", email="bob@example.com")
session.add(new_user)
session.commit()  # 不调这个，数据不会进库

# 更新：查出来改属性，再 commit
user = session.get(User, 1)
if user:
    user.email = "new@example.com"
    session.commit()

# 删除：delete() 接对象，不是 ID
session.delete(user)
session.commit()

特别注意：

session.get(Model, id) 是按主键查的快捷方式，比 select().where() 更高效，且返回 None 而非空列表
session.execute(select(...)).scalars().first() 返回单个值（如 count(*) 结果），.scalars().all() 返回对象列表
没 session.commit() 就等于没操作；session.rollback() 可撤回未提交的变更

为什么有时候查询返回空，但数据库明明有数据

大概率是事务隔离或自动刷新问题，不是代码写错了：

用了 autocommit=False（默认），又没调 commit() 或 flush()，新插入的数据在当前 session 看不到
MySQL 默认隔离级别是 REPEATABLE READ，另一个连接刚插入的数据，当前 session 在事务内查不到，除非 session.expire_all() 或新开 session
字段名写错大小写：MySQL 在 Linux 下表名和字段名默认区分大小写，user.Name 和 user.name 是两个东西
select(User) 查的是整行，如果只想要某个字段（比如 name），得写 select(User.name)，否则 .scalars() 会失败