這篇文章主要跟大家介紹了關於Python MySQL資料庫連接池元件pymysqlpool的相關資料，文中透過範例程式碼介紹的非常詳細，對大家具有一定的參考學習價值，需要的朋友們下面來一起看看吧。
引言
pymysqlpool （本地下載）是資料庫工具包中新成員，目的是能提供一個實用的資料庫連接池中間件，從而避免在應用中頻繁地建立和釋放資料庫連接資源。
功能
連線池本身是線程安全的，可在多線程環境下使用，不必擔心連接資源被多個線程共享的問題；
提供盡可能緊湊的接口用於數據庫操作；
連接池的管理位於套件內完成，用戶端可以透過介面取得池中的連線資源（傳回###pymysql.Connection）；
基本工作流程
|--------| |--------------| | | <==borrow connection object== | Pool manager | | Client | | | | | ==return connection object==> | FIFO queue | |--------| |--------------|
#參數配置
單例模式
;字元集
，預設為'utf8'##auto_resize_scale: 自動擴充max_pool_size 的增益，預設為1.5 倍擴充；
kwargs: 其他設定參數將會在建立連線物件時傳遞給
from pymysqlpool import ConnectionPool
config = {
'pool_name': 'test',
'host': 'localhost',
'port': 3306,
'user': 'root',
'password': 'root',
'database': 'test'
}
def connection_pool():
# Return a connection pool instance
pool = ConnectionPool(**config)
pool.connect()
return pool
# 直接访问并获取一个 cursor 对象，自动 commit 模式会在这种方式下启用
with connection_pool().cursor() as cursor:
print('Truncate table user')
cursor.execute('TRUNCATE user')
print('Insert one record')
result = cursor.execute('INSERT INTO user (name, age) VALUES (%s, %s)', ('Jerry', 20))
print(result, cursor.lastrowid)
print('Insert multiple records')
users = [(name, age) for name in ['Jacky', 'Mary', 'Micheal'] for age in range(10, 15)]
result = cursor.executemany('INSERT INTO user (name, age) VALUES (%s, %s)', users)
print(result)
print('View items in table user')
cursor.execute('SELECT * FROM user')
for user in cursor:
print(user)
print('Update the name of one user in the table')
cursor.execute('UPDATE user SET name="Chris", age=29 WHERE id = 16')
cursor.execute('SELECT * FROM user ORDER BY id DESC LIMIT 1')
print(cursor.fetchone())
print('Delete the last record')
cursor.execute('DELETE FROM user WHERE id = 16')import pandas as pd
from pymysqlpool import ConnectionPool
config = {
'pool_name': 'test',
'host': 'localhost',
'port': 3306,
'user': 'root',
'password': 'root',
'database': 'test'
}
def connection_pool():
# Return a connection pool instance
pool = ConnectionPool(**config)
pool.connect()
return pool
with connection_pool().connection() as conn:
pd.read_sql('SELECT * FROM user', conn)
# 或者
connection = connection_pool().borrow_connection()
pd.read_sql('SELECT * FROM user', conn)
connection_pool().return_connection(connection)以上是Python MySQL資料庫中pymysqlpool是如何使用的？的詳細內容。更多資訊請關注PHP中文網其他相關文章！
