创建 Engine, 连接数据库。
from sqlalchemy import create_engine
dbInfo = "mysql+pymysql://<username>:<password>@127.0.0.1:3306/<database>"
__engine = create_engine(dbInfo,
echo=False, # 是否打印debug日志信息。
max_overflow=5, # 超过连接池大小外最多创建的连接
pool_size=20, # 连接池大小
pool_timeout=30, # 池中没有线程最多等待的时间，否则报错
# pool_recycle=-1, # 多久之后对线程池中的线程进行一次连接的回收（重置）
isolation_level="READ UNCOMMITTED", # 取消缓存.
)
创建Session
from sqlalchemy.orm import sessionmaker, scoped_session
sessionDB = sessionmaker(bind=__engine) # 非线程安全.
sessionDB = scoped_session(sessionmaker(bind=__engine)) # 线程安全.
session使用
session = sessionDB() # 实例化。
session.add()
session.commit()
session.rollback()
session.close()
2021-04-30 其他的使用到再更新...
