如何通过python dict更新sqlalchemy orm对象

Question

dict的关键名称映射到sqlalchemy对象attrs

例如:

class User(Base):
    __tablename__ = 'users'

    id = Column(Integer, primary_key=True)
    name = Column(String)
    fullname = Column(String)
    password = Column(String)

可以从id = 3 {name: "diana"}或id = 15更新,{name: "marchel", fullname: "richie marchel"}

Answer 1

您可以使用setattr()动态更新现有SQLAlchemy对象的属性:

user = session.query(User).get(someid)

for key, value in yourdict.iteritems():
    setattr(user, key, value)

Answer 2

我这里有另一个解决方案.将模型方法定义如下是很方便的.

class ModelName(db.Model):
    """
    docstring here
    """
    ...

    def update(self, **kwargs):
        for key, value in kwargs.items():
            setattr(self, key, value)

我希望它能解决你的问题.

谢谢

Answer 3

根据@martijn-pieters 的回答，您不仅setattr可以使用 动态更新列，还可以使用动态表和列结合getattr和setattr

例子：

# models.py
class User(Base):
    __tablename__ = 'users'

    id = Column(Integer, primary_key=True)
    name = Column(String)
    fullname = Column(String)
    password = Column(String)

# update.py
import models

def dynamic_update(dynamic_table, col_id, dynamic_cols):
    """
    dynamic_table: name of the table, "User" for example
    col_id: id of which column you want to update
    dynamic_cols: key value pairs {name: "diana"}
    """
    if hasattr(models, dynamic_table):
        table = getattr(models, dynamic_table)
        col_info = table.query.filter_by(id=col_id).first()
        for (key, value) in dynamic_cols.items():
            if hasattr(table, key):
                setattr(col_info, key, value)
                session.commit()

顺便说一句，你可以得到更多的信息setattr，getattr，hasattr从蟒蛇官方文档 https://docs.python.org/2/library/functions.html#setattr

https://docs.python.org/2/library/functions.html#getattr

https://docs.python.org/2/library/functions.html#hasattr

Answer 4

根据您的用例（如果您不需要验证或推断模型中的任何内容），可以使用filter_bywith id来保存一个数据库调用，以获取特定的行，并使用字典（如您最初想要的那样）对其进行更新。

user_query = session.query(User).filter_by(id=someid)
data_to_update = dict(name="marchel", fullname="richie marchel")

user_query.update(data_to_update)

您可能还需要synchronize_session=False在update通话中添加关键字参数，具体取决于会话的类型（如果使用scoped_session）：

user_query.update(data_to_update, synchronize_session=False)