diff --git a/sqlmesh/core/engine_adapter/clickhouse.py b/sqlmesh/core/engine_adapter/clickhouse.py
index ccffe64118..84d6ad311e 100644
--- a/sqlmesh/core/engine_adapter/clickhouse.py
+++ b/sqlmesh/core/engine_adapter/clickhouse.py
@@ -112,8 +112,9 @@ def query_factory() -> Query:
                     storage_format=exp.var("MergeTree"),
                     **kwargs,
                 )
+                ordered_df = df[list(source_columns_to_types)]
 
-                self.cursor.client.insert_df(temp_table.sql(dialect=self.dialect), df=df)
+                self.cursor.client.insert_df(temp_table.sql(dialect=self.dialect), df=ordered_df)
 
             return exp.select(*self._casted_columns(target_columns_to_types, source_columns)).from_(
                 temp_table
diff --git a/tests/core/engine_adapter/integration/conftest.py b/tests/core/engine_adapter/integration/conftest.py
index eafdf2fe1d..30f934da63 100644
--- a/tests/core/engine_adapter/integration/conftest.py
+++ b/tests/core/engine_adapter/integration/conftest.py
@@ -148,7 +148,7 @@ def ctx_df(
     yield from create_test_context(*request.param)
 
 
-@pytest.fixture(params=list(generate_pytest_params(ENGINES, query=True, df=False)))
+@pytest.fixture(params=list(generate_pytest_params(ENGINES, query=True, df=True)))
 def ctx_query_and_df(
     request: FixtureRequest,
     create_test_context: t.Callable[[IntegrationTestEngine, str], t.Iterable[TestContext]],