async def manage(self):
cm = _ContextManager(self.database)<EOL>if isinstance(self.database.obj, AIODatabase):<EOL><INDENT>cm.connection = await self.database.async_connect()<EOL><DEDENT>else:<EOL><INDENT>cm.connection = self.database.connect()<EOL><DEDENT>return cm<EOL>
Manage a database connection.