SQLAlchemy ORM构建四步闭环:定义模型(继承Base、Column声明字段)、配置连接(create_engine+sessionmaker)、创建表(Base.metadata.create_all)、CRUD操作(session增删改查并commit)。

用 SQLAlchemy 构建 ORM 系统不难,关键是把几个核心环节串清楚:定义模型、配置连接、创建表、操作数据。下面按实际开发顺序一步步说清楚。
定义数据模型(Model)
模型就是 Python 类,对应数据库里的表。每个类继承 db.Model(Flask-SQLAlchemy)或直接用 Base(原生 SQLAlchemy),字段用 Column 定义,类型选对很关键。
比如用户表:
from sqlalchemy import Column, Integer, String, Boolean from sqlalchemy.ext.declarative import declarative_base <p>Base = declarative_base()</p><p><span>立即学习</span>“<a href="https://pan.quark.cn/s/00968c3c2c15" style="text-decoration: underline !important; color: blue; font-weight: bolder;" rel="nofollow" target="_blank">Python免费学习笔记(深入)</a>”;</p><p>class User(Base): <strong>tablename</strong> = 'users' id = Column(Integer, primary_key=True) name = Column(String(50), nullable=False) email = Column(String(120), unique=True) is_active = Column(Boolean, default=True)
注意点:
- 主键必须明确声明,否则报错
- String 要带长度(如 String(50)),SQLite 可忽略但其他库会报错
- nullable=False 控制 NOT NULL,unique=True 对应唯一索引
- 外键和关系后面再加,先跑通基础结构
配置数据库连接与初始化
连接字符串格式是:dialect+driver://username:pass@host:port/database。本地开发常用 SQLite,简单省事:
from sqlalchemy import create_engine from sqlalchemy.orm import sessionmaker <p>engine = create_engine('sqlite:///app.db', echo=True) # echo=True 查看生成的 SQL SessionLocal = sessionmaker(autocommit=False, autoflush=False, bind=engine) session = SessionLocal()
常见情况:
- PostgreSQL:postgresql://user:pass@localhost:5432/mydb
- MySQL:+pymysql://user:pass@localhost:3306/mydb
- Windows 路径用正斜杠或双反斜杠,避免转义问题:’sqlite:///C:/my/app.db’
创建表(首次运行必做)
模型写好了,数据库里还没表。调用 Base.metadata.create_all(engine) 就能自动生成:
Base.metadata.create_all(engine)
这一步只建不存在的表,已有表不会被改动。开发中如果改了模型字段,不能靠它自动更新 —— 要么删库重来(调试期可用),要么用 alembic 做迁移。
使用模板与程序分离的方式构建,依靠专门设计的数据库操作类实现数据库存取,具有专有错误处理模块,通过 Email 实时报告数据库错误,除具有满足购物需要的全部功能外,成新商城购物系统还对购物系统体系做了丰富的扩展,全新设计的搜索功能,自定义成新商城购物系统代码功能代码已经全面优化,杜绝SQL注入漏洞前台测试用户名:admin密码:admin888后台管理员名:admin密码:admin888
0 小技巧:
- 加个判断,避免重复执行:
if not engine.dialect.has_table(engine.connect(), 'users'): - 测试时可临时用内存数据库:
create_engine('sqlite:///:memory:')
增删改查(CRUD)操作
所有操作都通过 完成,记得最后 commit() 或 rollback()。
插入一条:
new_user = User(name='张三', email='zhang@example.com') session.add(new_user) session.commit() # 实际写入
查询:
# 查全部 users = session.query(User).all() <h1>条件查询</h1><p>user = session.query(User).filter(User.email == 'zhang@example.com').first()</p><h1>模糊匹配</h1><p>users = session.query(User).filter(User.name.like('%张%')).all()
更新和删除:
# 更新 user = session.query(User).get(1) user.name = '李四' session.commit() <h1>删除</h1><p>session.delete(user) session.commit()
关键提醒:
- session.query(Model) 是起点,不是数据本身
- .first() 返回单条或 None;.one() 要求且仅有一条,否则报错
- 修改对象属性后必须 commit(),不然只是内存变更
- 查完不用 session.close(),用完归还连接池更稳妥(尤其 Web 应用)
基本上就这些。模型 → 连接 → 建表 → 操作,四步闭环。不复杂但容易忽略细节,比如没 commit、字段类型写错、SQLite 路径出问题。跑通一次,后面加字段、加表、加关联就顺了。
以上就是Python使用SQLAlchemy构建数据库ORM系统全流程【指导】的详细内容,更多请关注php中文网其它相关文章!
微信扫一扫打赏
支付宝扫一扫打赏
