无需重启服务器，Django如何为各校动态创建数据库连接？

核心问题原因 #

Django启动时会加载settings.DATABASES中的配置并缓存连接实例，动态添加新数据库后如果不重置缓存，connections会找不到新配置，从而抛出ConnectionDoesNotExist错误。

具体实现步骤 #

1. 动态添加数据库配置到settings #

在创建学校数据库的逻辑中，完成数据库创建后，将新数据库的配置添加到settings.DATABASES，同时重置connections的缓存：

from django.conf import settings
from django.db import connections

# 假设从表单或学校信息中获取数据库别名
db_alias = "school_db_belle_rose"

# 添加数据库配置（根据你的数据库引擎调整参数）
settings.DATABASES[db_alias] = {
    "ENGINE": "django.db.backends.mysql",  # 或postgresql/sqlite3等
    "NAME": db_alias,
    "USER": "你的数据库用户名",
    "PASSWORD": "你的数据库密码",
    "HOST": "localhost",
    "PORT": "3306",
}

# 重置connections缓存，让Django识别新配置
connections._connections.pop(db_alias, None)  # 移除旧缓存（如果存在）
connections.ensure_defaults(db_alias)  # 初始化配置默认值
connections[db_alias]  # 预创建连接实例

2. 封装连接获取方法（推荐） #

为了避免重复代码，同时处理多进程场景下的配置同步，封装一个获取学校数据库连接的方法：

from django.conf import settings
from django.db import connections
from .models import School  # 主数据库中存储学校信息的模型

def get_school_db(school_db_alias):
    # 检查配置是否存在，不存在则从主数据库读取并添加
    if school_db_alias not in settings.DATABASES:
        school = School.objects.get(db_alias=school_db_alias)
        settings.DATABASES[school_db_alias] = {
            "ENGINE": school.db_engine,
            "NAME": school.db_alias,
            "USER": school.db_user,
            "PASSWORD": school.db_password,
            "HOST": school.db_host,
            "PORT": school.db_port,
        }
        # 重置缓存
        connections._connections.pop(school_db_alias, None)
        connections.ensure_defaults(school_db_alias)
    return connections[school_db_alias]

3. 使用动态连接操作数据 #

获取连接后，通过using()方法指定数据库操作模型，或直接使用游标：

# 操作模型示例
from .models.school_models import Student  # 学校数据库中的模型

# 使用封装的方法获取连接
school_db = get_school_db("school_db_belle_rose")
# 查询数据
students = Student.objects.using(school_db.alias).all()

# 游标操作示例
with school_db.cursor() as cursor:
    cursor.execute("SELECT COUNT(*) FROM student")
    count = cursor.fetchone()[0]

4. 完整视图示例（对应你的InscriptionEcole视图） #

from django.shortcuts import render, redirect
from django.conf import settings
from django.db import connections
from django.core.management import call_command
from .models import School

def InscriptionEcole(request):
    if request.method == "POST":
        school_name = request.POST.get("school_name")
        db_alias = f"school_db_{school_name.lower().replace(' ', '_')}"
        
        # 1. 创建数据库（以MySQL为例）
        with connections["default"].cursor() as cursor:
            cursor.execute(f"CREATE DATABASE IF NOT EXISTS {db_alias} CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci;")
        
        # 2. 添加数据库配置
        settings.DATABASES[db_alias] = {
            "ENGINE": "django.db.backends.mysql",
            "NAME": db_alias,
            "USER": "root",
            "PASSWORD": "你的密码",
            "HOST": "localhost",
            "PORT": "3306",
        }
        
        # 3. 初始化连接
        connections._connections.pop(db_alias, None)
        connections.ensure_defaults(db_alias)
        try:
            # 验证连接
            with connections[db_alias].cursor():
                pass
        except Exception as e:
            # 回滚数据库创建
            with connections["default"].cursor() as cursor:
                cursor.execute(f"DROP DATABASE IF EXISTS {db_alias};")
            return render(request, "inscription.html", {"error": f"数据库连接失败：{str(e)}"})
        
        # 4. 同步表结构（执行migrate）
        call_command("migrate", "--database", db_alias, "--noinput")
        
        # 5. 保存学校信息到主数据库
        School.objects.create(
            name=school_name,
            db_alias=db_alias,
            db_engine="django.db.backends.mysql",
            db_user="root",
            db_password="你的密码",
            db_host="localhost",
            db_port="3306"
        )
        
        return redirect("school_success")
    
    return render(request, "inscription.html")

注意事项 #

• 多进程服务器兼容：如果使用Gunicorn多worker或uWSGI多进程，每个worker的settings是独立的，必须从主数据库读取学校配置，不能依赖内存中的settings.DATABASES。
• 数据库权限：确保操作数据库的用户拥有创建数据库、执行migrate的权限。
• 连接池管理：大量学校可能导致数据库连接数超标，建议配置数据库连接池（如django-db-connection-pool）。
• 错误处理：添加连接和操作数据库时要捕获异常，避免因连接失败导致数据不一致。

内容的提问来源于stack exchange，提问作者Myveck Fernand PANGOU PABOCHA