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 数据库。
2. 创建连接：create_connection 函数用于创建与 MySQL 数据库的连接，需要提供主机地址、用户名、密码和数据库名称。如果连接成功，返回连接对象；否则返回 None。
3. 关闭连接：close_connection 函数用于关闭数据库连接，确保资源释放。
4. 查询数据：query_data 函数用于执行 SQL 查询并打印结果。
5. 主程序：在主程序中调用上述函数，完成连接、查询和关闭操作。

如果有任何问题或需要进一步的帮助，请随时告诉我！