pymysql数据存储

基础概念

pymysql 是一个用于连接 MySQL 数据库的 Python 库。它允许 Python 程序与 MySQL 数据库进行交互，执行 SQL 查询和操作数据库。pymysql 提供了简单易用的 API，使得在 Python 中进行数据库操作变得方便。

类型

pymysql 主要用于以下类型的数据库操作：

CRUD 操作：创建（Create）、读取（Read）、更新（Update）和删除（Delete）数据。
事务处理：支持数据库事务，保证数据的一致性和完整性。
预处理语句：使用预处理语句防止 SQL 注入攻击。

应用场景

pymysql 广泛应用于各种需要与 MySQL 数据库交互的场景，例如：

Web 开发：使用 Flask、Django 等 Python Web 框架时，常用于数据库操作。
数据分析：从数据库中提取数据进行分析和可视化。
自动化任务：编写脚本定期从数据库中获取数据并执行相应操作。

常见问题及解决方法

问题一：连接数据库时出现错误

原因：可能是数据库地址、端口、用户名或密码配置错误。

解决方法：

import pymysql

try:
    conn = pymysql.connect(
        host='localhost',
        port=3306,
        user='your_username',
        password='your_password',
        db='your_database'
    )
except pymysql.Error as e:
    print(f"连接数据库失败：{e}")

确保 host、port、user、password 和 db 参数配置正确。

问题二：执行 SQL 查询时出现错误

原因：可能是 SQL 语句编写错误或数据库中没有相应的数据。

解决方法：

try:
    with conn.cursor() as cursor:
        sql = "SELECT * FROM your_table"
        cursor.execute(sql)
        result = cursor.fetchall()
        for row in result:
            print(row)
except pymysql.Error as e:
    print(f"执行 SQL 查询失败：{e}")

确保 SQL 语句正确，并检查数据库中是否存在相应的数据表和数据。

问题三：事务处理时出现错误

原因：可能是事务提交或回滚操作失败。

解决方法：

try:
    with conn.cursor() as cursor:
        # 开启事务
        conn.begin()
        
        # 执行 SQL 操作
        sql1 = "UPDATE your_table SET column1 = value1 WHERE condition1"
        cursor.execute(sql1)
        
        sql2 = "INSERT INTO your_table (column1, column2) VALUES (value1, value2)"
        cursor.execute(sql2)
        
        # 提交事务
        conn.commit()
except pymysql.Error as e:
    # 回滚事务
    conn.rollback()
    print(f"事务处理失败：{e}")

确保在事务处理过程中正确使用 begin()、commit() 和 rollback() 方法。