一、連接數據

from sqlalchemy import create_engine
from sqlalchemy.orm import sessionmaker# 1. 連接數據庫
dbHost = 'postgres://用戶名:密碼@主機:端口/數據庫名'
engine = create_engine(dbHost)
# create_engine() 參數說明：
# a. dbHost, # 數據庫連接信息
# b. echo=False,  # 是否打印SQL
# c. pool_size=10,  # 連接池的大小，指定同時在連接池中保持的數據庫連接數，默認:5
# d. max_overflow=20,  # 超出連接池大小的連接數，超過這個數量的連接將被丟棄,默認: 5# 2. 創建會話
Session = sessionmaker(bind=engine)
session = Session()

二、模型

from sqlalchemy import Column, String, TIMESTAMP
from sqlalchemy.dialects.postgresql import INTEGER, TEXT, VARCHAR
from sqlalchemy.ext.declarative import declarative_base# 模型父類
Base = declarative_base()
class User(Base):__tablename__ = 'auth_user'id = Column(INTEGER, primary_key=True)active = Column(INTEGER)name = Column(TEXT)class Size(Base):__tablename__ = 'master_size'id = Column(INTEGER, primary_key=True)active = Column(INTEGER)size = Column(TEXT)user_id = Column(INTEGER)

三、ORM操作

from sqlalchemy import func# 1. 查詢
# func.lower(User.name)  轉換為小寫
user_objs = session.query(User).filter(func.lower(User.name) == 'jack', User.active == 0)
user_obj = session.query(User).get(5)   # 獲取id=5
user_obj = session.query(User).get({"id": 5, "active": 0}) # 獲取id=5 and active=0# 2. 添加 
# 添加User
user_obj = User(name='張三'， active=0)
session.add(user_obj)   # 添加
session.commit()   # 提交
# 添加Size
size_obj = Size(size='XXL'， active=0, user_id=user_obj.id)
session.add(size_obj)   # 添加
session.commit()   # 提交# 3. 刪除
user_objs = session.query(User).filter(func.lower(User.name) == 'jack', User.active == 0)
session.delete(user_objs)
session.commit()# 修改
user_obj = session.query(User).get({"id": 5, "active": 0})
user_obj.name = '李四'
session.commit()