python 封装mysql

import mysql.connector

class MySQLDB:
    def __init__(self, host, user, password, database):
        self.connection = mysql.connector.connect(
            host=host,
            user=user,
            password=password,
            database=database
        )
        self.cursor = self.connection.cursor()

    def execute_query(self, query, params=None):
        if params:
            self.cursor.execute(query, params)
        else:
            self.cursor.execute(query)
        self.connection.commit()
        return self.cursor.fetchall()

    def close(self):
        self.cursor.close()
        self.connection.close()

# 使用示例
db = MySQLDB(host='localhost', user='root', password='password', database='testdb')
result = db.execute_query("SELECT * FROM users WHERE age > %s", (25,))
print(result)
db.close()