### 如何在Python中连接MySQL数据库 要在Python中连接到MySQL数据库，可以使用`pymysql`或`mysql-connector-python`库。以下是基于这些库的实现方式。 #### 使用 `PyMySQL` 库连接 MySQL 数据库 `PyMySQL` 是一个纯 Python 实现的 MySQL 客户端库。它允许开发者通过标准接口与 MySQL 数据库交互[^1]。 ```python import pymysql def connect_to_mysql(): try: connection = pymysql.connect( host='localhost', user='your_username', password='your_password', db='your_database_name', charset='utf8mb4', cursorclass=pymysql.cursors.DictCursor ) print("Connection successful!") return connection except Exception as e: print(f"Error connecting to the database: {e}") return None ``` 上述代码展示了如何创建一个函数来尝试连接到指定的 MySQL 数据库。如果成功，则返回连接对象；否则打印错误消息并返回 `None`[^3]。 #### 使用 `mysql-connector-python` 连接 MySQL 数据库 另一种常用的方法是利用官方支持的驱动程序——`mysql-connector-python`[^5]。 ```python import mysql.connector def establish_connection(): try: cnx = mysql.connector.connect( user='your_username', password='your_password', host='127.0.0.1', database='your_database' ) if cnx.is_connected(): print("Database connection established.") return cnx except mysql.connector.Error as err: print(f"Something went wrong while trying to connect: {err}") return None ``` 此部分说明了另一个用于建立 MySQL 数据库连接的技术路径，并提供了异常处理机制以捕获潜在问题[^4]。 #### 处理事务管理 无论采用哪种方法，在完成数据修改之后都需要调用 `.commit()` 方法提交更改或将未保存的工作丢弃掉（即回滚）。这一步骤至关重要，因为只有这样才会使所做的变更永久化存储于数据库之中。 ```python cursor = connection.cursor() try: sql_query = "INSERT INTO table_name (column1, column2) VALUES (%s, %s)" values = ("value1", "value2") cursor.execute(sql_query, values) connection.commit() # Commit transaction after execution. except Exception as ex: connection.rollback() # Rollback on failure. finally: cursor.close() connection.close() ``` 以上片段演示了如何安全地执行 SQL 查询以及适当地关闭资源释放占用.