Method raw_query

src/core/db/repository.py:382–387

(self, query: str, params: dict[str, Any] | None = None)

        return query

    async def raw_query(self, query: str, params: dict[str, Any] | None = None) -> Any:
        from sqlalchemy import text

        async with self.get_session() as session:
            result = await session.execute(text(query), params or {})
            return result

    @asynccontextmanager
    async def get_session(self):