| 1896 | |
| 1897 | |
| 1898 | class RawSQLQuery(AwaitableQuery): |
| 1899 | __slots__ = ("_sql", "_db") |
| 1900 | |
| 1901 | def __init__(self, model: type[MODEL], db: BaseDBAsyncClient, sql: str) -> None: |
| 1902 | super().__init__(model) |
| 1903 | self._sql = sql |
| 1904 | self._db = db |
| 1905 | |
| 1906 | async def _execute(self) -> Any: |
| 1907 | instance_list = await self._db.executor_class( |
| 1908 | model=self.model, |
| 1909 | db=self._db, |
| 1910 | ).execute_select(RawSQL(self._sql).get_sql(self._db.query_class.SQL_CONTEXT), []) |
| 1911 | return instance_list |
| 1912 | |
| 1913 | def __await__(self) -> Generator[Any, None, list[MODEL]]: |
| 1914 | self._choose_db_if_not_chosen() |
| 1915 | return self._execute().__await__() |
| 1916 | |
| 1917 | |
| 1918 | class BulkUpdateQuery(UpdateQuery, Generic[MODEL]): |
no outgoing calls
no test coverage detected
searching dependent graphs…