【Python 】一篇吃透Python SQLAlchemy！零基础入门+实战案例+流程图（超全详解）

一篇吃透Python SQLAlchemy零基础入门实战案例流程图超全详解✨前言在Python后端开发中操作数据库几乎是刚需原生SQL语句手写繁琐、可读性差、容易出现注入漏洞而SQLAlchemy作为Python最主流的ORM框架完美解决了这些问题 本文将从零开始带大家全方位掌握SQLAlchemy核心用法包含环境搭建、核心原理、数据库连接、模型定义、增删改查、关联关系全程附可直接运行的代码案例流程图新手也能一键看懂读完本文你可以彻底摆脱原生SQL硬编码优雅实现Python数据库操作一、SQLAlchemy 是什么1.1 ORM 概念ORM对象关系映射将数据库中的数据表、行数据与Python中的类、对象做自动映射无需手写原生SQL通过操作Python对象即可操作数据库。映射关系Python 类 ➡️ 数据库数据表类属性 ➡️ 数据表字段类实例对象 ➡️ 数据表一行数据1.2 SQLAlchemy 优势✅ 跨数据库兼容一套代码可适配MySQL、PostgreSQL、SQLite等无需大幅修改✅ 杜绝SQL注入底层自动参数化处理安全性更高✅ 代码简洁优雅面向对象编程可读性、可维护性极强✅ 功能强大支持事务、关联查询、复杂筛选、分页等高级操作1.3 整体工作流程映射建立连接Session提交事务处理定义ORM模型类数据库表结构创建会话Session数据库操作Python对象执行数据库增删改查数据持久化到数据库二、环境安装️安装核心依赖支持Python3.7版本# 安装sqlalchemy核心库pip install sqlalchemy# 若使用MySQL需额外安装驱动pip install pymysql三、核心组件详解SQLAlchemy 四大核心组件必须掌握Engine引擎数据库连接核心负责建立和数据库的连接Base基类所有ORM模型类的父类用于统一映射表结构Session会话数据库操作核心所有增删改查都通过会话完成Column/字段类型定义数据表字段、约束、类型四、完整入门案例SQLite先使用无需安装服务的SQLite数据库快速上手零门槛运行4.1 基础初始化引擎、基类、会话fromsqlalchemyimportcreate_enginefromsqlalchemy.ext.declarativeimportdeclarative_basefromsqlalchemy.ormimportsessionmaker# 1. 创建数据库引擎SQLite本地文件数据库enginecreate_engine(sqlite:///test.db,echoTrue)# echoTrue 打印执行的SQL语句方便调试# 2. 创建ORM基类Basedeclarative_base()# 3. 创建会话工厂绑定引擎SessionLocalsessionmaker(autocommitFalse,autoflushFalse,bindengine)# 4. 获取会话实例dbSessionLocal()4.2 定义数据模型创建数据表自定义用户模型类映射user数据表fromsqlalchemyimportColumn,Integer,String,DateTimefromdatetimeimportdatetime# 自定义用户模型classUser(Base):# 数据表名称__tablename__user# 定义字段idColumn(Integer,primary_keyTrue,autoincrementTrue,comment主键ID)usernameColumn(String(30),nullableFalse,uniqueTrue,comment用户名)ageColumn(Integer,nullableTrue,comment年龄)emailColumn(String(50),uniqueTrue,comment邮箱)create_timeColumn(DateTime,defaultdatetime.now,comment创建时间)# 批量创建所有数据表执行映射Base.metadata.create_all(bindengine)print(数据表创建成功)字段核心参数说明primary_keyTrue主键autoincrementTrue自增nullableFalse非空约束uniqueTrue唯一约束default默认值五、核心增删改查实战基于上面的User模型实现全套数据库CRUD操作代码可直接运行5.1 新增数据Create# 单条新增user1User(username张三,age20,emailzhangsan163.com)db.add(user1)# 批量新增user_list[User(username李四,age22,emaillisi163.com),User(username王五,age25,emailwangwu163.com)]db.add_all(user_list)# 提交事务必须提交数据才会写入数据库db.commit()print(数据新增成功)5.2 查询数据Read【最常用】支持全量查询、条件查询、模糊查询、分页、排序等操作# 1. 查询所有数据all_usersdb.query(User).all()foruserinall_users:print(fID:{user.id}, 用户名:{user.username}, 年龄:{user.age})# 2. 根据主键查询单条数据userdb.query(User).get(1)print(主键查询结果,user.usernameifuserelse无数据)# 3. 条件查询精准匹配userdb.query(User).filter(User.username张三).first()print(条件查询,user.age)# 4. 多条件查询userdb.query(User).filter(User.age22,User.email.like(%163.com)).first()# 5. 模糊查询usersdb.query(User).filter(User.username.like(%五%)).all()# 6. 排序查询倒序usersdb.query(User).order_by(User.age.desc()).all()# 7. 分页查询page页码limit每页条数page_usersdb.query(User).limit(2).offset(0).all()5.3 修改数据Update修改数据需先查询、再赋值、最后提交# 方式1单条数据修改userdb.query(User).get(1)ifuser:user.age21# 修改字段值user.emailzhangsan_new163.comdb.commit()print(数据修改成功)# 方式2批量条件修改db.query(User).filter(User.age22).update({age:23})db.commit()5.4 删除数据Delete# 方式1删除单条数据userdb.query(User).get(3)ifuser:db.delete(user)db.commit()# 方式2批量条件删除db.query(User).filter(User.username李四).delete()db.commit()print(数据删除成功)六、MySQL 数据库适配上面案例是SQLite切换MySQL仅需修改引擎连接地址其余代码完全不用改完美体现跨库优势# MySQL连接格式mysqlpymysql://账号:密码主机:端口/数据库名enginecreate_engine(mysqlpymysql://root:123456localhost:3306/test_db,echoTrue,pool_pre_pingTrue,# 自动检测连接有效性pool_recycle3600# 连接回收时间)⚠️ 注意使用MySQL需提前手动创建好数据库test_db无需创建数据表代码自动生成七、事务处理机制✅数据库事务是开发核心SQLAlchemy默认开启事务出错需回滚避免数据异常try:# 执行数据库操作userUser(username小明,age18)db.add(user)# 模拟报错1/0db.commit()exceptExceptionase:# 异常回滚撤销所有操作db.rollback()print(f操作失败事务回滚{e})finally:# 关闭会话db.close()八、一对多关联查询实战实际开发中常用表关联这里演示最经典的用户-文章一对多关系一个用户对应多篇文章8.1 定义关联模型fromsqlalchemy.ormimportrelationship,ForeignKey# 用户表主表classUser(Base):__tablename__useridColumn(Integer,primary_keyTrue,autoincrementTrue)usernameColumn(String(30),nullableFalse)# 关联文章表反向查询articlesrelationship(Article,back_populatesauthor)# 文章表从表classArticle(Base):__tablename__articleidColumn(Integer,primary_keyTrue,autoincrementTrue)titleColumn(String(100),nullableFalse,comment文章标题)contentColumn(String(500),comment文章内容)# 外键关联用户表user_idColumn(Integer,ForeignKey(user.id),comment用户ID)# 关联用户表authorrelationship(User,back_populatesarticles)# 创建表Base.metadata.create_all(bindengine)8.2 关联数据查询# 查询用户对应的所有文章userdb.query(User).first()print(f用户【{user.username}】的所有文章)forarticleinuser.articles:print(f文章标题{article.title})# 查询文章对应的作者articledb.query(Article).first()print(f文章作者{article.author.username})8.3 关联关系流程图一对多关联反向查询所有文章正向查询所属用户User表 主表Article表 从表user.id 主键article.user_id 外键User.articlesArticle.author九、常用踩坑总结⚠️新增/修改/删除数据后必须执行commit()数据才会持久化代码报错务必执行rollback()回滚事务避免锁表MySQL连接失败优先检查账号密码、端口、数据库是否存在、是否开启远程连接字段默认值不生效时检查是否设置default且已提交事务关联查询报错优先检查relationship和外键是否匹配十、总结本文全覆盖讲解了SQLAlchemy核心知识点掌握ORM核心映射原理、四大核心组件熟练实现 SQLite/MySQL 数据库连接、模型定义精通全套增删改查、条件筛选、分页排序操作掌握事务处理、一对多表关联高级用法SQLAlchemy是Python后端FastAPI/Flask/Django必备技能熟练使用可以极大提升开发效率告别繁琐原生SQL后续更新SQLAlchemy多对多关联、原生SQL混合查询、批量操作、异步用法