การสอบถามด้วยเซสชัน

เซสชัน

from sqlalchemy import create_engine
from sqlalchemy.orm import Session
engine = create_engine('sqlite:///:memory:')
with Session(engine) as session:
    print('Session open:', session)

การเพิ่มออบเจ็กต์

from sqlalchemy.orm import Session
# session.add(user) stages it
# session.commit() writes it
print('add stages, commit saves')

การยืนยันการเปลี่ยนแปลง

# with Session(engine) as session:
#     session.add(User(name='Alice'))
#     session.commit()
print('commit persists the work')

การเรียกดูข้อมูลด้วย select()

from sqlalchemy import select
# stmt = select(User)
# users = session.scalars(stmt).all()
print('select(User) then scalars().all()')

การดึงข้อมูลทุกแถว

from sqlalchemy import select
# all_users = session.scalars(select(User)).all()
# for u in all_users:
#     print(u.name)
print('all() returns a list of objects')

การกรองด้วย where()

from sqlalchemy import select
# stmt = select(User).where(User.age > 28)
# adults = session.scalars(stmt).all()
print('where(User.age > 28) filters rows')

การดึงออบเจ็กต์หนึ่งรายการ

from sqlalchemy import select
# stmt = select(User).where(User.name == 'Alice')
# user = session.scalars(stmt).first()
print('first() = first match or None')

การค้นหาด้วยคีย์หลัก

# user = session.get(User, 1)
# print(user.name)
print('session.get(Model, pk) fetches by id')

การจัดเรียงผลลัพธ์

from sqlalchemy import select
# stmt = select(User).order_by(User.age.desc())
# sorted_users = session.scalars(stmt).all()
print('order_by(User.age.desc()) sorts results')

การอัปเดตออบเจ็กต์

# user = session.get(User, 1)
# user.name = 'Alicia'
# session.commit()  # auto UPDATE
print('Edit attribute, then commit')

การลบออบเจ็กต์

# user = session.get(User, 1)
# session.delete(user)
# session.commit()  # row removed
print('delete(obj) then commit removes the row')

ตรวจสอบความเข้าใจ

สรุปทบทวน