이번에는 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',
},
}
다음 효과를 얻고 싶다면:
app_label이 auth인 모델의 읽기 및 쓰기는 auth_db에서 완료되고, 나머지 모델 쓰기는 기본에서 완료되며, 읽기는 Replica1과 Replica2에서 무작위로 완료됩니다.
인증:
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이런 방식으로 app_label이 auth인 모델의 읽기 및 쓰기는 auth_db에서 완료되어 연결이 허용되고 마이그레이션은 auth_db 데이터베이스에서만 실행될 수 있습니다. 나머지:
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
이런 식으로 Replica1과 Replica2에서는 무작위로 읽기가 완료되고, 쓰기는 Primary를 사용합니다.
마지막으로 설정에서 설정하세요:
DATABASE_ROUTERS = ['path.to.AuthRouter', 'path.to.PrimaryReplicaRouter']그게 다야. 마이그레이션 작업을 수행하는 경우:
$ ./manage.py migrate $ ./manage.py migrate --database=users마이그레이션 작업은 기본적으로 기본 데이터베이스에서 작동합니다. 다른 데이터베이스에서 작동하려면 --database 옵션과 데이터베이스 별칭을 사용할 수 있습니다. 이에 따라 dbshell, dumpdata 및 loaddata 명령에는 모두 --database 옵션이 있습니다. 경로를 수동으로 선택할 수도 있습니다:
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를 첫 번째 데이터베이스에 처음 저장할 때 기본 키가 생성되므로 두 번째 데이터베이스를 사용하여 저장할 때 p에는 이미 기본 키가 있습니다. 키를 사용하지 않으면 문제가 발생하지 않지만, 이전에 사용한 적이 있으면 원본 데이터를 덮어쓰게 됩니다. 두 가지 솔루션이 있습니다. 1. 저장하기 전에 기본 키를 지우세요:
>>> p = Person(name='Fred') >>> p.save(using='first') >>> p.pk = None # Clear the primary key. >>> p.save(using='second') # Write a completely new object.2. force_insert
>>> 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')
이 기사의 사례를 읽은 후 방법을 마스터했다고 생각합니다. 더 흥미로운 정보를 보려면 PHP 중국어의 다른 관련 기사를 주의 깊게 살펴보시기 바랍니다. 웹사이트!
위 내용은 Django 다중 데이터베이스를 사용하는 단계에 대한 자세한 설명의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!