python执行mysql连接池封装增删改查方法
作者:野牛程序员:2023-12-22 13:18:50python阅读 2751
连接池封装增删改查的Python代码示例如下:
import pymysql
from pymysql import pool
class MySQLPool:
def __init__(self, host, user, password, database, pool_size=5):
self.host = host
self.user = user
self.password = password
self.database = database
self.pool_size = pool_size
self.connection_pool = self.create_connection_pool()
def create_connection_pool(self):
return pool.SimpleMySQLPool(
host=self.host,
user=self.user,
password=self.password,
database=self.database,
pool_size=self.pool_size
)
def execute_query(self, query, params=None):
connection = self.connection_pool.get_connection()
cursor = connection.cursor()
try:
cursor.execute(query, params)
result = cursor.fetchall()
return result
finally:
cursor.close()
connection.close()
def execute_update(self, query, params=None):
connection = self.connection_pool.get_connection()
cursor = connection.cursor()
try:
cursor.execute(query, params)
connection.commit()
finally:
cursor.close()
connection.close()
# 示例用法
mysql_pool = MySQLPool(host='your_host', user='your_user', password='your_password', database='your_database')
# 查询示例
query_result = mysql_pool.execute_query("SELECT * FROM your_table")
print(query_result)
# 更新示例
update_query = "UPDATE your_table SET column1=%s WHERE column2=%s"
update_params = ('new_value', 'condition_value')
mysql_pool.execute_update(update_query, update_params)
# 插入示例
insert_query = "INSERT INTO your_table (column1, column2) VALUES (%s, %s)"
insert_params = ('value1', 'value2')
mysql_pool.execute_update(insert_query, insert_params)
# 删除示例
delete_query = "DELETE FROM your_table WHERE column=%s"
delete_params = ('value_to_delete',)
mysql_pool.execute_update(delete_query, delete_params)请确保安装了相应的库,可以使用以下命令安装:
pip install pymysql
在上述代码中,将MySQL连接池的创建和查询、更新操作进行了封装,以便更方便地执行数据库操作。
野牛程序员教少儿编程与信息学奥赛-微信|电话:15892516892

