在使用 Python 对 MySQL 数据库进行数据处理时，可以通过一些基础和高级的技巧来实现数据的查询、插入、更新以及异常处理等操作。以下是一个详细的教程和示例代码，帮助您从基础开始学习如何使用 Python 与 MySQL 进行交互。 ### 数据库连接与基本查询 在开始处理数据之前，需要先连接 MySQL 数据库。使用 `pymysql` 模块可以轻松实现这一目标。以下是连接数据库并执行简单查询的示例代码： ```python import pymysql # 连接数据库 connect = pymysql.connect( host='localhost', port=3306, user='root', passwd='your password', db='your database name', charset='utf8' ) # 创建游标对象 cursor = connect.cursor() # 执行SQL查询 sql = "SHOW DATABASES;" cursor.execute(sql) # 输出查询结果 print(cursor.fetchall()) # 关闭游标和数据库连接 cursor.close() connect.close() ``` ### 插入数据 将数据插入到数据库中是数据处理的重要部分。以下是如何将数据插入到 MySQL 表中的示例代码： ```python # 重新连接数据库 connect = pymysql.connect( host='localhost', port=3306, user='root', passwd='your password', db='your database name', charset='utf8' ) cursor = connect.cursor() # 插入数据的SQL语句 sql_insert = "INSERT INTO your_table_name (column1, column2) VALUES (%s, %s)" data_to_insert = ("value1", "value2") # 执行插入操作 cursor.execute(sql_insert, data_to_insert) # 提交事务 connect.commit() # 关闭游标和连接 cursor.close() connect.close() ``` ### 异常处理 在进行数据库操作时，可能会遇到各种异常情况，例如数据库连接失败或 SQL 语句执行错误。为了确保程序的健壮性，需要进行异常处理。以下是一个包含异常处理的数据插入示例： ```python try: # 连接数据库 connect = pymysql.connect( host='localhost', port=3306, user='root', passwd='your password', db='your database name', charset='utf8' ) cursor = connect.cursor() # 尝试执行SQL语句 sql_insert = "INSERT INTO your_table_name (column1, column2) VALUES (%s, %s)" data_to_insert = ("value1", "value2") cursor.execute(sql_insert, data_to_insert) connect.commit() except pymysql.Error as e: print(f"Error {e.args[0]}: {e.args[1]}") connect.rollback() finally: # 确保游标和连接被关闭 if 'cursor' in locals(): cursor.close() if 'connect' in locals(): connect.close() ``` ### 使用 Pandas 处理数据 Pandas 是一个强大的数据处理库，可以与 MySQL 结合使用来处理和分析数据。通过 Pandas，可以轻松地将数据从数据库读取到 DataFrame 中，或者将 DataFrame 中的数据写入数据库： ```python import pandas as pd import pymysql from sqlalchemy import create_engine # 创建数据库引擎 engine = create_engine('mysql+pymysql://root:your_password@localhost:3306/your_database_name') # 从数据库读取数据 df = pd.read_sql("SELECT * FROM your_table_name", engine) # 显示数据 print(df.head()) # 将DataFrame写入数据库 df.to_sql(name='your_table_name', con=engine, if_exists='append', index=False) ``` ### 数据更新与删除 除了插入数据之外，还可以执行更新和删除操作。以下是更新和删除数据的示例代码： ```python # 连接数据库 connect = pymysql.connect( host='localhost', port=3306, user='root', passwd='your password', db='your database name', charset='utf8' ) cursor = connect.cursor() # 更新数据 sql_update = "UPDATE your_table_name SET column1 = %s WHERE column2 = %s" data_update = ("new_value", "condition_value") cursor.execute(sql_update, data_update) connect.commit() # 删除数据 sql_delete = "DELETE FROM your_table_name WHERE column = %s" data_delete = ("value_to_delete",) cursor.execute(sql_delete, data_delete) connect.commit() # 关闭游标和连接 cursor.close() connect.close() ``` 以上示例涵盖了从数据库连接、数据插入、异常处理、使用 Pandas 处理数据到数据更新和删除的基本操作。这些操作可以帮助您开始使用 Python 进行 MySQL 数据处理[^2]。