我有以下内容:
@periodic_task(run_every=crontab(minute="*/1"))
def PeriodicUpdateAgentLastRica():
query = """update agents
inner join
(select sims.consignment_agents_id as agents_id,
MAX(sims.rica_current_stamp)
as last_rica_stamp
from sims
where sims.rica_current_stamp > DATE_SUB(now(), INTERVAL 3 MONTH) and sims.consignment_agents_id is not NULL
group by sims.consignment_agents_id) as dt on dt.agents_id = agents.id
set agents.last_rica_stamp = dt.last_rica_stamp"""
res = Session.execute(query)
print res
if res.rowcount:
log.info("Updated %s agents" % res.rowcount)
#transaction.commit()
当我运行 celery worker -B
这是返回的内容:
[2014-02-12 09:15:00,012: INFO/MainProcess] Received task: prepaid.models.Prepaid.PeriodicUpdateAgentLastRica[9ca091c8-595f-4163-8ddf-2742e573b90c]
[2014-02-12 09:15:01,812: WARNING/Worker-7] <sqlalchemy.engine.result.ResultProxy object at 0x776f310>
[2014-02-12 09:15:01,813: INFO/Worker-7] Updated 2923 agents
[2014-02-12 09:15:01,816: INFO/MainProcess] Task prepaid.models.Prepaid.PeriodicUpdateAgentLastRica[9ca091c8-595f-4163-8ddf-2742e573b90c] succeeded in 1.798980095s: None
即使它说它已更新:Updated 2923 agents
,但当我检查数据库时,没有任何记录被更改。
查询没有任何问题,因为当我在 mySQL Workbench 中运行它时它有效。
当我尝试强制 AutoCommit 时也会发生同样的情况,即
res = Session.execute(text(query).execution_options(autocommit=True))
所以它提交了,但是 Update
仍然没有影响数据库。
为什么不影响数据库?为什么它不起作用?
更新
我也试过:
with transaction.manager:
#Rest of code
但它仍然没有改变数据库中的任何内容
最佳答案
这看起来您正在 Pyramid 中使用 zodb 事务管理器。
您必须将 session 标记为已更改
你应该做类似的事情
from zope.sqlalchemy import mark_changed
mark_changed(Session)
如果不行试试
from zope.sqlalchemy import ZopeTransactionExtension
Session.configure(extension=ZopeTransactionExtension('changed'))
关于python - 为什么 SQLAlchemy 执行更新不起作用,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/21721545/