当前位置:主页 > python教程 > Django中使用 Closure Table 储存无限分级数据

Django用Closure Table储存无限分级数据的实例方法

发布:2019-10-01 21:17:23 116


给大家整理了相关的编程文章,网友武经国根据主题投稿了本篇教程内容,涉及到django、Closure、Table、django分级数据、Django中使用 Closure Table 储存无限分级数据相关内容,已被381网友关注,涉猎到的知识点内容可以在下方电子书获得。

Django中使用 Closure Table 储存无限分级数据

Django中使用 Closure Table 储存无限分级数据

起步

上一篇讨论了如何用数据库存储无限分级的数据。对于数据量大的情况(比如用户之间有邀请链,有点三级分销的意思),就要用到 closure table 的结构来进行存储。那么在 Django 中如何处理这个结构的模型呢?

定义模型

至少是要两个模型的,一个是存储分类,一个储存分类之间的关系:

class Category(models.Model):
  name = models.CharField(max_length=31)
  def __str__(self):
    return self.name
class CategoryRelation(models.Model):
  ancestor = models.ForeignKey(Category, null=True, related_name='ancestors', on_delete=models.SET_NULL, db_constraint=False, verbose_name='祖先')
  descendant = models.ForeignKey(Category,null=True, related_name='descendants', on_delete=models.SET_NULL,
                  db_constraint=False, verbose_name='子孙')
  distance = models.IntegerField()
  class Meta:
    unique_together = ("ancestor", "descendant")

数据操作

获得所有后代节点

class Category(models.Model):
  ...
  def get_descendants(self, include_self=False):
    """获得所有后代节点"""
    kw = {
      'descendants__ancestor' : self
    }
    if not include_self:
      kw['descendants__distance__gt'] = 0
    qs = Category.objects.filter(**kw).order_by('descendants__distance')
    return qs获得直属下级
class Category(models.Model):
  ...
  def get_children(self):
    """获得直属下级"""
    qs = Category.objects.filter(descendants__ancestor=self, descendants__distance=1)
    return qs

节点的移动

节点的移动是比较难的,在 [ https://www.percona.com/blog/2011/02/14/moving-subtrees-in-closure-table/][1 ] 中讲述了,利用django能够执行原生的sql语句进行:

def add_child(self, child):
    """将某个分类加入本分类,"""
    if CategoryRelation.objects.filter(ancestor=child, descendant=self).exists() \
        or CategoryRelation.objects.filter(ancestor=self, descendant=child, distance=1).exists():
      """child不能是self的祖先节点 or 它们已经是父子节点"""
      return
    # 如果表中不存在节点自身数据
    if not CategoryRelation.objects.filter(ancestor=child, descendant=child).exists():
      CategoryRelation.objects.create(ancestor=child, descendant=child, distance=0)
    table_name = CategoryRelation._meta.db_table
    cursor = connection.cursor()
    cursor.execute(f"""
      DELETE a
      FROM
        {table_name} AS a
      JOIN {table_name} AS d ON a.descendant_id = d.descendant_id
      LEFT JOIN {table_name} AS x ON x.ancestor_id = d.ancestor_id
      AND x.descendant_id = a.ancestor_id
      WHERE
        d.ancestor_id = {child.id}
      AND x.ancestor_id IS NULL;
    """)
    cursor.execute(f"""
    INSERT INTO {table_name} (ancestor_id, descendant_id, distance)
    SELECT supertree.ancestor_id, subtree.descendant_id,
    supertree.distance+subtree.distance+1
    FROM {table_name} AS supertree JOIN {table_name} AS subtree
    WHERE subtree.ancestor_id = {child.id}
    AND supertree.descendant_id = {self.id};
    """)

 节点删除

节点删除有两种操作,一个是将所有子节点也删除,另一个是将自己点移到上级节点中。

扩展阅读

[ https://www.percona.com/blog/2011/02/14/moving-subtrees-in-closure-table/][2 ]
[ http://technobytz.com/closure_table_store_hierarchical_data.html][3 ]

完整代码

class Category(models.Model):
name = models.CharField(max_length=31)
def __str__(self):
  return self.name
def get_descendants(self, include_self=False):
  """获得所有后代节点"""
  kw = {
    'descendants__ancestor' : self
  }
  if not include_self:
    kw['descendants__distance__gt'] = 0
  qs = Category.objects.filter(**kw).order_by('descendants__distance')
  return qs
def get_children(self):
  """获得直属下级"""
  qs = Category.objects.filter(descendants__ancestor=self, descendants__distance=1)
  return qs
def get_ancestors(self, include_self=False):
  """获得所有祖先节点"""
  kw = {
    'ancestors__descendant': self
  }
  if not include_self:
    kw['ancestors__distance__gt'] = 0
  qs = Category.objects.filter(**kw).order_by('ancestors__distance')
  return qs
def get_parent(self):
  """分类仅有一个父节点"""
  parent = Category.objects.get(ancestors__descendant=self, ancestors__distance=1)
  return parent
def get_parents(self):
  """分类仅有一个父节点"""
  qs = Category.objects.filter(ancestors__descendant=self, ancestors__distance=1)
  return qs
def remove(self, delete_subtree=False):
  """删除节点"""
  if delete_subtree:
    # 删除所有子节点
    children_queryset = self.get_descendants(include_self=True)
    for child in children_queryset:
      CategoryRelation.objects.filter(Q(ancestor=child) | Q(descendant=child)).delete()
      child.delete()
  else:
    # 所有子节点移到上级
    parent = self.get_parent()
    children = self.get_children()
    for child in children:
      parent.add_chile(child)
    # CategoryRelation.objects.filter(descendant=self, distance=0).delete()
    CategoryRelation.objects.filter(Q(ancestor=self) | Q(descendant=self)).delete()
    self.delete()
def add_child(self, child):
  """将某个分类加入本分类,"""
  if CategoryRelation.objects.filter(ancestor=child, descendant=self).exists() \
      or CategoryRelation.objects.filter(ancestor=self, descendant=child, distance=1).exists():
    """child不能是self的祖先节点 or 它们已经是父子节点"""
    return
  # 如果表中不存在节点自身数据
  if not CategoryRelation.objects.filter(ancestor=child, descendant=child).exists():
    CategoryRelation.objects.create(ancestor=child, descendant=child, distance=0)
  table_name = CategoryRelation._meta.db_table
  cursor = connection.cursor()
  cursor.execute(f"""
    DELETE a
    FROM
      {table_name} AS a
    JOIN {table_name} AS d ON a.descendant_id = d.descendant_id
    LEFT JOIN {table_name} AS x ON x.ancestor_id = d.ancestor_id
    AND x.descendant_id = a.ancestor_id
    WHERE
      d.ancestor_id = {child.id}
    AND x.ancestor_id IS NULL;
  """)
  cursor.execute(f"""
  INSERT INTO {table_name} (ancestor_id, descendant_id, distance)
  SELECT supertree.ancestor_id, subtree.descendant_id,
  supertree.distance+subtree.distance+1
  FROM {table_name} AS supertree JOIN {table_name} AS subtree
  WHERE subtree.ancestor_id = {child.id}
  AND supertree.descendant_id = {self.id};
  """)class CategoryRelation(models.Model): ancestor = models.ForeignKey(Category, null=True, related_name='ancestors', on_delete=models.SET_NULL, db_constraint=False, verbose_name='祖先') descendant = models.ForeignKey(Category,null=True, related_name='descendants', on_delete=models.SET_NULL, db_constraint=False, verbose_name='子孙') distance = models.IntegerField()
class Meta:
  unique_together = ("ancestor", "descendant")[1]: https://www.percona.com/blog/2011/02/14/moving-subtrees-in-closure-table/
 [2]: https://www.percona.com/blog/2011/02/14/moving-subtrees-in-closure-table/
 [3]: http://technobytz.com/closure_table_store_hierarchical_data.html

总结

以上所述是小编给大家介绍的Django中使用 Closure Table 储存无限分级数据,希望对大家有所帮助,如果大家有任何疑问请给我留言,小编会及时回复大家的。在此也非常感谢大家对码农之家网站的支持!


参考资料

相关文章

  • 用celery执行Django串行异步任务的实例详解

    发布:2020-01-17

    这篇文章主要介绍了使用celery执行Django串行异步任务,文中通过示例代码介绍的非常详细,对大家学习或者使用Django具有一定的参考学习价值,需要的朋友们下面来一起学习学习吧


  • django框架CSRF防护原理及实例用法

    发布:2021-05-10

    这篇文章主要介绍了django框架CSRF防护原理与用法,结合实例形式分析了Django框架CSRF防护的概念、原理、使用方法及相关操作注意事项,需要的朋友可以参考下


  • Django项目搭建之实现简单的API访问

    发布:2023-04-05

    这篇文章主要给大家介绍了关于Django项目搭建之实现简单的API访问的相关资料,文中通过图文以及示例代码介绍的非常详细,对大家学习或者使用Django具有一定的参考学习价值,需要的朋友可以参考下


  • 基于pip install django失败时的解决方法

    发布:2022-04-07

    今天小编就为大家分享一篇基于pip install django失败时的解决方法,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧


  • 详解Java中的HashTable

    详解Java中的HashTable

    发布:2022-06-17

    给网友朋友们带来一篇关于Java的教程,这篇文章主要介绍了Java中的HashTable的相关资料,帮助大家更好的理解和使用Java,感兴趣的朋友可以了解下


  • vscode搭建之python Django环境配置方式

    发布:2023-04-25

    这篇文章主要介绍了vscode搭建之python Django环境配置方式,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教


  • bootstrap table用法详解

    发布:2020-07-08

    这篇文章主要为大家详细介绍了JS表格组件神器bootstrap table使用指南,具有一定的参考价值,感兴趣的小伙伴们可以参考一下


  • 深入理解Django中的Signal

    发布:2020-02-08

    这篇文章主要介绍了Django中的Signal代码详解,分享了相关代码示例,小编觉得还是挺不错的,具有一定借鉴价值,需要的朋友可以参考下


网友讨论