python - 异常处理程序不工作 : Commiting to SQL Database with SQLAlchemy in Python

Question

我正在尝试使用 Python 中的 SQLAlchemy 将条目提交到 MySQL 数据库。下面的函数旨在允许我提交一批条目，即使其中一两个条目包含数据库不接受的错误。但是，当它到达无法提交的条目时，它不会跳过该条目并转到下一个条目，而是尝试一遍又一遍地提交相同的条目，从而为该条目获取相同的错误消息一千次。为什么我的函数中的 trycatch 不起作用？

def commitentry(database, enginetext, verbose = False):
    """
    Takes a database object and text string that defines the SQL
    engine and adds all entries in the database list to the SQL
    database.
    """

    engine = create_engine(enginetext)
    Session = sessionmaker()
    Session.configure(bind=engine)
    session = Session()
    counter = 0
    for entry in database:
        try:
            session.add(entry)
            session.commit()

        except Exception, e:
            print("Commit Error")

            if verbose:
                print(e)

        finally:
            counter += 1
            if verbose:
                print(counter, counter/float(len(database)))

    if verbose:
        print("Entries saved!")
    session.close()

Answer 1

当提交失败时，它不会像成功提交那样从内存中删除对象。因此，当下一个对象添加到 session 中时，它并不孤单，刚刚失败的对象仍然存在。将 session.rollback() 添加到 except block 将从 session 中删除无法保存到数据库的对象，从而允许保存下一个对象。

def commitentry(database, enginetext, verbose = False):
    """
    Takes a database object and text string that defines the SQL
    engine and adds all entries in the database list to the SQL
    database.
    """

    engine = create_engine(enginetext)
    Session = sessionmaker()
    Session.configure(bind=engine)
    session = Session()
    counter = 0
    for entry in database:
        try:
            session.add(entry)
            session.commit()

        except Exception, e:
            print("Commit Error")
            session.rollback()


            if verbose:
                print(e)

        finally:
            counter += 1
            if verbose:
                print(counter, counter/float(len(database)))

    if verbose:
        print("Entries saved!")
    session.close()