连接mysql数据库的代码

import mysql.connector

def connect_to_mysql():
    try:
        # 创建数据库连接
        connection = mysql.connector.connect(
            host="your_host",          # 数据库服务器地址
            user="your_username",      # 数据库用户名
            password="your_password",  # 数据库密码
            database="your_database"   # 要连接的数据库名称
        )
        
        if connection.is_connected():
            print("成功连接到MySQL数据库")
            
            # 获取游标对象
            cursor = connection.cursor()
            
            # 执行SQL查询
            cursor.execute("SELECT VERSION()")
            
            # 获取单条数据
            version = cursor.fetchone()
            print(f"数据库版本: {version[0]}")
            
            # 关闭游标和连接
            cursor.close()
            connection.close()
            print("数据库连接已关闭")
            
    except mysql.connector.Error as err:
        print(f"连接错误: {err}")

# 调用函数连接数据库
connect_to_mysql()