day53 Django多表查询、务和锁

基于双下划线的跨表查询（join）

一对一

正向连表靠属性

查询旭东的家庭住址

ret = models.Author.objects.filter(name='旭东').values('ad__addr')
print(ret)

如果用SQL语句表示，应该是这个样子的：

select app01_authordetail.addr from app01_author inner join app01_authordetail on app01_author.ad_id = app01_authordetail.id where app01_author.name='旭东';

反向连表类名小写

ret = models.AuthorDetail.objects.filter(author__name='旭东').values('addr')
print(ret)

一对多

查询东京出版社出版了哪些书

如果直接使用SQL语句，应该写成：

select app01_book.title from app01_publish inner join app01_book on app01_publish.id = app01_book.publishs_id where app01_publish.name='东京出版社';

使用ORM，则写成这样：

ret = models.Publish.objects.filter(name='东京出版社').values('book__title')
print(ret)
ret = models.Book.objects.filter(publishs__name='东京出版社').values('title')
print(ret)

多对多

查询一下金龙2写了哪些书

ret = models.Book.objects.filter(authors__name='金龙2').values('title')
print(ret)

ret = models.Author.objects.filter(name='金龙2').values('book__title')
print(ret)

聚合查询

aggregate聚合查询,结果是普通字典,queryset的结束符
from django.db.models import Avg,Max,Min,Count,Sum

obj = models.Book.objects.all().aggregate(a=Max('price')) #{'price__avg': 200.0}
print(obj)
Book.objects.aggregate(Avg('price'), Max('price'), Min('price'))

分组查询

分组查询，写成SQL语句应该是：

group by app01_book.publishs_id

例如：找出每个出版社出版的书的最高价格

方式1

ret = models.Book.objects.values('publishs_id').annotate(m=Max('price'))
print(ret)

总结：values写在annotate前面，意思是以values括号内的字段作为分组的依据。annotate里面是你要做的统计结果。这样，返回结果为queryset类型数据，里面是字典：

{'publishs_id':1,'m':100}

方式2

ret = models.Publish.objects.annotate(m=Max('book__price')).values('m','name')
print(ret)

总结：annotate直接写在了objects后面，意思是按照前面表的所有的数据（默认是id值）作为分组依据。结果返回的是前面这个表的所有models对象（model对象中包含了每个对象自己的统计结果），再通过values来取值。取值时可以直接写字段和统计结果的别名，也是queryset类型，里面是字典：

{'m':100,'name':'东京出版社'}

查询每个作者的姓名以及出版的书的最高价格：

ret = models.Book.objects.values('authors__name','authors__id').annotate(m=Max('price'))  # group by authors__name,authors__id
print(ret)

ret = models.Author.objects.annotate(m=Max('book__price')).values('name','m')
print(ret)

F查询

F查询结果是本表中两个字段的比较之后的符合条件的结果集

查询一下点赞数大于评论数的所有书籍。

从前，我们也可以通过使用循环来找到：

list1 = []
books = models.Book.objects.all()
for i in books:
    if i.dianzan > i.comment:
        list1.append(i)

如果使用F查询，代码会更加简洁直观：

ret = models.Book.objects.filter(dianzan__gt=F('comment')).values('title')

ret = models.Book.objects.filter(dianzan__lt=F('comment')).values('title')
print(ret)

本表字段进行四则运算

models.Book.objects.all().update(
    price=F('price') + 20  # 支持四则运算
)

Q查询

Q查询用来进行逻辑运算，Q的连接符：

& -- and
| -- or
~ -- not，取反

查询一下点赞大于300或者价钱小于300的书

ret = models.Book.objects.filter(Q(dianzan__gt=300)|~Q(price__lt=500),xx='oo').values('title')

ret = models.Book.objects.filter(Q(dianzan__gt=300)).values('title')

ret = models.Book.objects.filter(Q(Q(dianzan__gt=300)|~Q(price__lt=500))&Q(xx='oo')).values('title')    # Q查询能够进行各种复杂条件的拼接
print(ret)

ORM执行原生SQL语句（了解）

方式1

ret = models.Book.objects.raw('select * from app01_book;')
for i in ret:
    print(i.title)
print(ret)

方式2 Django自带的连接通道（配置的pymysql）

from django.db import connection
import pymysql
conn = pymysq.connect()
cursor = connection.cursor()
cursor.execute('select * from app01_book;')
print(cursor.fetchall())

方式3 pymysql

conn = pymysql.connect(
    host='127.0.0.1',
    port=3306,
    user='root',
    password='123',
    database='orm02',
    charset='utf8',
)
cursor = conn.cursor(pymysql.cursors.DictCursor)
cursor.execute('select * from app01_book;')
print(cursor.fetchall())

Django外部脚本调用models数据库操作

import os

if __name__ == '__main__':
    os.environ.setdefault("DJANGO_SETTINGS_MODULE", "orm02.settings")
    import django
    django.setup()
    
	from app01 import models
    ret = models.Book.objects.all().values('title')
    print(ret)

ORM事务和锁

锁

我们可以这样给代码枷锁：

models.Book.objects.select_for_update().filter(id=1)

事务

方式1 全局配置

DATABASES = {
    'default': {
        'ENGINE': 'django.db.backends.mysql',
        'NAME': 'mxshop',
        'HOST': '127.0.0.1',
        'PORT': '3306',
        'USER': 'root',
        'PASSWORD': '123',
        "ATOMIC_REQUESTS": True, #全局开启事务，绑定的是http请求响应整个过程当中的sql
    }
}

方式2 视图函数加装饰器

from django.db import transaction
@transaction.atomic
def viewfunc(request):
    # This code executes inside a transaction.
    do_stuff()

方式3 上下文加装饰器

from django.db import transaction
def viewfunc(request):
    # This code executes in autocommit mode (Django's default).
    do_stuff()

    with transaction.atomic():   #保存点
        # This code executes inside a transaction.
        do_more_stuff()

    do_other_stuff()