SQLAlchemy中跳过异常插入语句，继续执行剩余操作的方法

当SQLAlchemy的Session执行操作触发数据库约束异常时，整个会话会被标记为失效状态，此时即便手动调用rollback，也可能因为会话内残留的脏数据或错误状态，导致后续操作无法正常执行。以下是两种可行的解决方案：

方案一：为每条插入操作创建独立会话 #

直接为每条数据创建独立的Session，确保单个数据的错误不会影响其他插入操作，每个操作都是独立事务：

from sqlalchemy import create_engine
from sqlalchemy.orm import sessionmaker
from your_module import YourModel  # 替换为你的模型类

# 初始化引擎和会话工厂
engine = create_engine("your_database_connection_url")
SessionFactory = sessionmaker(bind=engine)

# 待插入的数据列表
data_list = [
    # 你的10条待插入数据，格式为字典或模型实例
]

for idx, data in enumerate(data_list, 1):
    session = SessionFactory()
    try:
        # 创建模型实例并添加到会话
        obj = YourModel(**data) if isinstance(data, dict) else data
        session.add(obj)
        session.commit()
        print(f"第{idx}条数据插入成功")
    except Exception as e:
        # 出错时回滚并跳过当前数据
        session.rollback()
        print(f"第{idx}条数据插入失败，已跳过: {str(e)}")
    finally:
        # 无论成功失败，都关闭当前会话
        session.close()

方案二：复用会话但异常后彻底清理状态 #

如果不想频繁创建会话，可以在捕获异常后，通过回滚+清理会话状态的方式，让会话恢复可用：

from sqlalchemy import create_engine
from sqlalchemy.orm import sessionmaker
from sqlalchemy.exc import IntegrityError  # 捕获具体的约束异常
from your_module import YourModel

engine = create_engine("your_database_connection_url")
Session = sessionmaker(bind=engine)
session = Session()

data_list = [
    # 你的10条待插入数据
]

for idx, data in enumerate(data_list, 1):
    try:
        obj = YourModel(**data)
        session.add(obj)
        session.commit()
        print(f"第{idx}条数据插入成功")
    except IntegrityError as e:
        # 仅捕获约束相关异常，避免忽略其他错误
        session.rollback()
        # 清理会话中所有已加载的对象，消除脏数据残留
        session.expire_all()
        print(f"第{idx}条数据违反约束，已跳过: {str(e)}")
    except Exception as e:
        # 处理其他非约束类异常
        session.rollback()
        session.expire_all()
        print(f"第{idx}条数据插入失败，已跳过: {str(e)}")

session.close()

关键注意点 #

• 异常发生后不要调用flush()：此时会话已处于失效状态，flush会尝试同步脏数据，触发新的异常。
• 优先捕获具体异常（如IntegrityError）：避免泛用Exception捕获无关错误，便于排查问题。
• 若使用批量插入，单条错误会导致整批失败，因此单条独立处理是更稳妥的选择。

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