python - 使用多数据库的 Django 事务

Question

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

例如我的代码。

@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.7Python 2.7

数据库:默认值——postgresdb_one — mysqldb_two — mysql

Answer 1

transaction.commit_manually装饰器was deprecated在 Django 1.6 中。您应该切换到 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 ...