Python中重复执行SQL insert出错请求助：需实现无需重启多次插入

你遇到的第二次插入报错，大概率不是单纯缺个循环，而是数据库连接、游标或者事务管理没处理到位。我给你拆解常见坑点，直接上可落地的解决方案和代码示例：

常见错误原因&核心修复点 #

1. 每次插入都新建连接，没复用资源 #

很多新手会犯的错：第一次插入后随手关闭连接，第二次操作时连接已经失效；或者重复创建连接导致数据库连接池耗尽，直接报错。

2. 事务没提交 #

默认情况下，多数数据库连接不会自动提交事务。如果第一次插入后没手动执行commit()，事务会处于挂起状态，第二次操作就会触发冲突。

3. 游标没重置或重复创建 #

游标可以重复执行多次SQL，没必要每次插入都新建。如果游标被意外关闭，第二次调用自然会失败。

正确的重复插入实现示例 #

方案1：复用单个连接，循环执行插入（适合零散多次插入） #

这种方式适合程序运行期间需要多次触发插入的场景，只创建一次连接，全程复用：

import mysql.connector  # 以MySQL为例，PostgreSQL的psycopg2、SQLite的sqlite3逻辑完全一致

# 全局复用连接（程序运行期间保持打开）
db_conn = mysql.connector.connect(
    host="你的数据库地址",
    user="用户名",
    password="密码",
    database="目标库名"
)
db_cursor = db_conn.cursor()

def insert_single_record(data):
    try:
        # 定义插入SQL（根据你的表结构调整字段和占位符）
        insert_sql = "INSERT INTO user_info(name, age) VALUES (%s, %s)"
        db_cursor.execute(insert_sql, data)
        db_conn.commit()  # 必须提交事务，否则数据不会写入
        print(f"成功插入数据：{data}")
    except Exception as e:
        db_conn.rollback()  # 出错时回滚，避免事务阻塞
        print(f"插入失败：{str(e)}")

# 第一次插入
insert_single_record(("张三", 25))
# 第二次插入（无需重启程序，直接调用）
insert_single_record(("李四", 30))
# 第三次插入
insert_single_record(("王五", 28))

# 程序退出前再关闭连接和游标
# db_cursor.close()
# db_conn.close()

方案2：批量插入（高效处理多条数据） #

如果是一次性要插入多条记录，用executemany比循环execute性能高很多：

def batch_insert_records(data_list):
    try:
        insert_sql = "INSERT INTO user_info(name, age) VALUES (%s, %s)"
        db_cursor.executemany(insert_sql, data_list)
        db_conn.commit()
        print(f"批量插入完成，共插入{db_cursor.rowcount}条数据")
    except Exception as e:
        db_conn.rollback()
        print(f"批量插入失败：{str(e)}")

# 调用示例：一次插入3条
batch_insert_records([("赵六", 32), ("钱七", 26), ("孙八", 35)])

关键注意事项 #

• 不要频繁创建/关闭连接：数据库连接是昂贵资源，频繁操作会导致性能下降甚至连接超时错误。长期运行的程序建议保持一个全局连接。
• 事务必须显式提交：插入、更新、删除操作后一定要执行commit()，否则数据只会停留在内存中，不会写入数据库，还会导致后续操作阻塞。
• 异常处理不能少：加try-except块捕获错误，既能避免程序崩溃，也能快速定位问题（比如字段不匹配、主键冲突等）。
• 游标可重复使用：一个游标可以执行任意多次SQL，不需要每次操作都重新创建。

如果你的报错有具体提示（比如"Connection closed"或"Duplicate entry"），可以把错误信息贴出来，我再帮你精准排查！

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