我在使用sqlalchemy.
我sqlalchemy用来将数据插入 MySQL 数据库。然后，我让另一个应用程序处理这些数据，并直接更新它。
但sqlalchemy总是返回旧数据而不是更新数据。我认为sqlalchemy缓存了我的请求......所以......我应该如何禁用它？
问问题
20602 次
6 回答
49
人们认为有一个“缓存”在起作用，除了通常的事务本地的 SQLAlchemy 身份映射之外，通常的原因是他们正在观察事务隔离的影响。SQLAlchemy 的会话默认在事务模式下工作，这意味着它会等待直到session.commit()被调用，以便将数据持久化到数据库中。在此期间，其他地方正在进行的其他事务将看不到此数据。
然而，由于交易的孤立性，还有一个额外的转折。那些正在进行的其他事务不仅在提交之前不会看到您的事务的数据，在某些情况下，在提交或回滚之前它们也看不到它（这与您的 close() 在这里产生的效果相同） . 具有平均隔离度的事务将保持它迄今为止加载的状态，并继续为您提供与事务本地相同的状态，即使实际数据已更改 - 这在事务隔离用语中称为可重复读取。
http://en.wikipedia.org/wiki/Isolation_%28database_systems%29
于 2012-04-18T14:51:50.660 回答
19
这个问题对我来说真的很沮丧，但我终于想通了。
我有一个与旧 PHP 站点一起运行的 Flask/SQLAlchemy 应用程序。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”隔离级别启动时，它将执行“脏读”，这意味着它将直接从数据库中读取未提交的更改。
希望这可以帮助
这是 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)
于 2013-08-14T07:11:55.633 回答
4
除了zzzeek出色的答案，
我有一个类似的问题。我通过使用短暂的生命周期解决了这个问题。
with closing(new_session()) as sess:
# do your stuff
我为每个任务、任务组或请求使用了一个新会话（如果是 Web 应用程序）。这为我解决了“缓存”问题。
这个材料对我非常有用：
于 2013-04-03T12:59:56.407 回答
3
这发生在我的 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)
像魅力一样工作。
于 2014-02-20T19:32:44.260 回答
0
首先，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 服务并进行检查。
于 2012-04-18T14:03:20.523 回答