SQLAlchemy链接池的使用

1、倒入需要的模块

from sqlalchemy import create_engine
from sqlalchemy.orm import sessionmaker
from sqlalchemy.pool import QueuePool

2、创建数据库连接引擎（engine），并指定连接池的类型（这里使用QueuePool）：

engine = create_engine('mysql://username:password@hostname/database', poolclass=QueuePool)

3、创建一个Session类，并指定连接池的引擎：

Session = sessionmaker(bind=engine)

4、创建Session对象，并使用with语句块来管理它的生命周期

with Session() as session:
    # 这里可以执行数据库操作
    result = session.query(User).filter(User.name=='john').first()

上边的代码中，Session对象会从连接池中获取一个数据库连接，执行完成后会将该连接释放回池中。

另外，你可以通过设置连接池的参数来调整连接池的行为，例如设置连接池的大小、超时时间等等。以下是一个示例

engine = create_engine('mysql://username:password@hostname/database',
                       poolclass=QueuePool,
                       pool_size=5,
                       pool_timeout=30,
                       pool_recycle=3600)

在上面的代码中，连接池的大小为5，连接超时时间为30秒，连接重置时间为3600秒。