Django ORM 聚合与分组查询实战指南

小岛来信

发布时间：2026-10-13 | 5人浏览过

原创

本文详细介绍Django ORM中的聚合查询与分组查询功能。通过aggregate()函数实现Avg、Sum等全局统计，返回字典结果；利用annotate()为QuerySet添加聚合字段，结合filter进行条件筛选。文章包含Publisher、Book、Author模型定义及具体代码示例，解析如何计算书籍价格统计及作者关联数量，帮助开发者高效处理数据库复杂查询。

Django ORM聚合与分组查询实战指南

首先定义数据模型，文件名为models.py。


from django.db import models 
# 出版社
class Publisher(models.Model):
  id = models.AutoField(primary_key=True)
  name = models.CharField(max_length=64, null=False, unique=True)
 
  def __str__(self):
    return "<Publisher object: {}>".format(self.name) 
 
# 书籍
class Book(models.Model):
  id = models.AutoField(primary_key=True)
  title = models.CharField(max_length=64, null=False, unique=True)
  price = models.DecimalField(max_digits=5, decimal_places=2, default=00.00) # 最长位数为 5，小数位数为 2，默认值为 00.00
  publisher = models.ForeignKey(to="Publisher", null=True) # 把 null 设置为 True
 
  def __str__(self):
    return "<Book object: {}>".format(self.title)
 
# 作者
class Author(models.Model):
  id = models.AutoField(primary_key=True)
  name = models.CharField(max_length=16, null=False, unique=True)
  book = models.ManyToManyField(to="Book") # 多对多关联 Book 表，ORM 会自动生成第 3 张表
 
  def __str__(self):
    return "<Author object: {}>".format(self.name)

在数据库中存在一个book表，其结构由后续代码定义。

接下来对书籍的price字段进行修改操作，以准备测试数据。

聚合查询aggregate详解

介绍聚合查询的基本概念。

使用aggregate()方法，该方法返回一个字典，其中包含聚合计算后的键值对。

字典中的键名由字段名和聚合函数名自动生成，用于标识具体的聚合值；键值则为实际计算得出的结果。

查看具体的实现代码，文件名为orm.py。


import os 
if __name__ == '__main__':
  # 加载 Django 项目的配置信息
  os.environ.setdefault("DJANGO_SETTINGS_MODULE", "mysite2.settings")
  # 导入 Django，并启动 Django 项目
  import django
  django.setup() 
  from app01 import models 
  # 聚合查询需要导入的函数
  from django.db.models import Avg, Sum, Max, Min, Count 
  # 计算所有书籍 price 的平均值
  avg_ret = models.Book.objects.all().aggregate(Avg("price"))
  print(avg_ret) 
  # 计算所有书籍 price 的总和
  sum_ret = models.Book.objects.all().aggregate(Sum("price"))
  print(sum_ret) 
  # 计算所有书籍 price 的最大值
  max_ret = models.Book.objects.all().aggregate(Max("price"))
  print(max_ret) 
  # 计算所有书籍 price 的最小值
  min_ret = models.Book.objects.all().aggregate(Min("price"))
  print(min_ret) 
  # 计算所有书籍 price 的个数
  count_ret = models.Book.objects.all().aggregate(Count("price"))
  print(count_ret)

执行上述代码后的运行结果展示。

需要注意的是，aggregate()返回的数据类型为字典。

分组查询annotate详解

介绍分组查询的相关概念。

查看分组查询的实现代码，文件名为orm.py。


import os 
if __name__ == '__main__':
  # 加载 Django 项目的配置信息
  os.environ.setdefault("DJANGO_SETTINGS_MODULE", "mysite2.settings")
  # 导入 Django，并启动 Django 项目
  import django
  django.setup() 
  from app01 import models 
  from django.db.models import Count 
  # 查询每一本书的作者个数
  ret = models.Book.objects.all().annotate(author_num=Count("author")) # 返回的是 book 对象，annotate(author_num) 相当于让 book 对象多了一个 author_num 字段
  print(ret)   
  for book in ret:
    print("书名：{}，作者数：{}".format(book.title, book.author_num))

执行分组查询代码后的运行结果展示。

调用book.annotate(author_num)时，相当于在Book对象中动态增加了一个author_num属性，但这并不会在底层数据库中创建新的物理字段。

查看进一步的操作代码，文件名为orm.py。


import os 
if __name__ == '__main__':
  # 加载 Django 项目的配置信息
  os.environ.setdefault("DJANGO_SETTINGS_MODULE", "mysite2.settings")
  # 导入 Django，并启动 Django 项目
  import django
  django.setup() 
  from app01 import models
  from django.db.models import Count 
  # 查询作者数大于 1 的书
  ret = models.Book.objects.all().annotate(author_num=Count("author")).filter(author_num__gt=1)
  print(ret)

执行该段代码后的运行结果展示。

查看更复杂的查询示例代码，文件名为orm.py。


import os 
if __name__ == '__main__':
  # 加载 Django 项目的配置信息
  os.environ.setdefault("DJANGO_SETTINGS_MODULE", "mysite2.settings")
  # 导入 Django，并启动 Django 项目
  import django
  django.setup() 
  from app01 import models 
  from django.db.models import Sum 
  # 查询各个作者出的书的总价格
  ret = models.Author.objects.all().annotate(price_sum=Sum("book__price")) # 获取所有 author 表数据并添加 price_sum 字段 
  for i in ret:
    print(i, i.name, i.price_sum) # 打印所有 author 对象、 author 的 name 字段、price_sum 字段 的数据
  # 打印 author 表的所有 id、name、price_sum 字段数据
  print(ret.values_list("id", "name", "price_sum"))

执行复杂查询代码后的运行结果展示。