关于MySQL的Django：如何启用自动提交？

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了关于MySQL的Django：如何启用自动提交？，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含1333字，纯文字阅读大概需要2分钟。

内容图文

我有类似下面的代码在后台进程中运行：

def run()
    while True:
        objs = MyModel.objects.filter(last_updated < time.time() - FREQUENCY)
        print objs

def update()
    while True:
       # some processing code
       mymodel.last_updated = time.time()
       mymodel.save()

上述函数在两个独立的线程中运行：update()依次更新所有模型,而run()选择需要更新的模型.这一切都针对MySQL运行,而MyModel则存在于InnoDB表中.

问题是run()总是看到last_updated的相同值.原因是它位于事务内部并选择数据的一致快照.当然,我希望它选择最新的数据.如果我执行以下操作,它可以工作：

def run()
    from django.db import connection
    while True:
        connection.connection.execute('SET autocommit = 1')
        objs = MyModel.objects.filter(last_updated < time.time() - FREQUENCY)
        print objs

但这意味着我将每次执行一次额外的查询.最重要的是,如果连接在我设置autocommit = 1和下面的select之间关闭,它将无法工作.

Postgres乐意支持这个：http://docs.djangoproject.com/en/dev/ref/databases/#autocommit-mode(至少根据文档),但是有没有办法为MySQL启用自动提交？

此外,由于它作为后台进程运行,因此不会处理任何请求,也不会涉及中间件.

解决方法:

在Django中,我监听connection_created信号,一旦建立连接就发送“set autocommit = 1”语句.它工作正常！

from django.db.backends.signals import connection_created
from django.dispatch import receiver

@receiver(connection_created)
def connection_init(sender, connection, **kwargv):
    connection.cursor().execute("SET autocommit=1")

内容总结

以上是互联网集市为您收集整理的关于MySQL的Django：如何启用自动提交？全部内容，希望文章能够帮你解决关于MySQL的Django：如何启用自动提交？所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端