如何禁用 SQLAlchemy 缓存？

问题描述：

我在使用时遇到缓存问题sqlalchemy。

我使用sqlalchemy将数据插入MySQL数据库。然后，我让另一个应用程序处理该数据并直接更新它。

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

解决方案 1：

除了通常的 SQLAlchemy 身份映射（它位于事务本地）之外，人们认为其中存在“缓存”的常见原因是他们正在观察事务隔离的影响。SQLAlchemy 的会话默认以事务模式工作，这意味着它会等待直到session.commit()被调用，以便将数据持久保存到数据库。在此期间，其他地方正在进行的其他事务将看不到此数据。

但是，由于事务的隔离性质，还有一个额外的问题。正在进行的其他事务不仅在提交之前看不到您的事务数据，而且在某些情况下，它们在提交或回滚之前也看不到它（这与您的 close() 在此处产生的效果相同）。具有平均隔离度的事务将保留迄今为止已加载的状态，并继续为您提供与事务本地相同的状态，即使实际数据已更改 - 这在事务隔离术语中称为可重复读取。

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

解决方案 2：

这个问题确实让我很沮丧，但我终于弄明白了。

我有一个 Flask/SQLAlchemy 应用程序与一个较旧的 PHP 网站一起运行。PHP 网站会写入数据库，而 SQLAlchemy 不会察觉任何更改。

我尝试过 sessionmaker 设置 autoflush=True，但没有成功。在查询之前，我尝试过 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 UNCOMMITED”isolation_level 启动时，它将执行“脏读”，这意味着它将直接从数据库读取未提交的更改。

希望这有帮助

以下是 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)

解决方案 3：

除了zzzeek出色的答案之外，

我遇到了类似的问题。我通过使用简短的生活会话解决了该问题。

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

我为每个任务、任务组或请求（在 Web 应用程序的情况下）使用了一个新的会话。这为我解决了“缓存”问题。

这些材料对我非常有用：

何时构造会话、何时提交会话、何时关闭会话

解决方案 4：

我已尝试过，session.commit(), session.flush()但都不起作用。

在查看了 sqlalchemy 源代码后，我找到了禁用缓存的解决方案。

设置query_cache_size=0有效create_engine。

create_engine(connection_string, convert_unicode=True, echo=True, query_cache_size=0)

解决方案 5：

这发生在我的 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)

非常有效。

解决方案 6：

与其他人可能相关的一件事是，当您创建会话并且引擎时，要传递expire_on_commit=True到 sessionmaker 调用中。

sessionmaker(bind=engine, expire_on_commit=True)

我遇到了一些问题，其中 sqlalchemy 关系在创建和提交后没有开始刷新（因为在我的关系中我定义了一个order_by函数，但我的次要对象没有按照预期的顺序排列，这解决了这个问题。

解决方案 7：

首先，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...

请按照以下步骤操作：http://docs.sqlalchemy.org/en/latest/core/connections.html

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

解决方案 8：

import sqlalchemy as db
db.create_engine(db_string, query_cache_size=0, pool_size=30, max_overflow=0, pool_pre_ping=True, echo=True, echo_pool=True)

运行代码片段Hide results展开片段

我们可以在 sqlalchemy 1.3.13 以上的版本中解决这个问题，低于这个版本不支持禁用语句缓存。

解决方案 9：

据我所知，SQLAlchemy不存储缓存，因此您需要查看日志输出。