首先安裝SQLAlchemy并使用SQLite創(chuàng)建數(shù)據(jù)庫連接；2. 定義User模型并映射到數(shù)據(jù)庫表；3. 初始化引擎和會話，創(chuàng)建數(shù)據(jù)表；4. 執(zhí)行增刪改查操作：添加用戶、查詢條件數(shù)據(jù)、更新字段、刪除記錄；5. 每次操作后必須調(diào)用commit()提交事務(wù)，最后關(guān)閉會話以釋放資源。

下面是一個實用的 Python SQLAlchemy 示例，涵蓋從安裝、定義模型、創(chuàng)建數(shù)據(jù)庫到增刪改查（CRUD）操作的完整流程。適合初學(xué)者快速上手。

? 1. 安裝 SQLAlchemy

pip install sqlalchemy

? 2. 創(chuàng)建數(shù)據(jù)庫連接和模型

我們使用 SQLite 作為示例數(shù)據(jù)庫（無需額外服務(wù)）。

from sqlalchemy import create_engine, Column, Integer, String
from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy.orm import sessionmaker

# 創(chuàng)建基類
Base = declarative_base()

# 定義 User 模型
class User(Base):
    __tablename__ = 'users'

    id = Column(Integer, primary_key=True)
    name = Column(String(50), nullable=False)
    age = Column(Integer)
    email = Column(String(100), unique=True)

    def __repr__(self):
        return f"<User(name='{self.name}', age={self.age}, email='{self.email}')>"

? 3. 初始化數(shù)據(jù)庫和會話

# 創(chuàng)建數(shù)據(jù)庫文件（sqlite:///users.db）
engine = create_engine('sqlite:///users.db', echo=True)  # echo=True 可查看 SQL 語句

# 創(chuàng)建表（如果不存在）
Base.metadata.create_all(engine)

# 創(chuàng)建會話
Session = sessionmaker(bind=engine)
session = Session()

echo=True 會打印出執(zhí)行的 SQL，方便調(diào)試。

? 4. 增刪改查（CRUD）操作

? 插入數(shù)據(jù)（Create）

# 添加單個用戶
new_user = User(name="Alice", age=30, email="alice@example.com")
session.add(new_user)
session.commit()

# 批量添加
users = [
    User(name="Bob", age=25, email="bob@example.com"),
    User(name="Charlie", age=35, email="charlie@example.com")
]
session.add_all(users)
session.commit()

? 查詢數(shù)據(jù)（Read）

# 查詢所有用戶
all_users = session.query(User).all()
for user in all_users:
    print(user)

# 條件查詢：查找名字為 Alice 的用戶
alice = session.query(User).filter_by(name="Alice").first()
print(alice)

# 使用 filter（支持更復(fù)雜條件）
adults = session.query(User).filter(User.age > 25).all()
for user in adults:
    print(user)

? 更新數(shù)據(jù)（Update）

# 更新 Alice 的年齡
alice = session.query(User).filter_by(name="Alice").first()
if alice:
    alice.age = 31
    session.commit()

或者更簡潔：

session.query(User).filter_by(name="Alice").update({"age": 31})
session.commit()

? 刪除數(shù)據(jù)（Delete）

# 刪除名字為 Charlie 的用戶
session.query(User).filter_by(name="Charlie").delete()
session.commit()

? 5. 關(guān)閉會話

session.close()

? 完整示例代碼（整合版）

from sqlalchemy import create_engine, Column, Integer, String
from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy.orm import sessionmaker

Base = declarative_base()

class User(Base):
    __tablename__ = 'users'
    id = Column(Integer, primary_key=True)
    name = Column(String(50), nullable=False)
    age = Column(Integer)
    email = Column(String(100), unique=True)

    def __repr__(self):
        return f"<User(name='{self.name}', age={self.age}, email='{self.email}')>"

# 初始化數(shù)據(jù)庫
engine = create_engine('sqlite:///users.db', echo=True)
Base.metadata.create_all(engine)

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

# CRUD 示例
if __name__ == "__main__":
    # 添加
    if session.query(User).count() == 0:  # 避免重復(fù)插入
        session.add_all([
            User(name="Alice", age=30, email="alice@example.com"),
            User(name="Bob", age=25, email="bob@example.com"),
        ])
        session.commit()

    # 查詢
    for user in session.query(User).all():
        print(user)

    # 更新
    session.query(User).filter_by(name="Alice").update({"age": 31})
    session.commit()

    # 刪除
    session.query(User).filter_by(name="Bob").delete()
    session.commit()

session.close()

? 小結(jié)

• SQLAlchemy 提供了清晰的 ORM 映射，讓 Python 類對應(yīng)數(shù)據(jù)庫表。
• 使用 session 管理事務(wù)，commit() 保存更改。
• 適合小型項目快速開發(fā)，也支持大型應(yīng)用的復(fù)雜查詢。

基本上就這些，不復(fù)雜但容易忽略 commit 和 session 管理。

以上是Python Sqlalchemy示例的詳細內(nèi)容。更多信息請關(guān)注PHP中文網(wǎng)其他相關(guān)文章！