sqlalchemy 关闭所有连接

Question

我正在尝试使用 sqlalchemy 删除我的数据库：

def dropDb(self, dbName):
    self.closeConnection()
    self.selectDb(None)
    self.execute("drop database %s" % dbName)

def closeConnection(self):
    self._Session.close_all()
    self._engine.dispose()
    del self._Session
    del self._engine

我使用以下方法创建引擎：

sqlalchemy.create_engine(connection_string, poolclass = NullPool)

但我收到以下错误：

详细 ProgrammingError: (ProgrammingError) ('42000', '[42000] [Microsoft][ODBC SQL Server Driver][SQL Server]无法删除数据库 “test_db”，因为它当前正在使用中。 (3702) (SQLExecDirectW)') '删除数据库 test_db' ()

如何强制关闭所有连接？

Answer 1

The current method 用于使用 SQLAlchemy 会话 api 关闭所有连接

from sqlalchemy.orm import close_all_sessions

close_all_sessions()

session.close_all() 已弃用。