Как сохранить объекты навалом с помощью django 1.6

Question

Я ищу способ обновления нескольких объектов более эффективно, чем вызов .save() на каждом из них.

У меня есть код, который использует .filter() для загрузки объектов. Затем он связывается с внешней службой, чтобы решить, что нужно делать с каждым объектом. Наконец, у меня есть список объектов с обновленными значениями, которые мне нужно сохранить.

Этот код работает, но слишком медленно:

for o in l: o.save() 

Поиск предложений, которые я до сих пор нашел .bulk_create() и .update()

bulk_create отлично работает для новых объектов. Но замена выше цикла на model.objects.bulk_create(l) дает IntegrityError: UNIQUE constraint failed:, вероятно, потому, что он пытается создавать новые объекты, а не обновлять существующие объекты.

Использование .update() также не применимо к моему прецеденту, так как оно обновит все объекты в наборе с тем же значением. В моем случае я вычислил другое значение для каждого из объектов, которые мне нужно сохранить.

Есть ли более быстрое решение, чем вызов .save() на каждый объект?

Answer 1

Вы можете попробовать установить флаг has_changed в объект при его изменении, а затем сохранить объекты, в которых has_changed имеет значение True.

Это связано с тем, что не все объекты всегда изменяются. Если все объекты всегда меняются, это не решение.

Answer 2

Django не может этого сделать, потому что (в общем) ваша база данных не может этого сделать. Нет единого оператора SQL для обновления разных строк с разными значениями. (Особые исключения, такие как использование CASE...WHEN, вряд ли помогут здесь.)

Если многие или большинство объектов были новыми, вы можете отслеживать, какие и создавать их с помощью bulk_create; в противном случае, итерация и выполнение save(), вероятно, лучший выбор.

Возможно, вы планируете распараллеливать процедуру с помощью потоков, особенно если существует значительная латентность, связанная с внешней службой.

Answer 3

Я нашел обходной путь:

class CASE(object): 
    def __init__(self, field_name, objects): 
     self.field_name = field_name 
     self.objects = objects 

    def __unicode__(self): return self 

    def as_sql(self, qn, connection): 
     sql = [ 'CASE id' ] 
     params = [] 
     for o in self.objects: 
      sql.append('WHEN %s THEN %s') 
      params.append(o.pk) 
      params.append(getattr(o, self.field_name)) 
     sql.append('ELSE') 
     sql.append(qn(self.field_name)) 
     sql.append('END') 
     return (' '.join(sql), params) 

model.objects.update(value=CASE('value', l)) 

Это не очень, но, насколько я могу судить, это действительно производит правильный и эффективный SQL до тех пор, как я просто обновление одного текстового поля.