adding dialect & handling temp views

Author: fresioAS

sqlmesh/core/config/connection.py

@@ -1587,22 +1587,28 @@ def _extra_engine_config(self) -> t.Dict[str, t.Any]:
         return {"catalog_support": CatalogSupport.SINGLE_CATALOG_ONLY}
 
 
-class FabricWarehouseConnectionConfig(MSSQLConnectionConfig):
+class FabricConnectionConfig(MSSQLConnectionConfig):
     """
-    Fabric Warehouse Connection Configuration. Inherits most settings from MSSQLConnectionConfig.
+    Fabric Connection Configuration.
+
+    Inherits most settings from MSSQLConnectionConfig and sets the type to 'fabric'.
+    It is recommended to use the 'pyodbc' driver for Fabric.
     """
 
-    type_: t.Literal["fabric_warehouse"] = Field(alias="type", default="fabric_warehouse")  # type: ignore
+    type_: t.Literal["fabric"] = Field(alias="type", default="fabric")
     autocommit: t.Optional[bool] = True
 
     @property
     def _engine_adapter(self) -> t.Type[EngineAdapter]:
-        from sqlmesh.core.engine_adapter.fabric_warehouse import FabricWarehouseAdapter
+        # This is the crucial link to the adapter you already created.
+        from sqlmesh.core.engine_adapter.fabric import FabricAdapter
 
-        return FabricWarehouseAdapter
+        return FabricAdapter
 
     @property
     def _extra_engine_config(self) -> t.Dict[str, t.Any]:
+        # This ensures the 'database' name from the config is passed
+        # to the FabricAdapter's constructor.
         return {
             "database": self.database,
             "catalog_support": CatalogSupport.REQUIRES_SET_CATALOG,

sqlmesh/core/engine_adapter/__init__.py

@@ -19,7 +19,7 @@
 from sqlmesh.core.engine_adapter.trino import TrinoEngineAdapter
 from sqlmesh.core.engine_adapter.athena import AthenaEngineAdapter
 from sqlmesh.core.engine_adapter.risingwave import RisingwaveEngineAdapter
-from sqlmesh.core.engine_adapter.fabric_warehouse import FabricWarehouseAdapter
+from sqlmesh.core.engine_adapter.fabric import FabricAdapter
 
 DIALECT_TO_ENGINE_ADAPTER = {
     "hive": SparkEngineAdapter,
@@ -36,7 +36,7 @@
     "trino": TrinoEngineAdapter,
     "athena": AthenaEngineAdapter,
     "risingwave": RisingwaveEngineAdapter,
-    "fabric_warehouse": FabricWarehouseAdapter,
+    "fabric": FabricAdapter,
 }
 
 DIALECT_ALIASES = {
@@ -47,9 +47,11 @@
 def create_engine_adapter(
     connection_factory: t.Callable[[], t.Any], dialect: str, **kwargs: t.Any
 ) -> EngineAdapter:
+    print(kwargs)
     dialect = dialect.lower()
     dialect = DIALECT_ALIASES.get(dialect, dialect)
     engine_adapter = DIALECT_TO_ENGINE_ADAPTER.get(dialect)
+    print(engine_adapter)
     if engine_adapter is None:
         return EngineAdapter(connection_factory, dialect, **kwargs)
     if engine_adapter is EngineAdapterWithIndexSupport: