在 Python 中使用连接池可以提高连接 MySQL 数据库的效率和性能。连接池可以在应用程序启动时创建一组数据库连接,这些连接可以被多个线程共享。当线程需要使用数据库连接时,可以从连接池中获取一个空闲连接,使用完成后再将连接释放回连接池,以便其他线程可以继续使用。
使用以下命令安装 mysql-connector-python:
pip install mysql-connector-python
如果你使用的是 Python3,请使用以下命令:
pip3 install mysql-connector-python
以下是使用 mysql-connector-python 库创建连接池的示例代码:
import mysql.connector.pooling
# 创建连接池
pool = mysql.connector.pooling.MySQLConnectionPool(
pool_name='mypool',
pool_size=5,
host='localhost',
user='username',
password='password',
database='database_name')
# 从连接池中获取连接
cnx = pool.get_connection()
# 创建游标对象
cursor = cnx.cursor()
# 执行 SQL 语句
query = "SELECT * FROM table_name"
cursor.execute(query)
# 处理结果
for row in cursor.fetchall():
print(row)
# 释放连接回连接池
cursor.close()
cnx.close()
在这个示例中,我们使用
mysql.connector.pooling.MySQLConnectionPool 类创建了一个连接池,指定了连接池的名称、大小和数据库连接信息。在需要使用数据库连接时,我们可以使用 pool.get_connection() 方法从连接池中获取一个空闲连接,然后创建游标对象并执行 SQL 语句。使用完成后,我们可以将连接释放回连接池,以便其他线程可以继续使用。