This commit is contained in:
yumoqing 2026-07-14 14:52:52 +08:00
parent ab3ff00753
commit e83fbd9931

View File

@ -205,10 +205,14 @@ class DBPools(EventDispatcher):
self.databases[name] = desc self.databases[name] = desc
async def getSqlor(self, name): async def getSqlor(self, name):
desc = self.databases.get(name) try:
sor = sqlorFactory(desc) desc = self.databases.get(name)
await sor.connect() sor = sqlorFactory(desc)
return sor await sor.connect()
return sor
except Exception as e:
exception(f'{name=}, {e}')
raise e
@asynccontextmanager @asynccontextmanager
async def sqlorContext(self, name): async def sqlorContext(self, name):