### 如何使用 Python 连接数据库并执行插入操作 以下是通过 `pymysql` 库实现 Python 连接到 MySQL 数据库并执行插入操作的一个完整示例： ```python import pymysql try: # 建立数据库连接 conn = pymysql.connect( host='localhost', # 数据库主机地址 user='root', # 数据库用户名 password='your_password', # 替换为自己的密码 database='test_db', # 需要提前创建好的数据库名称 charset='utf8mb4' # 字符集编码 ) # 创建游标对象 cursor = conn.cursor() # 定义 SQL 插入语句 insert_sql = "INSERT INTO users (name, age) VALUES (%s, %s)" data_to_insert = ('John Doe', 30) # 执行插入操作 cursor.execute(insert_sql, data_to_insert) # 提交事务以保存更改 conn.commit() print("数据插入成功！") except pymysql.Error as e: print(f"发生错误：{e}") # 如果发生异常，则回滚事务 if conn: conn.rollback() finally: # 关闭游标和连接 if cursor: cursor.close() if conn: conn.close() ``` #### 解析说明 1. **建立连接** 使用 `pymysql.connect()` 方法来建立与 MySQL 数据库的连接，需提供必要的参数如 `host`, `user`, `password`, 和 `database` 等[^1]。 2. **定义 SQL 查询** 在本例中，我们准备了一条用于向表 `users` 中插入新记录的 SQL 语句。占位符 `%s` 表示动态传参的位置，从而防止 SQL 注入攻击[^4]。 3. **执行查询** 利用 `cursor.execute()` 方法运行指定的 SQL 操作，并传递所需的数据作为第二个参数[^2]。 4. **提交事务** 对于修改型的操作（如 INSERT/UPDATE），需要调用 `conn.commit()` 来确认变更；否则，在遇到错误时可以调用 `conn.rollback()` 取消未完成的任务[^3]。 5. **关闭资源** 不论是否发生异常，都应确保释放所有占用的资源，即关闭游标 (`cursor`) 和断开数据库链接 (`conn`)。 --- ### 注意事项 - 确保目标数据库已存在且具有相应的权限。 - 若涉及敏感信息（例如密码），建议采用更安全的方式存储而非硬编码。 - 当处理大量数据时，考虑分批写入以优化性能。