Сбой массового обновления SQLAlchemy с AttributeError - PullRequest
Новая
       48

Сбой массового обновления SQLAlchemy с AttributeError

0 голосов
/ 13 июня 2018

Ниже приведены конфигурации моделей и отношений, которые у меня есть (не практический пример) 

class MyUser(Base):
    __tablename__ = 'my_user'
    id = Column(Integer, primary_key=True)
    name = Column(String)


class Address(Base):
    __tablename__ = 'address'
    id = Column(Integer, primary_key=True)
    email = Column(String)
    my_user = relationship("MyUser", backref="addresses", cascade='save-update, merge')
    _my_user_id = Column('my_user_id', Integer, ForeignKey('my_user.id'), nullable=True)


>>> user = db_session.query(User).get(6)
>>> add = models.Address(email='test2@test2.test2', my_user=user)
>>> db_session.add(add)
>>> db_session.commit()
>>> db_session.query(models.Address).filter_by(my_user=user).update(values=dict(email='test3@test3.test3'))
    Traceback (most recent call last):
      File "<stdin>", line 1, in <module>
      File "<hidden>/lib64/python3.6/site-packages/sqlalchemy/orm/query.py", line 3345, in update
        update_op.exec_()
      File "<hidden>/lib64/python3.6/site-packages/sqlalchemy/orm/persistence.py", line 1178, in exec_
        self._do_pre_synchronize()
      File "<hidden>/lib64/python3.6/site-packages/sqlalchemy/orm/persistence.py", line 1254, in _do_pre_synchronize
        query.session.identity_map.items()
      File "<hidden>/lib64/python3.6/site-packages/sqlalchemy/orm/persistence.py", line 1256, in <listcomp>
        eval_condition(obj)]
      File "<hidden>/lib64/python3.6/site-packages/sqlalchemy/orm/evaluator.py", line 109, in evaluate
        right_val = eval_right(obj)
      File "<hidden>/lib64/python3.6/site-packages/sqlalchemy/orm/evaluator.py", line 65, in <lambda>
        return lambda obj: get_corresponding_attr(obj)
    AttributeError: 'Address' object has no attribute 'my_user_id'

Это прекрасно работает, когда 

>>> db_session.query(models.Address).filter_by(my_user=user).update(values=dict(email='test3@test3.test3'), synchronize_session=False)
>>> db_session.query(models.Address).filter_by(_my_user_id=user.id).update(values=dict(email='test3@test3.test3'))

Даже после закрытия сессии 

>> db_session.close()
>>> db_session.query(models.Address).filter_by(my_user=user).update(values=dict(email='test3@test3.test3'))

Что-то не так с запросом на обновление?Почему это работает в других случаях?

1 Ответ

0 голосов
/ 13 июня 2018

Это проблема 3366 в SQLAlchemy <1.2.x, <a href="http://docs.sqlalchemy.org/en/latest/changelog/changelog_12.html#change-b1e620dece39006ab44c47044e9a6fee" rel="nofollow noreferrer"> исправлена ​​в серии 1.2.x :

Стратегия «оценки», используемаяQuery.update() и Query.delete() теперь могут выполнять простое сравнение объектов из отношения «многие к одному» с экземпляром, когда имена атрибутов столбцов первичного ключа / внешнего ключа не совпадают с фактическими именами столбцов.Ранее это делало бы простое сопоставление на основе имен и завершалось бы неудачей с AttributeError.

Самое простое решение - обновить или избежать использования стратегии «оценки» для синхронизации сеанса при выполнении массовых операций: 

db_session.query(models.Address).\
    filter_by(my_user=user).\
    update(values=dict(email='test3@test3.test3'),
           synchronize_session=False)
# ... or 'fetch'
...