python 连接mysql数据库

import mysql.connector

# 创建数据库连接
def create_connection():
    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 close_connection(connection):
    if connection.is_connected():
        connection.close()
        print("MySQL 数据库连接已关闭")

# 示例：查询数据
def query_data(connection):
    cursor = connection.cursor()
    cursor.execute("SELECT * FROM your_table")  # 替换为你的表名
    rows = cursor.fetchall()
    for row in rows:
        print(row)

# 主函数
if __name__ == "__main__":
    conn = create_connection()
    if conn:
        query_data(conn)
        close_connection(conn)

解释说明：

1. 导入模块：mysql.connector 是用于连接 MySQL 数据库的 Python 模块。
2. 创建连接：create_connection 函数尝试连接到 MySQL 数据库，并返回一个连接对象。如果连接成功，会打印一条成功消息；如果失败，则捕获异常并打印错误信息。
3. 关闭连接：close_connection 函数用于关闭数据库连接，确保资源释放。
4. 查询数据：query_data 函数执行 SQL 查询并打印结果。
5. 主函数：if __name__ == "__main__": 确保脚本作为主程序运行时，依次调用创建连接、查询数据和关闭连接的函数。

请根据实际情况修改 host、user、password、database 和表名等参数。