使用 SQLAlchemy 解决缓存问题
使用 SQLAlchemy 从数据库插入和检索数据时,可能会出现缓存问题,从而导致不一致。本文研究了常见原因并提供了在 SQLAlchemy 中禁用缓存的解决方案。
了解 SQLAlchemy 缓存
SQLAlchemy 在每个事务中维护一个标识映射,该映射充当缓存最近访问的对象。这样可以防止对同一数据进行多个数据库查询,从而优化性能。但是,当数据从外部更新到 SQLAlchemy 时,此缓存可能会因返回过时的结果而导致问题。
禁用缓存
要解决此问题,有必要禁用SQLAlchemy 中的缓存。这可以通过在映射器配置上将 expire_on_commit 标志设置为 True 来实现。以下代码演示了如何执行此操作:
# Import the ORM classes from sqlalchemy import Column, Integer, String, create_engine, sessionmaker # Create an engine and session factory engine = create_engine('mysql+pymysql://username:password@host/database') Session = sessionmaker(bind=engine) # Define the User class class User(Base): __tablename__ = 'users' id = Column(Integer, primary_key=True) name = Column(String) __mapper_args__ = { 'expire_on_commit': True }
通过将expire_on_commit 设置为True,SQLAlchemy 将在提交时使身份映射中的所有对象过期。这可确保始终从数据库中检索最新数据。
示例
考虑原始问题中描述的场景:
# Create a session session = Session() # Insert data into the database new_user = User(name='John Doe') session.add(new_user) session.commit() # Update the data directly in the database connection = engine.connect() cursor = connection.cursor() cursor.execute("UPDATE users SET name='Jane Doe' WHERE>
禁用缓存后,SQLAlchemy 将返回更新的用户记录 (Jane Doe),而不是过时的缓存记录 (John美国能源部)。这解决了缓存问题并确保应用程序始终从数据库中检索最新数据。
以上是如何禁用 SQLAlchemy 缓存以防止数据不一致?的详细内容。更多信息请关注PHP中文网其他相关文章!