当前位置:首页python > 正文

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
野牛程序员教少儿编程与信息学竞赛-微信|电话:15892516892
相关推荐

最新推荐

热门点击