使用多数据库的Django事务

问题描述

我有三个数据库，我想在一个请求的事务中向它们添加数据。

例如我的代码。

@transaction.commit_manually
def my_view(request):
    try:
        MyModel_one(...).save(using='default')
        MyModel_two(...).save(using='db_one')
        MyModel_three(...).save(using='db_two') # <-- for example we make exception here (duplicate data)
    except IntegrityError:
        transaction.rollback()
        transaction.rollback(using='db_one')
        transaction.rollback(using='db_two')
        return ...
    transaction.commit()
    transaction.commit(using='db_one')
    transaction.commit(using='db_two')
    return ...

结果：

1. MyModel_One-数据未保存
2. MyModel_Two-数据已保存(我不知道为什么)
3. MyModel_Three-由于希望错误，数据未保存

问题：为什么事务在这里不起作用？我可以做些什么来获得工作事务处理？

(我尝试了其他方法，但没有成功) (我也知道这不是很漂亮的代码，但很容易理解这个问题)

Django 1.7.7 Python2.7

数据库： 默认-Postgres DB_ONE-MySQL DB_TWO-MySQL

---

解决方案

Django1.6中的transaction.commit_manually修饰符was deprecated。您应该切换到Django的新事务管理。

我认为您不需要手动提交事务，您可以嵌套transaction.atomic。

def my_view(request):
    try:
        with transaction.atomic(using='default'):
            with transaction.atomic(using='db_one'):
                with transaction.atomic(using='db_two'):
                    MyModel_one(...).save(using='default')
                    MyModel_two(...).save(using='db_one')
                    MyModel_three(...).save(using='db_two') # raises exception
    except IntegrityError:
        return ...
    return ...