使用对象属性的 SQLAlchemy 动态查询

Question

我正在寻找动态查询对象的属性。在这种情况下，我不知道我将在执行时使用哪个属性或列。

class Product(Base):
    __tablename__ = 'products'

    sku = Column(String, primary_key=True)
    list_price = Column(String)
    status = Column(String)
    url = Column(String)
    special_price1 = Column(String)
    special_price2 = Column(String)
    special_price3 = Column(String)

我有一个 SQLAlchemy 基类 Product，它描述了一些属性，以及与标价不同的其他特殊价格。

然后我在下面有一个PriceList 类，它可以访问有助于报告和更新'products' 表中的列的其他资源和方法。此类存储有关所有 Product 对象的唯一特价清单的信息。

class PriceList:

    def __init__(self, name, db_col_name):
        # Display name
        self.name = name

        # Used for querying the database for a specific column
        # This will always be one of the 4 price related column names
        # list_price, special_price1, special_price2, or special_price3
        self.db_col_name = db_col_name

我稍后开始迭代每个 Product 和 PriceList 实例。

for product in products:
    for price_list in price_lists:
        # Do stuff

此时我的product 对象有一个新的特价或多个新的特价，我计划在数据库中更新这些特价。我可以简单地将我的对象添加到数据库会话并提交，但我需要在我提交之前获取旧价格并将它们链接到各自的价目表。旧价格用于稍后通过电子邮件发送给我的报告中。我现在在做的是下面

for product in products:
    sku = product.sku
    for price_list in price_lists:
        # New price
        new_price = product.__getattribute__(price_list.db_col_name)

        # Get the existing special price from the database
        old_price = s.query(Product.__getattribute__(Product, price_list.db_col_name)).filter(Product.sku.like(sku)).first()

我觉得使用 __getattribute__() 让这件事变得过于复杂了。它有效，但这似乎不是pythonic。有谁知道在更新之前获取未知列值的更好方法？数据库更新每约 500 种产品只发生一次或两次，因此在处理每个特价时将它们存储在外部变量中并不是很有效。

Answer 1

要动态访问属性，您应该使用 getattr 内置函数。

new_price = getattr(product, price_list.db_col_name)

如果实例是陈旧的，你应该使用Session.expire，这意味着你下次访问属性时，它们将从数据库中检索出来。

s.expire(product)

# or only expire price
s.expire(product, [price_list.db_col_name])