Django の複数データベースを使用する手順の詳細な説明

今回は、Django の複数のデータベースを使用する手順について詳しく説明します。Django の複数のデータベースを使用する際の 注意事項 は何ですか?実際の事例を見てみましょう。

1.設定でデータベースを設定します

たとえば、2 つのデータベースを使用する場合:

DATABASES = {
  'default': {
    'NAME': 'app_data',
    'ENGINE': 'django.db.backends.postgresql',
    'USER': 'postgres_user',
    'PASSWORD': 's3krit'
  },
  'users': {
    'NAME': 'user_data',
    'ENGINE': 'django.db.backends.mysql',
    'USER': 'mysql_user',
    'PASSWORD': 'priv4te'
  }
}

このようにして、2 つのデータベースが識別され、1 つはデフォルトのエイリアスで、もう 1 つはエイリアス ユーザーが割り当てられます。データベースの別名は任意に決定できます。

デフォルトのエイリアスは特別で、モデルがルート内で特に選択されていない場合、デフォルトでデフォルトのデータベースが使用されます。

もちろん、デフォルトを空に設定することもできます:

DATABASES = {
  'default': {},
  'users': {
    'NAME': 'user_data',
    'ENGINE': 'django.db.backends.mysql',
    'USER': 'mysql_user',
    'PASSWORD': 'superS3cret'
  },
  'customers': {
    'NAME': 'customer_data',
    'ENGINE': 'django.db.backends.mysql',
    'USER': 'mysql_cust',
    'PASSWORD': 'veryPriv@ate'
  }
}

この方法では、デフォルトのデータベースがないため、使用されるサードパーティ ライブラリのモデルを含むすべてのモデルに対してデータベース ルーティングを実行する必要があります。

2. データベースを選択する必要があるモデルに app_label

class MyUser(models.Model):
  ...
  class Meta:
    app_label = 'users'

を指定します 3.データベースルーターを作成する

Database Router は、モデルがどのデータベースを使用するかを決定するために使用され、主に次の 4 つのメソッドを定義します。

モデルの読み取りに使用するデータベースを指定します。 db_for_read(model, **hints)

モデルの作成に使用するデータベースを指定します。 db_for_write(model, **hints)

obj1 と obj2 を関連付けることができるかどうかを決定します。主に外部キーと多対多の操作に使用されます。 allow_relation(obj1, obj2, **hints)

移行操作をデータベース エイリアス db で実行できるかどうかを判断します。 allow_migrate(db, app_label, model_name=None, **hints)

完全な例:

データベース設定:

DATABASES = {
  'default': {},
  'auth_db': {
    'NAME': 'auth_db',
    'ENGINE': 'django.db.backends.mysql',
    'USER': 'mysql_user',
    'PASSWORD': 'swordfish',
  },
  'primary': {
    'NAME': 'primary',
    'ENGINE': 'django.db.backends.mysql',
    'USER': 'mysql_user',
    'PASSWORD': 'spam',
  },
  'replica1': {
    'NAME': 'replica1',
    'ENGINE': 'django.db.backends.mysql',
    'USER': 'mysql_user',
    'PASSWORD': 'eggs',
  },
  'replica2': {
    'NAME': 'replica2',
    'ENGINE': 'django.db.backends.mysql',
    'USER': 'mysql_user',
    'PASSWORD': 'bacon',
  },
}

次のような効果を実現したい場合:

app_labelがauthであるModelの読み書きはauth_dbで完了し、残りのModelの書き込みはprimaryで完了し、readはreplica1とreplica2でランダムに完了します。

認証者:

rreee

これにより、app_labelがauthであるModelの読み書きがauth_db内で完了し、関連付けが可能となり、auth_dbデータベース内でのみ移行が実行できるようになります。

残り:

rreee

このように、readはreplica1とreplica2でランダムに完了し、書き込みはprimaryを使用します。

最後に設定で設定します:

class AuthRouter(object):
  """
  A router to control all database operations on models in the
  auth application.
  """
  def db_for_read(self, model, **hints):
    """
    Attempts to read auth models go to auth_db.
    """
    if model._meta.app_label == 'auth':
      return 'auth_db'
    return None
  def db_for_write(self, model, **hints):
    """
    Attempts to write auth models go to auth_db.
    """
    if model._meta.app_label == 'auth':
      return 'auth_db'
    return None
  def allow_relation(self, obj1, obj2, **hints):
    """
    Allow relations if a model in the auth app is involved.
    """
    if obj1._meta.app_label == 'auth' or \
      obj2._meta.app_label == 'auth':
      return True
    return None
  def allow_migrate(self, db, app_label, model_name=None, **hints):
    """
    Make sure the auth app only appears in the 'auth_db'
    database.
    """
    if app_label == 'auth':
      return db == 'auth_db'
    return None

それでおしまい。

移行操作を実行する場合:

import random
class PrimaryReplicaRouter(object):
  def db_for_read(self, model, **hints):
    """
    Reads go to a randomly-chosen replica.
    """
    return random.choice(['replica1', 'replica2'])
  def db_for_write(self, model, **hints):
    """
    Writes always go to primary.
    """
    return 'primary'
  def allow_relation(self, obj1, obj2, **hints):
    """
    Relations between objects are allowed if both objects are
    in the primary/replica pool.
    """
    db_list = ('primary', 'replica1', 'replica2')
    if obj1._state.db in db_list and obj2._state.db in db_list:
      return True
    return None
  def allow_migrate(self, db, app_label, model_name=None, **hints):
    """
    All non-auth models end up in this pool.
    """
    return True

移行操作は、デフォルトではデフォルトのデータベースで実行されます。他のデータベースで操作するには、--database オプションの後にデータベースのエイリアスを指定します。

同様に、dbshel​​l、dumpdata、loaddata コマンドにはすべて --database オプションが付いています。

ルートを手動で選択することもできます:

クエリ

:

DATABASE_ROUTERS = ['path.to.AuthRouter', 'path.to.PrimaryReplicaRouter']

保存したユーザー： rreee モバイル:

りー

上記のコードは、最初のデータベースに初めて p を保存するときに、デフォルトで主キーが生成され、2 番目のデータベースを使用して保存するときに、p はすでに主キーを持っています。キーを使用しなくても問題はありませんが、以前に使用されていた場合、元のデータは上書きされます。

解決策は 2 つあります:

1. 保存する前に主キーをクリアします:

$ ./manage.py migrate
$ ./manage.py migrate --database=users

2.force_insert を使用します

>>> # This will run on the 'default' database.
>>> Author.objects.all()
>>> # So will this.
>>> Author.objects.using('default').all() 
>>> # This will run on the 'other' database.
>>> Author.objects.using('other').all()

削除:

オブジェクト

がどのデータベースから取得され、どこから削除されたのか

>>> my_object.save(using='legacy_users')

オブジェクトを Legacy_users データベースから new_users データベースに転送したい場合:

>>> p = Person(name='Fred')
>>> p.save(using='first') # (statement 1)
>>> p.save(using='second') # (statement 2)

この記事の事例を読んだ後は、この方法を習得したと思います。さらに興味深い情報については、PHP 中国語に関する他の関連記事に注目してください。 Webサイト！

推奨読書:

WebStorm ES6 で babel を使用する方法

React を使用してコンポーネントを指定された DOM ノードにレンダリングする

以上がDjango の複数データベースを使用する手順の詳細な説明の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。