implement BaseQueryWrapper.prefetch_related
This commit is contained in:
parent
2ae30613dc
commit
3609420d8e
1 changed files with 22 additions and 4 deletions
|
@ -1,5 +1,7 @@
|
|||
from collections import deque
|
||||
|
||||
from django.db import models
|
||||
from django.db.models import Manager
|
||||
from django.db.models import Manager, Prefetch
|
||||
from django.db.models.fields.related_descriptors import ForwardManyToOneDescriptor
|
||||
|
||||
|
||||
|
@ -163,6 +165,8 @@ class ChangesQuerySet:
|
|||
|
||||
|
||||
class BaseQueryWrapper(BaseWrapper):
|
||||
_allowed_callables = ('_add_hints', '_next_is_sticky')
|
||||
|
||||
def __init__(self, changeset, obj, author=None, changes_qs=None):
|
||||
super().__init__(changeset, obj, author)
|
||||
if changes_qs is None:
|
||||
|
@ -183,8 +187,17 @@ class BaseQueryWrapper(BaseWrapper):
|
|||
def select_related(self, *args, **kwargs):
|
||||
return self._wrap_queryset(self._obj.select_related(*args, **kwargs))
|
||||
|
||||
def prefetch_related(self, *args, **kwargs):
|
||||
return self._wrap_queryset(self._obj.prefetch_related(*args, **kwargs))
|
||||
def prefetch_related(self, *lookups):
|
||||
new_lookups = deque()
|
||||
for lookup in lookups:
|
||||
if not isinstance(lookup, str):
|
||||
new_lookups.append(lookup)
|
||||
continue
|
||||
model = self._obj.model
|
||||
for name in lookup.split('__'):
|
||||
model = model._meta.get_field(name).related_model
|
||||
new_lookups.append(Prefetch(lookup, self._wrap_model(model).objects.all()))
|
||||
return self._wrap_queryset(self._obj.prefetch_related(*new_lookups))
|
||||
|
||||
def get(self, **kwargs):
|
||||
return self._wrap_instance(self._obj.get(**kwargs))
|
||||
|
@ -212,6 +225,9 @@ class BaseQueryWrapper(BaseWrapper):
|
|||
first = self._wrap_instance(first)
|
||||
return first
|
||||
|
||||
def using(self, alias):
|
||||
return self._wrap_queryset(self._obj.using(alias))
|
||||
|
||||
def __iter__(self):
|
||||
return iter([instance for instance in self._obj])
|
||||
|
||||
|
@ -260,4 +276,6 @@ class ManyRelatedManagerWrapper(ManagerWrapper):
|
|||
|
||||
|
||||
class QuerySetWrapper(BaseQueryWrapper):
|
||||
pass
|
||||
@property
|
||||
def _iterable_class(self):
|
||||
return self._obj._iterable_class
|
||||
|
|
Loading…
Add table
Add a link
Reference in a new issue