SQLAlchemy 连接挂起

Question

def get_engine():
    engine = create_engine('mysql+mysqlconnector://...my_conn_string...', echo=True)
    return engine

def generic_execute(sql):
    db = get_engine()
    connection = db.connect()
    connection.execute(sql)

上面的代码正确执行了查询，但似乎无限挂起。

如何正确地连接"close"或"kill"这个连接？非常感谢！

Answer 1

正如您所说，需要关闭连接，如 documentation 所述。因此，在执行完 sql 查询后，您需要调用：

connection.close()

此外，如果您完成了引擎 db，您可以调用 db.dispose() 来清理所有内容。

SQLAlchemy 连接挂起

SQLAlchemy connection hangs

python

sqlalchemy