关闭数据库连接池
(self)
| 221 | self._config_cache = {} |
| 222 | |
| 223 | async def close(self) -> None: |
| 224 | """关闭数据库连接池""" |
| 225 | if self._pool: |
| 226 | await self._pool.close() |
| 227 | self._pool = None |
| 228 | self._initialized = False |
| 229 | log.debug("PostgreSQL storage closed") |
| 230 | |
| 231 | def _ensure_initialized(self) -> None: |
| 232 | if not self._initialized or not self._pool: |
no test coverage detected