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)
(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...
7条答案
按热度按时间dtcbnfnu1#
除了通常的事务本地SQLAlchemy标识Map之外,人们认为还有一个“缓存”在起作用,通常的原因是他们观察到了事务隔离的效果。SQLAlchemy的会话默认工作在事务模式下,这意味着它要等到调用
session.commit()
才能将数据持久化到数据库中。在这段时间内,在别处进行的其它事务将看不到该数据。但是,由于事务的隔离特性,存在一个额外的问题,即那些正在进行的其他事务不仅在提交之前看不到事务的数据,在某些情况下,他们也无法看到它,直到 * 他们被提交或回滚 *(这与close()在这里的效果相同).具有平均隔离度的事务将保持到目前为止加载的状态,且即使真实的数据发生了变化,仍然保持事务本地相同状态--用事务隔离的说法,这称为可重复读取。
http://en.wikipedia.org/wiki/Isolation_%28database_systems%29
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应用程序“对话”了。代码如下:
当SQLAlchemy引擎以“READ UNCOMMITED”isolation_level启动时,它将执行“脏读”,这意味着它将直接从数据库读取未提交的更改。
希望这对你有帮助
以下是AaronD在评论中提供的可能解决方案
vohkndzv3#
除了 zzzeek 出色的回答之外,
我也遇到过类似的问题。我通过使用短时间的生活会话解决了这个问题。
我对每个任务、任务组或请求使用了一个新的会话(在Web应用程序的情况下),这为我解决了“缓存”问题。
这份材料对我非常有用:
何时构造会话、何时提交会话以及何时关闭会话
h5qlskok4#
这是在我的Flask应用程序中发生的,我的解决方案是在每次请求后使会话中的所有对象过期。
效果很好。
omtl5h9j5#
首先,SQLAlchemy没有缓存,根据你从数据库中取数据的方法,你应该在别人更新数据库后做一些测试,看看你是否能得到新的数据。
请执行中的步骤:http://docs.sqlalchemy.org/en/latest/core/connections.html
另一个可能的原因是您的MySQL数据库没有永久更新。重新启动MySQL服务并进行检查。
dkqlctbz6#
我试过
session.commit(), session.flush()
,没有一个对我有效。在浏览了sqlalchemy源代码后,找到了解决方案。在
create_engine
中设置query_cache_size=0
工作。zzoitvuj7#
我知道SQLAlchemy不存储缓存,所以你需要查看日志输出。