python3 mysql

import mysql.connector

# 连接到MySQL数据库
def connect_to_mysql():
    try:
        connection = mysql.connector.connect(
            host='localhost',  # 数据库主机地址
            user='your_username',  # 数据库用户名
            password='your_password',  # 数据库密码
            database='your_database'  # 数据库名称
        )
        if connection.is_connected():
            print("成功连接到MySQL数据库")
            return connection
    except mysql.connector.Error as err:
        print(f"连接失败: {err}")
        return None

# 插入数据到表中
def insert_data(connection, query, data):
    cursor = connection.cursor()
    try:
        cursor.execute(query, data)
        connection.commit()
        print("数据插入成功")
    except mysql.connector.Error as err:
        print(f"插入数据失败: {err}")
    finally:
        cursor.close()

# 查询数据
def query_data(connection, query):
    cursor = connection.cursor()
    try:
        cursor.execute(query)
        result = cursor.fetchall()
        for row in result:
            print(row)
    except mysql.connector.Error as err:
        print(f"查询数据失败: {err}")
    finally:
        cursor.close()

# 断开数据库连接
def close_connection(connection):
    if connection.is_connected():
        connection.close()
        print("数据库连接已关闭")

if __name__ == "__main__":
    conn = connect_to_mysql()
    if conn:
        # 示例：插入数据
        insert_query = "INSERT INTO employees (first_name, last_name, hire_date) VALUES (%s, %s, %s)"
        employee_data = ('John', 'Doe', '2023-10-01')
        insert_data(conn, insert_query, employee_data)

        # 示例：查询数据
        select_query = "SELECT * FROM employees"
        query_data(conn, select_query)

        # 关闭连接
        close_connection(conn)

解释说明：

1. 连接到MySQL数据库：使用mysql.connector.connect()方法连接到MySQL数据库，需要提供主机地址、用户名、密码和数据库名称。
2. 插入数据：定义了一个insert_data函数，用于执行SQL插入语句。cursor.execute()方法执行SQL命令，connection.commit()提交更改。
3. 查询数据：定义了一个query_data函数，用于执行SQL查询语句并打印结果。
4. 断开数据库连接：定义了一个close_connection函数，确保在操作完成后正确关闭数据库连接。

请根据实际情况修改host、user、password和database的值。