我在flask中编写了一个API,它使用sqlalchemy来处理MySQL数据库。我不使用flask-sqlalchemy,因为我不喜欢这个模块强制你按照某种模式声明模型。
我遇到的问题是我的数据库连接没有关闭。表示连接的对象已经超出了作用域,所以我认为它已经被垃圾收集器回收了。我还明确调用了session的close()方法。尽管如此,在API调用返回响应后,连接仍然保持打开状态。
sqlsession.py: 这是我用于session的包装器。
我遇到的问题是我的数据库连接没有关闭。表示连接的对象已经超出了作用域,所以我认为它已经被垃圾收集器回收了。我还明确调用了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'中查看)。