如何禁用SQLAlchemy缓存？

Posted 2021-03-26

当我使用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输出。