【Pymysql】执行插入语句无报错但影响行数为0的问题求助

问题定位与原因分析 #

1. SQL语句未实际执行插入 #

如果你的插入语句使用了INSERT IGNORE或ON DUPLICATE KEY UPDATE，当遇到唯一键冲突、字段约束不满足等情况时，数据库会跳过插入操作，此时cursor.execute()会返回0且不抛出异常。这种场景下SQL语法合法，但没有实际写入数据。

2. 上下文管理器的事务提交逻辑缺陷 #

看你提供的DB.mysql()实现：

try:
    conn = self.__pool.connection()
    cursor = conn.cursor(cursor=pymysql.cursors.DictCursor)
    yield cursor
    conn.commit()
except APIException as e:
    conn.rollback()
    raise e
finally:
    cursor.close()
    conn.close()

这里存在两个关键问题：

• yield cursor会暂停函数执行，conn.commit()要等到with块内代码全部执行完才会运行。如果with块内抛出非APIException类型的异常，会直接跳过commit，也不会触发rollback（因为except只捕获APIException），导致事务未提交。不过这种情况execute应该返回正常行数（比如1），但数据不会写入，和你描述的res=0不完全匹配，但属于代码隐患。
• 如果with块内有隐藏异常被上层捕获，commit同样不会执行，但execute返回值应该正常。

3. 连接池连接异常 #

连接池中的连接可能已失效但未被检测，导致execute没有真正将SQL发送到数据库，不过这种情况通常会抛出异常，和你无报错的情况不符，但可以作为排查点。

解决与排查步骤 #

步骤1：验证SQL语句的有效性 #

• 去掉INSERT IGNORE（如果使用了），重新执行，看是否抛出约束冲突类异常。
• 打印替换参数后的完整SQL，直接在数据库客户端执行，确认是否能正常插入：

  with DB.mysql() as cursor:
      print(cursor.mogrify(sql, args))  # 输出带参数的最终SQL
      res = cursor.execute(sql, args)
  

步骤2：修复上下文管理器的事务逻辑 #

修改DB.mysql()的异常捕获范围，确保任何异常都能触发回滚，同时避免未定义变量的报错：

# 修正后的DB.mysql()实现
try:
    conn = self.__pool.connection()
    cursor = conn.cursor(cursor=pymysql.cursors.DictCursor)
    yield cursor
    conn.commit()
except Exception as e:
    # 确保conn存在时才执行回滚
    if 'conn' in locals():
        conn.rollback()
    raise e
finally:
    # 避免cursor/conn未初始化时调用close
    if 'cursor' in locals():
        cursor.close()
    if 'conn' in locals():
        conn.close()

步骤3：排除连接池问题 #

临时使用直接连接替代连接池，测试插入是否正常：

# 临时测试代码
import pymysql

# 替换为你的数据库配置
conn = pymysql.connect(
    host='your_host',
    user='your_user',
    password='your_password',
    database='your_db'
)
cursor = conn.cursor(pymysql.cursors.DictCursor)
res = cursor.execute(sql, args)
print(f"受影响行数: {res}")
conn.commit()
cursor.close()
conn.close()

如果这段代码能正常插入并返回1，说明问题出在连接池或上下文管理器的实现上。

额外排查点 #

• 检查数据库自动提交状态：pymysql默认关闭自动提交，必须手动执行commit，可以在conn.commit()前加打印语句，确认该代码是否被执行。
• 排查是否存在表锁或行锁：如果其他事务锁定了目标表/行，插入可能被阻塞，但通常会超时抛出异常，而非返回0。

内容的提问来源于stack exchange，提问作者ye andy