SQLAlchemyORM中FlushError()异常的捕获与处理方式

在SQLAlchemy ORM中，可以使用try-except块来捕获和处理FlushError()异常。FlushError()异常通常在将对象的更改保存到数据库时发生冲突时引发。

下面是一个使用SQLAlchemy ORM处理FlushError()异常的示例：

from sqlalchemy import create_engine, Column, Integer, String, ForeignKey
from sqlalchemy.orm import sessionmaker, relationship
from sqlalchemy.orm.exc import FlushError
from sqlalchemy.ext.declarative import declarative_base

# 创建数据库连接
engine = create_engine('sqlite:///test.db')
Base = declarative_base(bind=engine)
Session = sessionmaker(bind=engine)
session = Session()

# 创建模型类
class User(Base):
    __tablename__ = 'users'
    id = Column(Integer, primary_key=True)
    name = Column(String(50))
    email = Column(String(50), unique=True)

# 创建表
Base.metadata.create_all()

# 添加新的用户
user1 = User(name='Alice', email='alice@example.com')
user2 = User(name='Bob', email='alice@example.com')  # 这里故意设置相同的email
session.add_all([user1, user2])

try:
    session.commit()
    print("提交成功！")
except FlushError as e:
    session.rollback()
    print("提交失败！发生冲突！")
    print(e)

# 关闭会话
session.close()

在上面的示例中，我们首先创建一个数据库连接，然后定义了一个User模型类，并使用__tablename__属性来指定表名。

接下来，我们创建了用户表，使用了create_all()方法创建所有定义的模型类。

然后，我们创建了两个User对象，并将它们添加到会话中。其中，user2的email字段与user1相同，这是故意制造冲突的情况。

在提交会话时，如果发生冲突，会触发FlushError()异常。在异常处理块中，我们回滚会话并打印出错误信息。

最后，我们关闭了会话。

总结：

- 在发生冲突时，FlushError()异常被触发，可以使用try-except块来捕获并处理该异常。

- 使用session.rollback()回滚会话以取消已做的更改。

- 可以通过打印异常对象来获取更详细的错误信息。

注意：在实际应用中，为了避免FlushError()异常，可以在添加对象到会话之前，先查询数据库判断是否存在重复的数据。