Peewee возвращает несколько объектов во внутреннем соединении

Question

class Parent(BaseModel): 
    name = peewee.CharField() 

class Child(BaseModel): 
    name = peewee.CharField() 
    parent = peewee.ForeignKeyField(Parent, related_name='children') 

parent = Parent.create(name="Parent1") 
child1 = Child.create(name="Child1", parent=parent) 
chilld2 = Child.create(name="Child2", parent=parent) 

query = (Parent.select() 
     .join(Child)) 

for p in query: 
    print p.name 
    for c in p.children: 
     print "\t",c.name 

Это приводит следующий вывод:

Parent1 
    Child1 
    Child2 
Parent1 
    Child1 
    Child2 

я ожидал:

Parent1 
    Child1 
    Child2 

Казалось бы, что я итерация через SQL результат в отличие от объекта в смысле ORM. Учитывая, что в запросе есть только один «родительский объект», с точки зрения ORM, как я могу изменить свой запрос или мою итерацию по запросу, чтобы получить ожидаемые результаты?

Я хочу вернуть запрос к моему шаблону, как в примере примера peewee, и просто перебрать его, чтобы отобразить объект, но если я это сделаю, он отобразит один и тот же объект дважды (или n раз для n числа связанных дети).

Я знаю, что я могу сделать следующее:

p = query.get() 
print p.name 
for c in p.children: 
    print "\t", c.name 

Но когда у меня есть несколько родителей и просто хочу проходные их всех, я не могу определить, сколько родителей есть. Метод запроса count возвращает счетчик результирующего набора, в отличие от количества их родительских объектов.

Это также работа вокруг:

pars = [] 
for p in query: 
    if p not in pars: 
     pars.append(p) 

for p in pars: 
    print p.name 
    for c in p.children: 
     print "\t", c.name 

Answer 1

Есть две проблемы с вашим кодом.

Во-первых, хотя вы присоединились к Child, вызов parent.children выполнит дополнительный отдельный запрос.

Из-за первой проблемы вы ошибаетесь, что делает внешний цикл, который просто дает вам родительскую часть Parent1 + Child1, Parent1 + Child2.

Чтобы исправить это, вы можете сделать использование prefetch или aggregate_rows:

# Execute a single query and de-dupe the duplicated parent rows. 
query = Parent.select(Parent, Child).join(Child).aggregate_rows() 
for parent in query: 
    print parent.name 
    for child in parent.children: 
     print childname 

# Execute a query for each joined table. Generally more efficient 
# than aggregate_rows(). 
query = prefetch(Parent.select(), Child) 
for parent in query: 
    print parent.name 
    for child in parent.children_prefetch: # NOTE the `_prefetch` 
     print child.name 

Это документировано обширно: http://docs.peewee-orm.com/en/latest/peewee/querying.html#avoiding-n-1-queries