Python SQLAlchemy 宝典：数据存储和检索的终极指南

：

1. 建立与数据库的连接

要使用 SQLAlchemy 访问数据库，首先需要建立一个与数据库的连接。这可以通过调用 create_engine() 函数来完成。该函数接受一个包含数据库连接信息的字符串作为参数。例如，要连接到一个名为 my_database 的 PostgreSQL 数据库，可以使用以下代码：

from sqlalchemy import create_engine

engine = create_engine("postgresql://user:password@host:port/my_database")

2. 创建会话

连接到数据库后，就可以创建会话来执行数据库操作。会话是一个独立的、轻量级的对象，它维护着与数据库的连接，并允许你执行事务和查询。要创建会话，可以使用 sessionmaker() 函数，它返回一个会话工厂。然后，调用会话工厂的 __call__() 方法来创建一个会话。例如：

from sqlalchemy.orm import sessionmaker, Session

Session = sessionmaker(bind=engine)
session = Session()

3. 数据存储

要将数据存储在数据库中，可以使用 add() 方法将对象添加到会话中。然后，调用 commit() 方法将数据提交到数据库。例如：

from sqlalchemy import Column, Integer, String
from sqlalchemy.orm import declarative_base

Base = declarative_base()

class User(Base):
    __tablename__ = "users"

    id = Column(Integer, primary_key=True)
    name = Column(String)
    email = Column(String)

user = User(name="John Doe", email="johndoe@example.com")
session.add(user)
session.commit()

4. 数据检索

要从数据库中检索数据，可以使用 query() 方法。该方法返回一个查询对象，它允许你指定查询条件和排序方式。然后，调用查询对象的 all() 方法来获取所有结果。例如：

users = session.query(User).all()
for user in users:
    print(user.name, user.email)

5. 关系和外键

SQLAlchemy 支持关系和外键，允许你在不同的表之间建立关联。要定义关系，可以使用 relationship() 方法。该方法接受另一个表的类和一个外键作为参数。例如：

class Post(Base):
    __tablename__ = "posts"

    id = Column(Integer, primary_key=True)
    title = Column(String)
    body = Column(String)
    user_id = Column(Integer, ForeignKey("users.id"))

    user = relationship("User", back_populates="posts")

6. 事务

事务是一系列原子操作，要么全部成功，要么全部失败。要开始一个事务，可以使用 begin() 方法。然后，执行数据库操作。最后，调用 commit() 方法提交事务，或调用 rollback() 方法回滚事务。例如：

session.begin()
try:
    user = User(name="Jane Doe", email="janedoe@example.com")
    session.add(user)
    session.commit()
except:
    session.rollback()

7. 高级功能

SQLAlchemy 还提供许多高级功能，包括：

• 聚合函数
• 分组和排序
• 联合和子查询
• 视图和存储过程
• 数据迁移

有关这些功能的更多信息，请参阅 SQLAlchemy 文档。

总结

SQLAlchemy 是一个功能强大且灵活的 Python SQL 工具包，用于数据库连接、数据存储和检索，以及模式定义。它易于使用，并且适用于不同类型的数据库。在本文中，我们介绍了如何使用 SQLAlchemy 建立与数据库的连接，以及如何执行基本的数据存储和检索操作。有关更多信息，请参阅 SQLAlchemy 文档。