mysql连接池 python 使用pymysql库

在Python中使用`pymysql`库和连接池是为了管理大量的数据库连接，避免频繁地创建和销毁连接，提高应用程序的效率。最常用的MySQL连接池工具是`SQLAlchemy`中的`pooling`功能，尽管也可以手动创建简单连接池。以下是使用`SQLAlchemy`连接池的基本步骤：

1. **安装依赖**：除了`pymysql`，还需要安装`sqlalchemy`和`pymysql_sa`（pymysql适配器）：

   pip install sqlalchemy pymysql-sa

2. **导入所需模块**：

   from sqlalchemy.pool import NullPool, QueuePool
   from sqlalchemy import create_engine

3. **配置连接池**：

   pool_size = 5  # 连接池大小
   max_overflow = 10  # 链接溢出最大数
   engine = create_engine('mysql+pymysql://username:password@host:port/database_name', poolclass=QueuePool, pool_size=pool_size, max_overflow=max_overflow)

使用`NullPool`表示无限制的连接池。

4. **从连接池获取连接**：

   with engine.connect() as connection:
       # 执行SQL操作
       result = connection.execute('YOUR SQL COMMAND')
       data = result.fetchall()

`with`语句会自动关闭连接。

5. **关闭连接池**：
- SQLAlchemy会自动在上下文结束后关闭连接，无需显式关闭。
- 如果你想手动关闭，调用`engine.dispose()`或`connection.close()`。