1. 安装 SQLAlchemy
SQLAlchemy 可以通过 pip 安装:
pip install sqlalchemy
2. 基本概念
2.1 引擎
引擎是 SQLAlchemy 中最重要的概念之一,它负责与数据库建立连接并执行 SQL 查询。创建引擎的代码如下:
from sqlalchemy import create_engine
engine = create_engine("sqlite:///database.db")
2.2 会话
会话是一个轻量级的对象,它负责管理数据库连接和事务。创建会话的代码如下:
from sqlalchemy.orm import sessionmaker
Session = sessionmaker(bind=engine)
session = Session()
2.3 模型
模型是 Python 类,它代表着数据库中的一个表。模型中的属性对应着表中的列。创建模型的代码如下:
from sqlalchemy.ext.declarative import declarative_base
Base = declarative_base()
class User(Base):
__tablename__ = "users"
id = Column(Integer, primary_key=True)
name = Column(String(50))
email = Column(String(50))
3. 基本操作
3.1 添加数据
向数据库中添加数据的代码如下:
user = User(name="John Doe", email="johndoe@example.com")
session.add(user)
session.commit()
3.2 查询数据
从数据库中查询数据的代码如下:
users = session.query(User).all()
for user in users:
print(user.name)
3.3 更新数据
更新数据库中数据的代码如下:
user = session.query(User).get(1)
user.name = "Jane Doe"
session.commit()
3.4 删除数据
从数据库中删除数据的代码如下:
user = session.query(User).get(1)
session.delete(user)
session.commit()
4. 常见问题
4.1 如何使用 SQLAlchemy 与其他数据库连接?
SQLAlchemy 支持多种数据库,包括 SQLite、MySQL、PostgreSQL 等。要使用 SQLAlchemy 与其他数据库连接,只需在创建引擎时指定相应的数据库 URL 即可。例如:
engine = create_engine("mysql+pymysql://user:password@host/database")
4.2 如何使用 SQLAlchemy 执行原生 SQL 查询?
可以使用 session.execute()
方法执行原生 SQL 查询。例如:
result = session.execute("SELECT * FROM users")
for row in result:
print(row)
4.3 如何使用 SQLAlchemy 进行事务处理?
可以使用 session.begin()
和 session.commit()
方法进行事务处理。例如:
session.begin()
try:
user = User(name="John Doe", email="johndoe@example.com")
session.add(user)
session.commit()
except Exception as e:
session.rollback()
5. 总结
SQLAlchemy 是一个强大的 ORM 工具包,可以轻松地将 Python 对象与数据库表进行映射,从而实现数据持久化。本教程介绍了 SQLAlchemy 的基本概念和用法,帮助您快速入门。