python - 删除 SQLAlchemy Flask 中的项目列表

Question

我正在尝试以优雅的方式使用 Flask 和 SQLAchlemy 删除项目列表。在我的例子中，我想从我的数据库中删除旧项目(小于特定时间的项目被认为是旧的)。

这是我的 python 模型对象:

class ItemModel(db.Model):
    __tablename__ = 'items'

    id = db.Column(db.Integer, primary_key=True)
    name = db.Column(db.String(80))
    time = db.Column(db.Integer)

现在，我尝试使用以下 filter_by 查询删除项目:

def delete_from_db(self):
    db.session.query('items').filter_by(self.time <= epoch_time).delete()
    db.session.commit()

它最终给我错误:

filter_by() takes 1 positional argument but 2 were given

如果我尝试使用过滤器函数而不是 filter_by，我也会收到一个错误:

   def delete_from_db(self):
        db.session.query('items').filter(self.time <= epoch_time).delete()
        db.session.commit()

sqlalchemy.exc.InvalidRequestError: This operation requires only one Table or entity be specified as the target.

最后，我决定回到基础并使用 sql 代码，这行得通，但我认为它不是很优雅:

def delete_from_db(self):
    from sqlalchemy.sql import text
    cmd = 'delete from items where time <= :time'
    db.engine.execute(text(cmd), time = epoch_time)
    db.session.commit()

使用 Flask 和 SQLAchlemy 是否有更优雅的方法？

Answer 1

如果你想从模型中管理它，这应该使用类方法:

@classmethod
def delete_from_db(cls):
    cls.query.filter(cls.time <= epoch_time).delete()
    db.session.commit()

或者相同，也许更干净，使用静态方法:

@staticmethod
def delete_from_db():
    ItemModel.query.filter(ItemModel.time <= epoch_time).delete()
    db.session.commit()