### Python 连接 MySQL 数据库的方法和示例代码 Python 连接 MySQL 数据库通常依赖于第三方库 `PyMySQL` 或 `mysqlclient`（即 `MySQLdb` 的 Python 3.x 版本）。其中，`PyMySQL` 是一个纯 Python 实现的 MySQL 客户端库，兼容性好且易于使用，是推荐的选择。 #### 安装依赖库 在使用 Python 连接 MySQL 数据库之前，需要先安装相应的驱动库。对于 `PyMySQL`，可以通过以下命令安装： ```bash pip install PyMySQL ``` #### 连接数据库的基本步骤 1. **导入模块** 在 Python 脚本中导入 `pymysql` 模块。 2. **建立连接** 使用 `pymysql.connect()` 函数建立与 MySQL 数据库的连接。需要提供主机名、端口号、用户名、密码以及数据库名称等参数。 3. **创建游标对象** 使用连接对象的 `.cursor()` 方法创建游标对象，用于执行 SQL 语句。 4. **执行 SQL 语句** 使用游标对象的 `.execute()` 方法执行 SQL 查询或更新操作。 5. **获取查询结果** 使用 `.fetchone()`、`.fetchall()` 或 `.fetchmany(n)` 方法获取查询结果。 6. **关闭连接** 操作完成后，关闭游标和数据库连接以释放资源。 #### 示例代码 以下是一个完整的 Python 连接 MySQL 数据库并执行查询的示例： ```python import pymysql # 建立数据库连接 try: connection = pymysql.connect( host='localhost', port=3306, user='root', password='your_password', database='your_database', charset='utf8mb4' ) print("数据库连接成功") # 创建游标对象 with connection.cursor() as cursor: # 执行SQL查询 cursor.execute("SELECT VERSION()") # 获取单条数据 version = cursor.fetchone() print(f"Database version: {version[0]}") # 执行查询获取所有数据库 cursor.execute("SHOW DATABASES") databases = cursor.fetchall() print("Available databases:") for db in databases: print(db[0]) except pymysql.Error as e: print(f"数据库连接失败: {e}") finally: # 关闭数据库连接 if 'connection' in locals() and connection.open: connection.close() print("数据库连接已关闭") ``` #### 事务处理与错误处理 在执行数据修改操作（如插入、更新、删除）时，应使用事务来确保数据一致性。可以通过 `connection.begin()` 启动事务，并在操作完成后调用 `connection.commit()` 提交事务；若发生异常，则调用 `connection.rollback()` 回滚。 ```python try: with connection.cursor() as cursor: # 插入数据 sql = "INSERT INTO users (name, email) VALUES (%s, %s)" cursor.execute(sql, ('Alice', 'alice@example.com')) # 提交事务 connection.commit() except pymysql.Error as e: # 回滚事务 connection.rollback() print(f"数据库操作失败: {e}") ``` #### 注意事项 - 确保 MySQL 服务正在运行，并且数据库用户有权限从 Python 脚本连接。 - 使用 `utf8mb4` 字符集可以支持更广泛的字符集，包括表情符号。 - 在生产环境中，建议将数据库连接参数（如用户名、密码）配置在配置文件中，避免硬编码。