(self, query: str)
| 60 | return str(self._connection.dialect) |
| 61 | |
| 62 | def execute(self, query: str) -> Any: |
| 63 | query_expr = self._connection.sql(query) |
| 64 | |
| 65 | sql_output_format = self.sql_output_format() |
| 66 | |
| 67 | return convert_to_output( |
| 68 | sql_output_format=sql_output_format, |
| 69 | to_polars=lambda: query_expr.to_polars(), |
| 70 | to_pandas=lambda: query_expr.to_pandas(), |
| 71 | to_native=lambda: query_expr, |
| 72 | ) |
| 73 | |
| 74 | @staticmethod |
| 75 | def is_compatible(var: Any) -> bool: |