采集器 mysql

import mysql.connector

def fetch_data(host, user, password, database, query):
    try:
        connection = mysql.connector.connect(host=host,
                                             user=user,
                                             password=password,
                                             database=database)
        cursor = connection.cursor(dictionary=True)
        cursor.execute(query)
        result = cursor.fetchall()
        return result
    except mysql.connector.Error as err:
        print(f"Error: {err}")
    finally:
        if connection.is_connected():
            cursor.close()
            connection.close()

# 使用示例
data = fetch_data('localhost', 'root', 'password', 'mydatabase', 'SELECT * FROM mytable')
for row in data:
    print(row)