登录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 close_connection(connection):
    if connection.is_connected():
        connection.close()
        print("MySQL连接已关闭")

# 示例：登录并执行简单查询
if __name__ == "__main__":
    conn = connect_to_mysql()
    if conn is not None:
        cursor = conn.cursor()
        cursor.execute("SELECT DATABASE();")  # 执行查询
        db_name = cursor.fetchone()  # 获取查询结果
        print(f"当前使用的数据库是: {db_name[0]}")
        close_connection(conn)

解释说明：

1. 导入模块：使用 mysql.connector 模块来连接 MySQL 数据库。
2. 连接函数：connect_to_mysql 函数用于创建与 MySQL 数据库的连接，需要提供主机地址、用户名、密码和数据库名称等参数。
3. 异常处理：如果连接失败，会捕获异常并打印错误信息。
4. 关闭连接：close_connection 函数用于关闭数据库连接，确保资源释放。
5. 示例代码：在主程序中，调用 connect_to_mysql 函数进行连接，并执行一个简单的查询来验证连接是否成功。最后关闭连接。

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