python操作mysql数据库

import mysql.connector

# 连接到MySQL数据库
def connect_to_db():
    try:
        connection = mysql.connector.connect(
            host='localhost',  # 数据库主机地址
            user='your_username',  # 数据库用户名
            password='your_password',  # 数据库密码
            database='your_database'  # 要连接的数据库名称
        )
        if connection.is_connected():
            print("成功连接到数据库")
        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 fetch_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__":
    # 创建数据库连接
    connection = connect_to_db()

    if connection:
        # 插入数据示例
        insert_query = "INSERT INTO employees (name, position, salary) VALUES (%s, %s, %s)"
        employee_data = ("John Doe", "Software Engineer", 80000)
        insert_data(connection, insert_query, employee_data)

        # 查询数据示例
        select_query = "SELECT * FROM employees"
        fetch_data(connection, select_query)

        # 关闭数据库连接
        close_connection(connection)

解释说明：

1. 连接到MySQL数据库：connect_to_db 函数用于建立与 MySQL 数据库的连接。你需要提供数据库的主机地址、用户名、密码和数据库名称。
2. 插入数据：insert_data 函数用于执行 SQL 插入操作。它接受一个连接对象、SQL 插入语句和要插入的数据。
3. 查询数据：fetch_data 函数用于执行 SQL 查询并打印结果。
4. 关闭连接：close_connection 函数用于关闭数据库连接，确保资源被正确释放。

请根据你的实际需求修改数据库连接参数（如主机地址、用户名、密码和数据库名称）以及 SQL 语句。