python执行mysql连接池封装增删改查方法
作者:野牛程序员:2023-12-22 13:18:50python阅读 2705
连接池封装增删改查的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
