c mysql连接类

import mysql.connector

class MySQLConnector:
    def __init__(self, host, user, password, database):
        self.host = host
        self.user = user
        self.password = password
        self.database = database
        self.connection = None

    def connect(self):
        try:
            self.connection = mysql.connector.connect(
                host=self.host,
                user=self.user,
                password=self.password,
                database=self.database
            )
            print("Connected to MySQL database successfully!")
        except mysql.connector.Error as err:
            print(f"Error connecting to MySQL database: {err}")

    def execute_query(self, query):
        if not self.connection:
            print("Not connected to MySQL database!")
            return

        cursor = self.connection.cursor()
        try:
            cursor.execute(query)
            result = cursor.fetchall()
            return result
        except mysql.connector.Error as err:
            print(f"Error executing query: {err}")
        finally:
            cursor.close()

# 使用示例
connector = MySQLConnector('localhost', 'root', 'password', 'testdb')
connector.connect()
result = connector.execute_query('SELECT * FROM users')
print(result)