複数DBトランザクション

Question

Djangoバージョン1.10.5 with Postgres 9.6.1

私は昨年、マルチスキーマのデフォルトデータベース環境で作業していました。しかし、私は1つのデータベースを3つのデータベースに分割することに決めました。

私はすべての3つのデータベースのマスター/スレーブルータで作業しています。

私は 'デフォルト'のデータベースキーを使用していません。代わりに、私は 'db1'、 'db2'、および 'db3'を持っています

私が混乱している部分は、このマルチデータベース環境でのトランザクションです。

この例では、期待どおりに失敗します。当然私には明らかである@transaction.atomic(using='db1')を使用しないことによって引き起こされた。

@transaction.atomic() 
def edit(self, context): 
    """Edit 

    :param dict context: Context 

    :return: None 
    """ 

    # Check if employee exists 
    try: 
     result = Passport.objects.get(pk=self.user.employee_id) 
    except Passport.DoesNotExist: 
     return False 

    result.name = context.get('name') 

    result.save() 

私は理解しようとしているという理由だけで、この奇妙な例を持っている...しかし、私はこれが失敗すると予想しているだろうが、それはしません。

@transaction.atomic(using='db1') 
def edit(self, context): 
    """Edit 

    :param dict context: Context 

    :return: None 
    """ 

    # Check if employee exists 
    try: 
     result = Passport.objects.get(pk=self.user.employee_id) 
    except Passport.DoesNotExist: 
     return False 

    result.name = context.get('name') 

    with transaction.atomic(using='db2'): 
     result.save() 

存在しないPassportモデルDB2モデルではまったく同じです。

ルーターはすべての書き込みがそれぞれの尊重されたDBに行くように設定されています。

したがって、アトミックトランザクションでusing='db1'を設定する目的は何ですか。私はソースを見て、 "使用していない"ときにはデフォルトはdefaultになっています。

上記の例では、最初のトランザクションの内部で別のトランザクションを作成しましたが、今度はモデルが存在しないusing='db2'です。私はそれが失敗したと考えましたが、データが適切なデータベースに書き込まれませんでした。

3つのデータベースすべてとやり取りする必要があり、3つのデータベースすべてに書き込むときに1つの問題が発生した場合、3つすべてをロールバックする必要があります。もちろんコミットした。

おそらく誰かが私を理解するためにこれを打ち砕くのを助けることができますか？

Answer 1

は、と解釈されています.X内のトランザクションの中で、次のデータベースコマンドを実行してください。

実際には、はデータベースXでトランザクションを開き、それをコミットするかブロックの末尾にロールバックする。

あるいは、documentationはそれを置くよう：ボンネットの下に

を、Djangoのトランザクション管理コード：一番外側のアトミックブロックに入るとき

• は、トランザクションを開きます。
• は、最も外側のブロックを終了するときにトランザクションをコミットまたはロールバックします。

与えられたコマンドのために使用するデータベースの質問は、あなたのrouter、ないusing句によって決定されます。だからあなたのtransaction.atomic(using='db2')ブロックは無意味です（単にdb2でトランザクションを開いて閉じます）が、エラーではありません。