重复相同的数据库查询将返回增量结果

Question

在长时间运行的 while 循环中，我正在尝试检查与我的标准匹配的第 1 条记录，以便对其执行操作。出于简单起见，查询的筛选器方面已从下面的代码中删除，无论哪种方式，我都会遇到相同的问题）。在下面的代码段中： while True:    time.sleep(2)    item = Session.query(Model).order_by(Model.id.asc()).first()    print(f'Item id: {item.id}')作为输出，我想实现的是：Item id: 1Item id: 1Item id: 1相反，我得到的是这个：Item id: 1Item id: 2Item id: 3我做错了什么？我不明白为什么当我甚至没有对表数据进行任何更新时，它会移动到NEXT记录。我甚至不确定在Google中搜索什么术语来尝试解决此问题...我尝试过在 上使用，但这似乎没有任何区别。flush()Session如果这很重要，这些是我正在使用的导入是：from flask import Flaskfrom sqlalchemy import create_enginefrom sqlalchemy.orm import scoped_sessionfrom sqlalchemy.orm import sessionmakerimport os, time, sys

Answer 1

好吧，虽然我还没有读到为什么它表现成这样，但至少现在我终于找到了解决问题需要做些什么：

一旦每次迭代中的查询都实现了其目的（在我的情况下，从需要处理的数据库中获取第一条记录，然后对其进行处理），我接下来需要调用以下内容：并解决了我的问题。session.expire_all()

因此，在我上面的示例中，它现在应该如下所示：

def main():

    while True:

        item = Session.query(Queue).order_by(Queue.id.asc()).filter_by(status=0).first()

        if item:

            try:

                item.status = 1

                Session.commit()

                print(f'Item id: {item.id}')

                Session.expire_all() # <---- Add this line

            except:

                print('error')

        time.sleep(2)

这是SQLAlchemy文档中大致指向这个方向的部分：SQLAlchemy - Refreshing / Expireing