如何在Django中自动创建数据库视图实现用户类型CRUD接口？

我来分享几个优雅的自动化方案，完美解决你迁移时重复手动操作的问题——毕竟依赖特定数据库（比如PostgreSQL）完全没问题，Django给了我们足够的工具来搞定这个场景：

1. 用自定义迁移自动创建数据库对象（视图、函数、触发器） #

这是最核心的一步，把你之前手动执行的SQL逻辑整合到Django的迁移系统里，这样每次迁移项目时都会自动执行，再也不用手动跑SQL了。

步骤： #

• 先定义好你的Clients模型（保持managed=False）：

from django.db import models

class Clients(models.Model):
    id = models.IntegerField(primary_key=True)
    username = models.CharField(max_length=150)
    email = models.EmailField()
    # 其他你需要的字段

    class Meta:
        managed = False
        db_table = 'clients_view'  # 对应你要创建的视图名称

• 生成一个空的迁移文件：

python manage.py makemigrations --empty your_app_name

• 打开生成的迁移文件，用RunSQL操作添加创建视图、存储过程、触发器的SQL，同时别忘了写反向迁移的SQL（用于回滚）：

from django.db import migrations

class Migration(migrations.Migration):
    dependencies = [
        ('your_app_name', '0001_initial'),  # 替换成你实际的依赖迁移
    ]

    operations = [
        # 1. 创建clients视图
        migrations.RunSQL(
            sql="""
            CREATE VIEW clients_view AS
            SELECT u.id, u.username, u.email
            FROM auth_user u
            JOIN users_have_types uht ON u.id = uht.user_id
            JOIN user_types ut ON uht.type_id = ut.id
            WHERE ut.name = 'client';
            """,
            reverse_sql="DROP VIEW clients_view;"
        ),
        # 2. 创建自动关联client类型的存储过程
        migrations.RunSQL(
            sql="""
            CREATE OR REPLACE FUNCTION create_client(p_username VARCHAR(150), p_email VARCHAR(254))
            RETURNS INTEGER AS $$
            DECLARE
                v_user_id INTEGER;
                v_client_type_id INTEGER;
            BEGIN
                -- 创建User记录
                INSERT INTO auth_user(username, email, is_active, date_joined)
                VALUES (p_username, p_email, TRUE, NOW())
                RETURNING id INTO v_user_id;

                -- 获取或创建client类型
                SELECT id INTO v_client_type_id FROM user_types WHERE name = 'client';
                IF NOT FOUND THEN
                    INSERT INTO user_types(name) VALUES ('client') RETURNING id INTO v_client_type_id;
                END IF;

                -- 关联用户和client类型
                INSERT INTO users_have_types(user_id, type_id) VALUES (v_user_id, v_client_type_id);

                RETURN v_user_id;
            END;
            $$ LANGUAGE plpgsql;
            """,
            reverse_sql="DROP FUNCTION create_client(VARCHAR(150), VARCHAR(254));"
        ),
        # 3. 如果用物化视图需要触发器（普通视图不需要，因为是实时查询）
        # migrations.RunSQL(
        #     sql="""
        #     CREATE TRIGGER refresh_clients_mv
        #     AFTER INSERT OR UPDATE OR DELETE ON users_have_types
        #     FOR EACH STATEMENT
        #     EXECUTE FUNCTION refresh_materialized_view('clients_mv');
        #     """,
        #     reverse_sql="DROP TRIGGER refresh_clients_mv ON users_have_types;"
        # )
    ]

• 执行迁移：python manage.py migrate，数据库里的视图、函数就自动创建好了！

2. 自定义模型管理器封装CRUD逻辑 #

因为Clients模型是managed=False，默认的Django管理器没法直接处理增删改，所以自定义一个管理器，把调用存储过程/原生SQL的逻辑封装起来，让你用Django的语法操作Clients：

from django.db import models

class ClientManager(models.Manager):
    def create(self, **kwargs):
        # 调用上面创建的存储过程，自动创建用户并标记为client
        with self.db.connection.cursor() as cursor:
            cursor.execute(
                "SELECT create_client(%s, %s)",
                [kwargs['username'], kwargs['email']]
            )
            client_id = cursor.fetchone()[0]
        return self.get(pk=client_id)

    def update(self, instance, **kwargs):
        # 自定义更新逻辑，比如直接更新User表
        with self.db.connection.cursor() as cursor:
            cursor.execute(
                "UPDATE auth_user SET username=%s, email=%s WHERE id=%s",
                [kwargs['username'], kwargs['email'], instance.id]
            )
        return self.get(pk=instance.id)

class Clients(models.Model):
    id = models.IntegerField(primary_key=True)
    username = models.CharField(max_length=150)
    email = models.EmailField()

    objects = ClientManager()

    class Meta:
        managed = False
        db_table = 'clients_view'

现在你就可以像操作普通Django模型一样用Clients.objects.create(username="foo", email="foo@bar.com")了！

3. 结合Django信号处理用户类型关联（可选） #

如果你不想依赖数据库触发器，也可以在Django层面用信号实现“创建用户时自动标记为client”的逻辑，适合所有用户创建都通过Django接口的场景：

from django.db.models.signals import post_save
from django.dispatch import receiver
from django.contrib.auth.models import User
from .models import UserTypes, UsersHaveTypes

@receiver(post_save, sender=User)
def assign_client_type(sender, instance, created, **kwargs):
    if created:
        # 检查这个用户是不是通过Clients模型创建的（可选，根据你的业务逻辑调整）
        if hasattr(instance, 'client'):
            client_type, _ = UserTypes.objects.get_or_create(name='client')
            UsersHaveTypes.objects.create(user=instance, type=client_type)

方案选择建议 #

• 如果你的项目必须依赖特定数据库（比如PostgreSQL），优先选自定义迁移+RunSQL，这是最可靠的方式，确保数据库对象和代码同步。
• 如果需要让Clients模型的使用更贴近Django习惯，加上自定义模型管理器，封装原生SQL逻辑。
• 信号适合纯Django场景，减少数据库端的依赖，但如果有非Django方式修改数据库的情况，还是需要触发器来保证数据一致性。

内容的提问来源于stack exchange，提问作者Vladimir Oprya