天天看点

Django-Model进阶

Model中的字段field中的参数详解

https://www.cnblogs.com/wupeiqi/articles/6216618.html

http://www.cnblogs.com/yuanchenqi/articles/7570003.html

Model创建联合唯一主键

class User(models.Model):
    username = models.CharField(max_length=32,db_index=True)

    def __str__(self):
        return self.username

class Tag(models.Model):
    title = models.CharField(max_length=16)
    def __str__(self):
        return self.title
    m = models.ManyToManyField(
        to='User',
        through='UserToTag',  # 重要
        through_fields=['u','t']
    )
    使用ManyToManyField只能在第三张表中创建三列数据

class UserToTag(models.Model):
    # nid = models.AutoField(primary_key=True)
    u = models.ForeignKey(to='User')
    t = models.ForeignKey(to='Tag')
    ctime = models.DateField()
    class Meta:
        unique_together=[    # 重要
            ('u','t'),
        ]
           
注:through的作用是使用UserToTag作为第三张表
注:through_fields的作用是使用’u’,'t’作为2个关联表各自的外键
注:如果使用though联合第三张自定义表时,不能使用add remove clean等增删改,只能使用all ,filter进行查询

4.多对多的自关联

class User(models.Model):
    username = models.CharField(max_length=32,db_index=True)

    d = models.ManyToManyField('User',related_name='b')
    def __str__(self):
        return self.username
           

注:自关联的时候必须含有Related_name用于指定反向查询时候的别名

注:symmetrical字段的使用

symmetrical=None,           # 仅用于多对多自关联时,symmetrical用于指定内部是否创建反向操作的字段
                            # 做如下操作时,不同的symmetrical会有不同的可选字段
                                models.BB.objects.filter(...)

                                # 可选字段有:code, id, m1
                                    class BB(models.Model):

                                    code = models.CharField(max_length=12)
                                    m1 = models.ManyToManyField('self',symmetrical=True)

                                # 可选字段有: bb, code, id, m1
                                    class BB(models.Model):

                                    code = models.CharField(max_length=12)
                                    m1 = models.ManyToManyField('self',symmetrical=False)
           

补充:一对多的自关联-评论楼

创建数据库
    .related_name
    .related_query_name
    # 表和表之间可以自关联
        多对多自关联 --> 互粉     related_name
        一对多自关联 --> 评论楼   related_name
           
注:自关联的时候必须含有Related_name用于指定反向查询时候的别名

5.select_related 主动进行连表操作,提高性能

def select_related(self, *fields)
     性能相关:表之间进行join连表操作,一次性获取关联的数据。
     model.tb.objects.all().select_related()
     model.tb.objects.all().select_related('外键字段')
     model.tb.objects.all().select_related('外键字段__外键字段')model.tb.objects.all().select_related('外键字段','外键字段')
           

观看以下代码

models.py

class UserType(models.Model):
    title = models.CharField(max_length=32)

class Person(models.Model):
    user = models.CharField(max_length=32)
    ut = models.ForeignKey(UserType)
           

view.py

person_list = models.Person.objects.all()
    # select * from person left join usertype on person.ut_id = usertype.id
    for row in person_list:
        print(row.user,row.id,row.ut_id)
        # SQL请求
        print(row.ut.title) # 每次运行都会执行一次SQL操作

    v = models.Person.objects.all()
           
  • 使用select_related
person_list = models.Person.objects.all().select_related('ut','te')
    # select * from person left join usertype on person.ut_id = usertype.id
    for row in person_list:
        print(row.user,row.id,row.ut_id)
        # SQL请求
        print(row.ut.title) # 只会执行一次SQL操作
        print(row.te.title)


    v = models.Person.objects.all()
           
总结:当在QuerySet后加上select_related()方法后,会默认加上主表和外键表,因此以下调用外键字段操作外键对象时,只会执行一次SQL操作而不会反复执行

6.使用prefetch_related进行多表查询,提高性能(推荐)

用法同select_related

b. prefetch_related
            models.UserInfo.objects.prefetch_related('ut')
            # select * from userinfo where id < 20
            # 计算获取到的所有用户的用户类型ID [1,]
            # select * from usertype where id in [1,]
           
与select_related不同的是,他不会进行一次多表连接的查询SQL,而是执行2条SQL达到多表连接查询的效果,并将结果集放入内存,下次使用时不必再重复执行。
注:连表查询性能低 UserInfo,UserType,这也是为什么不推荐使用select_related的原因

7.Django的原生SQL的执行方式

有三种

  • 使用游标
# from django.db import connection, connections
    # cursor = connection.cursor()  # cursor = connections['default'].cursor()
    # cursor.execute("""SELECT * from auth_user where id = %s""", [1])
    # row = cursor.fetchone()
           
  • 使用extra
  • 使用raw
使用raw时,必须查询主键
def raw(self, raw_query, params=None, translations=None, using=None):
    # 执行原生SQL
    models.UserInfo.objects.raw('select * from userinfo')

    # 如果SQL是其他表时,必须将名字设置为当前UserInfo对象的主键列名
    models.UserInfo.objects.raw('select id as nid from 其他表')

    # 为原生SQL设置参数
    models.UserInfo.objects.raw('select id as nid from userinfo where nid>%s', params=[12,])

    # 将获取的到列名转换为指定列名
    name_map = {'first': 'first_name', 'last': 'last_name', 'bd': 'birth_date', 'pk': 'id'}
    Person.objects.raw('SELECT * FROM some_other_table', translations=name_map)

    # 指定数据库
    models.UserInfo.objects.raw('select * from userinfo', using="default")

    ################### 原生SQL ###################
    from django.db import connection, connections
    cursor = connection.cursor()  # cursor = connections['default'].cursor()
    cursor.execute("""SELECT * from auth_user where id = %s""", [1])
    row = cursor.fetchone() # fetchall()/fetchmany(..)
           

8.其他操作

  • distinct去重
def distinct(self, *field_names)
    # 用于distinct去重
    models.UserInfo.objects.values('nid').distinct()
    # select distinct nid from userinfo

    注:只有在PostgreSQL中才能使用distinct进行去重
           
.values(‘nid’).distinct()是对nid进行去重,
只有在PostgreSQL数据库中才需要在distinct()中加参数
  • reverse 倒序
def reverse(self):
    # 倒序
    models.UserInfo.objects.all().order_by('-nid').reverse()
    # 注:如果存在order_by,reverse则是倒序,如果多个排序则一一倒序
           
reverse是在order_by的基础上进行的倒序
  • extra 用于自定义where条件,或者进行子查询操作
def extra(self, select=None, where=None, params=None, tables=None, order_by=None, select_params=None)
    # 构造额外的查询条件或者映射,如:子查询

    Entry.objects.extra(select={'new_id': "select col from sometable where othercol > %s"}, select_params=(1,))
    Entry.objects.extra(where=['headline=%s'], params=['Lennon'])
    Entry.objects.extra(where=["foo='a' OR bar = 'a'", "baz = 'a'"])
    Entry.objects.extra(select={'new_id': "select id from tb where id > %s"}, select_params=(1,), order_by=['-nid'])
           
  • only和defer
  1. only 取select后的字段,与values不同的是取到的queryset集合中存放的是obj对象
def only(self, *fields):
    #仅取某个表中的数据
     models.UserInfo.objects.only('username','id')
     或
     models.UserInfo.objects.filter(...).only('username','id')
           

2.与only相反,排除这几个字段,其他字段全部要select

def defer(self, *fields):
    models.UserInfo.objects.defer('username','id')
    或
    models.UserInfo.objects.filter(...).defer('username','id')
    #映射中排除某列数据
           
  • using 指定连接的数据库
def using(self, alias):
     指定使用的数据库,参数为别名(setting中的设置)
           

其他

def get_or_create(self, defaults=None, **kwargs):
    # 如果存在,则获取,否则,创建
    # defaults 指定创建时,其他字段的值
    obj, created = models.UserInfo.objects.get_or_create(username='root1', defaults={'email': '1111111','u_id': 2, 't_id': 2})

def update_or_create(self, defaults=None, **kwargs):
    # 如果存在,则更新,否则,创建
    # defaults 指定创建时或更新时的其他字段
    obj, created = models.UserInfo.objects.update_or_create(username='root1', defaults={'email': '1111111','u_id': 2, 't_id': 1})
    
def dates(self, field_name, kind, order='ASC'):
    # 根据时间进行某一部分进行去重查找并截取指定内容
    # kind只能是:"year"(年), "month"(年-月), "day"(年-月-日)
    # order只能是:"ASC"  "DESC"
    # 并获取转换后的时间
        - year : 年-01-01
        - month: 年-月-01
        - day  : 年-月-日

    models.DatePlus.objects.dates('ctime','day','DESC')

def datetimes(self, field_name, kind, order='ASC', tzinfo=None):
    # 根据时间进行某一部分进行去重查找并截取指定内容,将时间转换为指定时区时间
    # kind只能是 "year", "month", "day", "hour", "minute", "second"
    # order只能是:"ASC"  "DESC"
    # tzinfo时区对象
    models.DDD.objects.datetimes('ctime','hour',tzinfo=pytz.UTC)
    models.DDD.objects.datetimes('ctime','hour',tzinfo=pytz.timezone('Asia/Shanghai'))

    """
    pip3 install pytz
    import pytz
    pytz.all_timezones
    pytz.timezone(‘Asia/Shanghai’)
    """

def none(self):
    # 空QuerySet对象
    
def bulk_create(self, objs, batch_size=None):
    # 批量插入
    # batch_size表示一次插入的个数
    objs = [
        models.DDD(name='r11'),
        models.DDD(name='r22')
    ]
    models.DDD.objects.bulk_create(objs, 10)
# 批量插入时,每一次batch_create执行一次commit事务操作,如果不填,那就是一次事务操作。