django数据库分库

#coding=utf-8

DATABASES = {
    'default': {
        'ENGINE': 'django.db.backends.mysql', # Add 'postgresql_psycopg2', 'postgresql', 'mysql', 'sqlite3' or 'oracle'.

        'NAME': 'xxxx',                      # Or path to database file if using sqlite3.

        'USER': 'root',                      # Not used with sqlite3.

        'PASSWORD': '123456',                  # Not used with sqlite3.

        'HOST': '',                      # Set to empty string for localhost. Not used with sqlite3.

        'PORT': '3306',                      # Set to empty string for default. Not used with sqlite3.

        'OPTIONS': {  
                    'init_command': 'SET storage_engine=MyISAM',  
        },         
    },
    'analysis_db':{
        'ENGINE': 'django.db.backends.mysql',
        'NAME': 'analysis_qq',                      #分析相关的操作用这个库

        'HOST': '',
        'USER': 'root',
        'PASSWORD': '123456',
        'PORT':'3306',
        'OPTIONS':{
                    'init_command': 'SET storage_engine=MyISAM',
        },
    },
}
class MasterSlaveRouter(object):
    def db_for_read(self, model, **hints):
        if model._meta.app_label == 'analysisqq':
            return 'analysis_db'
        else:
            return 'default'
    def db_for_write(self, model, **hints):
        if model._meta.app_label == 'analysisqq':
            return 'analysis_db'
        else:
            return 'default'
    def allow_relation(self, obj1, obj2, **hints):
        db_list = ('default','analysis_db',)
        if obj1._state.db in db_list and obj2._state.db in db_list:
            return True
        return None
    def allow_syncdb(self, db, model):
        if db == 'analysis_db':
            print " in analysis db"
            return True
        elif db == 'default':
            return False
        else:
            return None
DATABASE_ROUTERS = ['db_router.MasterSlaveRouter']