}

团队最近在技术选型时对比了多个方案，这里分享一下我们的调研结果和最终决策依据。

atom-one-dark"

id="content_views">

SQLAlchemy是Python中最流行的ORM（对象关系映射）框架之一，它提供了高效且灵活的数据库操作方式。

本文将介绍如何使用SQLAlchemy

目录

1. 安装SQLAlchemy

2. 核心概念

安装

bash

(Python标准库已包含，无需额外安装)

核心概念

• Engine：数据库连接的引擎，负责与数据库通信

• Session：数据库会话，管理所有持久化操作

• Model：数据模型类，对应数据库中的表

• Query：查询对象，用于构建和执行数据库查询

连接数据库

python

create_engine('sqlite:///example.db',

echo=True)#

create_engine('postgresql://username:password@localhost:5432/mydatabase')#

MySQL示例

create_engine('mysql+mysqlconnector://username:password@localhost:3306/mydatabase')#

创建会话工厂

Base.metadata.create_all(bind=engine)#

删除所有表

Base.metadata.drop_all(bind=engine)

基本CRUD操作

创建数据

python

session.add_all([User(name="李四",

email="lisi@example.com"),User(name="王五",

最佳实践：

经过多个项目的验证，我总结了几个关键点：1)

做好异常处理

这些看似简单，但能避免很多生产环境问题。

session.query(User).get(1)

session.query(User).filter(User.name.like("张%")).update({"name":

"张氏"},

session.query(User).filter(User.name

"李四").delete(synchronize_session=False)

查询数据

基本查询

python

session.query(User.name).all()#

users

session.query(User).order_by(User.name.desc()).all()#

限制结果数量

session.query(User).limit(10).all()#

偏移量

session.query(User).offset(5).limit(10).all()

session.query(User).filter(User.name

"张三").first()#

session.query(User).filter(User.name.like("张%")).all()#

IN查询

session.query(User).filter(User.name.in_(["张三",

"李四"])).all()#

session.query(User).filter(User.name

"张三",

User.email.like("%@example.com")

).all()#

session.query(User).filter(or_(User.name

"张三",

session.query(User).filter(User.name

).join(Post).group_by(User.name).all()#

求和、平均值等

session.query(func.avg(User.id)).scalar()

Post).join(Post).filter(Post.title.like("%Python%")).all()#

左外连接

Post.author_id).all()

Tag(name="SQLAlchemy")post.tags.append(python_tag)

post.tags.append(sqlalchemy_tag)

'{post.title}'

email="test@example.com")session.add(user)session.commit()

except

e:session.rollback()print(f"发生错误:

{e}")#

email=email)session.add(user)session.commit()return

userexcept:session.rollback()raise#

嵌套事务

email="transaction@example.com")session.add(user)#

保存点

email="savepoint@example.com")session.add(user)savepoint.commit()

except:savepoint.rollback()

最佳实践

1. 会话管理：为每个请求创建新会话，请求结束后关闭

2. 异常处理：始终处理异常并适当回滚事务

3. 延迟加载：注意N+1查询问题，使用

   eager

4. 连接池：合理配置连接池大小和超时设置

5. 数据验证：在模型层或应用层验证数据完整性

   Exception:db.rollback()raisefinally:db.close()#

   使用示例

   email="context@example.com")db.add(user)

   ORM提供了强大而灵活的数据库操作方式，通过本文的介绍，您应该能够：

SQLAlchemy还有更多高级特性，如混合属性、事件监听、自定义查询等，值得进一步探索学习。