如何禁用SQLAlchemy缓存?

Posted

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了如何禁用SQLAlchemy缓存?相关的知识,希望对你有一定的参考价值。

当我使用sqlalchemy时,我有一个缓存问题。

我使用sqlalchemy将数据插入mysql数据库。然后,我有另一个应用程序处理这些数据,并直接更新它。

sqlalchemy总是返回旧数据而不是更新数据。我认为sqlalchemy缓存了我的请求......所以...我应该如何禁用它?

答案

人们认为游戏中存在“缓存”的通常原因是,除了通常的事务本地SQLAlchemy身份映射之外,他们正在观察事务隔离的影响。默认情况下,SQLAlchemy的会话在事务模式下工作,这意味着它会等到调用session.commit()才能将数据持久保存到数据库中。在此期间,其他正在进行的其他交易将无法查看此数据。

但是,由于交易的孤立性,还有一个额外的转折点。正在进行的其他事务不仅会在提交之前看不到您的事务数据,在它们被提交或回滚之前它们也无法在某些情况下看到它(这与您的close()具有相同的效果) 。具有平均隔离程度的事务将保持到目前为止已加载的状态,并且即使实际数据已更改,也会继续为事务提供相同的本地状态 - 这在事务隔离用语中称为可重复读取。

http://en.wikipedia.org/wiki/Isolation_%28database_systems%29

另一答案

这个问题对我来说真的很令人沮丧,但我终于明白了。

我有一个Flask / SQLAlchemy应用程序与旧的php站点一起运行。 PHP站点将写入数据库,SQLAlchemy不会知道任何更改。

我尝试了sessionmaker设置autoflush = True失败了我在查询和NONE工作之前尝试了db_session.flush(),db_session.expire_all()和db_session.commit()。仍显示陈旧数据。

最后,我遇到了SQLAlchemy文档的这一部分:http://docs.sqlalchemy.org/en/latest/dialects/postgresql.html#transaction-isolation-level

设置isolation_level非常有效。现在我的Flask应用程序正在与PHP应用程序“交谈”。这是代码:

engine = create_engine(
    "postgresql+pg8000://scott:tiger@localhost/test",
    isolation_level="READ UNCOMMITTED"
)

当SQLAlchemy引擎以“READ UNCOMMITTED”隔离级别启动时,它将执行“脏读”,这意味着它将直接从数据库读取未提交的更改。

希望这可以帮助


这是一个可能的解决方案由AaronD在评论中提供

from flask.ext.sqlalchemy import SQLAlchemy

class UnlockedAlchemy(SQLAlchemy):
    def apply_driver_hacks(self, app, info, options):
        if "isolation_level" not in options:
            options["isolation_level"] = "READ COMMITTED"
    return super(UnlockedAlchemy, self).apply_driver_hacks(app, info, options)
另一答案

除了zzzeek优秀的答案,

我有一个类似的问题。我通过短暂的生活会议解决了这个问题。

with closing(new_session()) as sess:
    # do your stuff

我使用了每个任务,任务组或请求的新会话(如果是Web应用程序)。这解决了我的“缓存”问题。

这个材料对我非常有用:

When do I construct a Session, when do I commit it, and when do I close it

另一答案

这在我的Flask应用程序中发生,我的解决方案是在每次请求后使会话中的所有对象失效。

from flask.signals import request_finished
def expire_session(sender, response, **extra):
    app.db.session.expire_all()
request_finished.connect(expire_session, flask_app)

工作就像一个魅力。

另一答案

首先,SQLAlchemy没有缓存。根据您从数据库获取数据的方法,您应该在其他人更新数据库后进行一些测试,看看是否可以获取新数据。

(1) use connection:
connection = engine.connect()
result = connection.execute("select username from users")
for row in result:
    print "username:", row['username']
connection.close()
(2) use Engine ...
(3) use MegaData...

请按照以下步骤操作:qazxsw poi

另一个可能的原因是您的MySQL DB未永久更新。重启MySQL服务并进行检查。

另一答案

因为我知道SQLAlchemy http://docs.sqlalchemy.org/en/latest/core/connections.html,所以你需要查看does not store caches输出。

以上是关于如何禁用SQLAlchemy缓存?的主要内容,如果未能解决你的问题,请参考以下文章

如何禁用分离实例关系上的 SQLAlchemy 延迟加载?

SQLAlchemy:如何在删除时禁用 ORM 级外键处理?

如何禁用在android片段类中按下的后退按钮

SQLAlchemy 查询引发关于 sqlite 和 Decimal 的不必要警告,如何专门禁用?

python SQLAlchemy 缓存问题

python SQLAlchemy 缓存问题