이번에는 Django 다중 데이터베이스 사용 단계에 대해 자세히 설명하겠습니다. Django 다중 데이터베이스 사용 시 주의사항은 무엇인가요?
1. 설정에서 DATABASE를 설정하세요
예를 들어 두 개의 데이터베이스를 사용하려는 경우:
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' } }
이러한 방식으로 두 개의 데이터베이스가 식별됩니다. 하나는 기본값 별칭이고 다른 하나는 별칭 사용자입니다. 데이터베이스 별명은 임의로 결정될 수 있습니다.
default의 별칭은 특별합니다. 경로에서 모델을 구체적으로 선택하지 않으면 기본적으로 기본 데이터베이스가 사용됩니다.
물론 기본값을 비어 있도록 설정할 수도 있습니다.
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.데이터베이스 라우터 쓰기
데이터베이스 라우터는 모델이 사용하는 데이터베이스를 결정하는 데 사용되며 주로 다음 네 가지 방법을 정의합니다.
db_for_read(모델, **힌트)
db_for_read(model, **hints)
规定model使用哪一个数据库读取。
db_for_write(model, **hints)
规定model使用哪一个数据库写入。
allow_relation(obj1, obj2, **hints)
确定obj1和obj2之间是否可以产生关联, 主要用于foreign key和 many to many操作。
allow_migrate(db, app_label, model_name=None, **hints)
db_for_write(모델, **힌트)
모델 작성에 사용할 데이터베이스를 지정합니다.
allow_relation(obj1, obj2, **힌트)
주로 외래 키 및 다대다 작업에 사용되는 obj1과 obj2를 연결할 수 있는지 여부를 결정합니다.
allow_ migration(db, app_label, model_name=None, **힌트)
데이터베이스 별명 db에서 마이그레이션 작업을 실행할 수 있는지 여부를 결정합니다.
완전한 예:
데이터베이스 설정:
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', }, }
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_ROUTERS = ['path.to.AuthRouter', 'path.to.PrimaryReplicaRouter']
$ ./manage.py migrate $ ./manage.py migrate --database=users
Query
:>>> # 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')
>>> p = Person(name='Fred') >>> p.save(using='first') # (statement 1) >>> p.save(using='second') # (statement 2)
>>> p = Person(name='Fred') >>> p.save(using='first') >>> p.pk = None # Clear the primary key. >>> p.save(using='second') # Write a completely new object.
>>> p = Person(name='Fred') >>> p.save(using='first') >>> p.save(using='second', force_insert=True)
어느 데이터베이스에서 object
를 얻었으며 어디서 삭제되었나요
>>> u = User.objects.using('legacy_users').get(username='fred') >>> u.delete() # will delete from the `legacy_users` database
Legacy_users 데이터베이스에서 new_users 데이터베이스로 개체를 전송하려는 경우: >>> user_obj.save(using='new_users')
>>> user_obj.delete(using='legacy_users')
위 내용은 Django 다중 데이터베이스를 사용하는 단계에 대한 자세한 설명의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!