mysql 如何禁用SQLAlchemy缓存?

iaqfqrcu  于 2022-11-28  发布在  Mysql
关注(0)|答案(7)|浏览(395)

我在使用sqlalchemy时遇到缓存问题。
我使用sqlalchemy将数据插入MySQL数据库,然后让另一个应用程序处理这些数据,并直接更新它。
但是sqlalchemy总是返回旧的数据而不是更新的数据。我想sqlalchemy缓存了我的请求...那么...我应该如何禁用它呢?

dtcbnfnu

dtcbnfnu1#

除了通常的事务本地SQLAlchemy标识Map之外,人们认为还有一个“缓存”在起作用,通常的原因是他们观察到了事务隔离的效果。SQLAlchemy的会话默认工作在事务模式下,这意味着它要等到调用session.commit()才能将数据持久化到数据库中。在这段时间内,在别处进行的其它事务将看不到该数据。
但是,由于事务的隔离特性,存在一个额外的问题,即那些正在进行的其他事务不仅在提交之前看不到事务的数据,在某些情况下,他们也无法看到它,直到 * 他们被提交或回滚 *(这与close()在这里的效果相同).具有平均隔离度的事务将保持到目前为止加载的状态,且即使真实的数据发生了变化,仍然保持事务本地相同状态--用事务隔离的说法,这称为可重复读取
http://en.wikipedia.org/wiki/Isolation_%28database_systems%29

zzzyeukh

zzzyeukh2#

这个问题对我来说真的很沮丧,但我终于想通了。
我有一个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)
vohkndzv

vohkndzv3#

除了 zzzeek 出色的回答之外,
我也遇到过类似的问题。我通过使用短时间的生活会话解决了这个问题。

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

我对每个任务、任务组或请求使用了一个新的会话(在Web应用程序的情况下),这为我解决了“缓存”问题。
这份材料对我非常有用:
何时构造会话、何时提交会话以及何时关闭会话

h5qlskok

h5qlskok4#

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

效果很好。

omtl5h9j

omtl5h9j5#

首先,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数据库没有永久更新。重新启动MySQL服务并进行检查。

dkqlctbz

dkqlctbz6#

我试过session.commit(), session.flush(),没有一个对我有效。
在浏览了sqlalchemy源代码后,找到了解决方案。在create_engine中设置query_cache_size=0工作。

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

zzoitvuj7#

我知道SQLAlchemy不存储缓存,所以你需要查看日志输出。

相关问题