SQLAlchemy在Flask API中连接MySQL时未关闭连接

Question

我在flask中编写了一个API，它使用sqlalchemy来处理MySQL数据库。我不使用flask-sqlalchemy，因为我不喜欢这个模块强制你按照某种模式声明模型。

我遇到的问题是我的数据库连接没有关闭。表示连接的对象已经超出了作用域，所以我认为它已经被垃圾收集器回收了。我还明确调用了session的close()方法。尽管如此，在API调用返回响应后，连接仍然保持打开状态。

sqlsession.py: 这是我用于session的包装器。

class SqlSession:
    def __init__(self, conn=Constants.Sql):
        self.db = SqlSession.createEngine(conn)

        Session = sessionmaker(bind=self.db)
        self.session = Session()
    @staticmethod
    def createEngine(conn):
        return create_engine(conn.URI.format(user=conn.USER, password=conn.PASS, host=conn.HOST, port=conn.PORT, database=conn.DATABASE, poolclass=NullPool))

    def close(self):
        self.session.close()

flaskroutes.py: 这是一个实例，展示了flask应用程序实例化并使用包装对象的过程。请注意，在api调用的范围内开始实例化该对象，然后在结束时关闭会话，并且在响应返回后可能被垃圾回收。

def commands(self, deviceId):
    sqlSession = SqlSession(self.sessionType) <---

    commandsQueued = getCommands()
    jsonCommands = []
    for command in commandsQueued:
     jsonCommand = command.returnJsonObject()
     jsonCommands.append(jsonCommand)
     sqlSession.session.delete(command)
    sqlSession.session.commit()
    resp = jsonify({'commands': jsonCommands})
    sqlSession.close() <---  
    resp.status_code = 200
    return resp

我原本期望HTTP响应一旦完成，连接就会被清除，但实际上，这些连接最终停留在"SLEEP"状态（在MySQL命令行界面的'show processlist'中查看）。

- melchoir55

Answer 1

我最终使用了这篇SO帖子中的建议：如何关闭MySQL中的SQLAlchemy连接

我强烈建议任何遇到这个问题的人阅读那篇帖子。基本上，我在close方法中添加了一个dispose（）调用。这样做会导致整个连接被销毁，而关闭仅将连接返回到可用池中（但保持打开状态）。

def close(self):
    self.session.close()
    self.db.dispose()

这整个事情对我有点困惑，但至少现在我更了解连接池了。

- melchoir55

---

只是评论一下让您知道，3年后您对我有很大的帮助。 - Sam Hollenbach

和 @SamHollenbach 一样，这个对我帮助很大，多年后仍然受益。 - booky99

哇，这是一个巨大的实现漏洞。关闭应该意味着完成和离开。我已经试图弄清楚为什么我的数据库已经连续一周耗尽了连接。当考虑到推荐的“with maker as session”语法时，情况尤其糟糕。 - Robert Rapplean