快捷導(dǎo)航

Django中使用 Closure Table 儲(chǔ)存無限分級(jí)數(shù)據(jù)

更新時(shí)間：2019年06月06日 14:20:52 作者：棲遲于一丘

對(duì)于數(shù)據(jù)量大的情況（比如用戶之間有邀請(qǐng)鏈，有點(diǎn)三級(jí)分銷的意思），就要用到 closure table 的結(jié)構(gòu)來進(jìn)行存儲(chǔ)。這篇文章主要介紹了Django中使用 Closure Table 儲(chǔ)存無限分級(jí)數(shù)據(jù),需要的朋友可以參考下

這篇文章給大家介紹Django中使用 Closure Table 儲(chǔ)存無限分級(jí)數(shù)據(jù)，具體內(nèi)容如下所述：

起步

對(duì)于數(shù)據(jù)量大的情況（比如用戶之間有邀請(qǐng)鏈，有點(diǎn)三級(jí)分銷的意思），就要用到 closure table 的結(jié)構(gòu)來進(jìn)行存儲(chǔ)。那么在 Django 中如何處理這個(gè)結(jié)構(gòu)的模型呢？

定義模型

至少是要兩個(gè)模型的，一個(gè)是存儲(chǔ)分類，一個(gè)儲(chǔ)存分類之間的關(guān)系：

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")

數(shù)據(jù)操作

獲得所有后代節(jié)點(diǎn)

class Category(models.Model):
 ...
 def get_descendants(self, include_self=False):
 """獲得所有后代節(jié)點(diǎn)"""
 kw = {
 'descendants__ancestor' : self
 }
 if not include_self:
 kw['descendants__distance__gt'] = 0
 qs = Category.objects.filter(**kw).order_by('descendants__distance')
 return qs獲得直屬下級(jí)
class Category(models.Model):
 ...
 def get_children(self):
 """獲得直屬下級(jí)"""
 qs = Category.objects.filter(descendants__ancestor=self, descendants__distance=1)
 return qs

節(jié)點(diǎn)的移動(dòng)

節(jié)點(diǎn)的移動(dòng)是比較難的，在 [ https://www.percona.com/blog/2011/02/14/moving-subtrees-in-closure-table/][1 ] 中講述了，利用django能夠執(zhí)行原生的sql語句進(jìn)行：

def add_child(self, child):
 """將某個(gè)分類加入本分類，"""
 if CategoryRelation.objects.filter(ancestor=child, descendant=self).exists() \
 or CategoryRelation.objects.filter(ancestor=self, descendant=child, distance=1).exists():
 """child不能是self的祖先節(jié)點(diǎn) or 它們已經(jīng)是父子節(jié)點(diǎn)"""
 return
 # 如果表中不存在節(jié)點(diǎn)自身數(shù)據(jù)
 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};
 """)

節(jié)點(diǎn)刪除

節(jié)點(diǎn)刪除有兩種操作，一個(gè)是將所有子節(jié)點(diǎn)也刪除，另一個(gè)是將自己點(diǎn)移到上級(jí)節(jié)點(diǎn)中。

擴(kuò)展閱讀

[ 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):
 """獲得所有后代節(jié)點(diǎn)"""
 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):
 """獲得直屬下級(jí)"""
 qs = Category.objects.filter(descendants__ancestor=self, descendants__distance=1)
 return qs
def get_ancestors(self, include_self=False):
 """獲得所有祖先節(jié)點(diǎn)"""
 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):
 """分類僅有一個(gè)父節(jié)點(diǎn)"""
 parent = Category.objects.get(ancestors__descendant=self, ancestors__distance=1)
 return parent
def get_parents(self):
 """分類僅有一個(gè)父節(jié)點(diǎn)"""
 qs = Category.objects.filter(ancestors__descendant=self, ancestors__distance=1)
 return qs
def remove(self, delete_subtree=False):
 """刪除節(jié)點(diǎn)"""
 if delete_subtree:
 # 刪除所有子節(jié)點(diǎn)
 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:
 # 所有子節(jié)點(diǎn)移到上級(jí)
 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):
 """將某個(gè)分類加入本分類，"""
 if CategoryRelation.objects.filter(ancestor=child, descendant=self).exists() \
 or CategoryRelation.objects.filter(ancestor=self, descendant=child, distance=1).exists():
 """child不能是self的祖先節(jié)點(diǎn) or 它們已經(jīng)是父子節(jié)點(diǎn)"""
 return
 # 如果表中不存在節(jié)點(diǎn)自身數(shù)據(jù)
 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

總結(jié)

以上所述是小編給大家介紹的Django中使用 Closure Table 儲(chǔ)存無限分級(jí)數(shù)據(jù)，希望對(duì)大家有所幫助，如果大家有任何疑問請(qǐng)給我留言，小編會(huì)及時(shí)回復(fù)大家的。在此也非常感謝大家對(duì)腳本之家網(wǎng)站的支持！

您可能感興趣的文章: