Python SQLAlchemy - 更新子模型时更新父模型的时间戳

标签 python sqlalchemy foreign-key-relationship

我创建了两个模型,BasketBasketItem,如下所示。一个篮子可以有很多篮子项目,所以我使用外键来创建这种关系。

您可以看到 Basket 模型有一个 updated_at 字段,其中包含上次更新篮子的时间戳。我希望在添加、删除或更新 BasketItem 时更新此字段。

我添加了一个事件监听器,但我的解决方案似乎不是很优雅。有更好的方法吗?

class Basket(Base):
    __tablename__ = "baskets"

    id = Column(String(45), primary_key=True, default=uuid4)
    shop = Column(String(45), nullable=False)
    currency_code = Column(String(3), nullable=False)
    total = Column(String(15), nullable=False, default=0)
    status = Column(Enum("open", "closed"), nullable=False, default="open")
    created_at = Column(DateTime, default=datetime.datetime.utcnow)
    updated_at = Column(DateTime, default=datetime.datetime.now, onupdate=datetime.datetime.utcnow)

    items = relationship("BasketItem", backref="basket")


class BasketItem(Base):
    __tablename__ = "basket_items"

    basket_id = Column(String(45), ForeignKey('baskets.id'), primary_key=True)
    product_url = Column(String(90), nullable=False, primary_key=True)
    quantity = Column(Integer, nullable=False)

@event.listens_for(BasketItem, 'after_insert')
@event.listens_for(BasketItem, 'after_update')
@event.listens_for(BasketItem, 'after_delete')
def basket_item_change(mapper, connection, target):
    db_session = scoped_session(sessionmaker(autocommit=False, autoflush=False, bind=engine))
    basket = db_session.query(Basket).get(target.basket_id)
    basket.updated_at = datetime.datetime.utcnow()
    db_session.commit()

最佳答案

我认为使用事件监听器很好,但您可以执行以下操作。当您添加一个新的 basketitem 时,我确定您首先查询父项,然后将这个子项与该父项一起添加。如果是,那么:

basket = Basket.query.get(id)
if basket:
    basket.update()
    # you can perform delete or update too
    item = BasketItem(basket=basket, ...)
    db.session.add(item)
    db.session.commit()

class Basket(db.Model):
    ...
    def update(self):
        self.updated_at  = datetime.utcnow()
        db.session.add(self)
        db.session.commit()

关于Python SQLAlchemy - 更新子模型时更新父模型的时间戳,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/41779265/

相关文章:

python - Python 避免深度嵌套函数调用

python - 难以初始化 kivy 屏幕,TypeError : __init__() takes 1 positional argument but 2 were given

python - 为 windows 配置 sqlalchemy

ruby-on-rails - 为什么在多态关联中不能有外键?

php - 将一张表连接到多张表

python - 列表理解for循环+三元运算for循环?

python - SQLAlchemy 在 FlushError 后不会回滚

python - 如何在flask-sqlalchemy中插入重复数据。通过避免 SQL-ALCHEMY 完整性错误

python - Django:从父表到子表的外键

python - Keras导入报错Nadam