:
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 文档。