Skip to content
This repository was archived by the owner on Nov 7, 2025. It is now read-only.

Commit 6fca39d

Browse files
committed
Adding fallback
1 parent 185c831 commit 6fca39d

File tree

1 file changed

+16
-9
lines changed

1 file changed

+16
-9
lines changed

platform/frontend_connectors/schema_transformer.go

Lines changed: 16 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -1146,22 +1146,29 @@ func (s *SchemaCheckPass) Transform(plan *model.ExecutionPlan) (*model.Execution
11461146
{TransformationName: "TimestampFieldTransformation", Transformation: s.applyTimestampField},
11471147
{TransformationName: "ApplySearchAfterParameter", Transformation: s.applySearchAfterParameter},
11481148
}
1149+
11491150
// Section 3: backend specific transformations
1150-
if plan.BackendConnector.GetId() == quesma_api.ClickHouseSQLBackend {
1151+
// fallback to clickhouse date functions if no backend connector is set
1152+
if plan.BackendConnector == nil {
11511153
transformationChain = append(transformationChain, struct {
11521154
TransformationName string
11531155
Transformation func(schema.Schema, *model.Query) (*model.Query, error)
11541156
}{TransformationName: "QuesmaDateFunctions", Transformation: s.convertQueryDateTimeFunctionToClickhouse})
1155-
}
1156-
1157-
if plan.BackendConnector.GetId() == quesma_api.DorisSQLBackend {
1158-
transformationChain = append(transformationChain, struct {
1159-
TransformationName string
1160-
Transformation func(schema.Schema, *model.Query) (*model.Query, error)
1161-
}{TransformationName: "QuesmaDateFunctions", Transformation: s.convertQueryDateTimeFunctionToDoris})
1157+
} else {
1158+
if plan.BackendConnector.GetId() == quesma_api.ClickHouseSQLBackend {
1159+
transformationChain = append(transformationChain, struct {
1160+
TransformationName string
1161+
Transformation func(schema.Schema, *model.Query) (*model.Query, error)
1162+
}{TransformationName: "QuesmaDateFunctions", Transformation: s.convertQueryDateTimeFunctionToClickhouse})
1163+
}
11621164

1165+
if plan.BackendConnector.GetId() == quesma_api.DorisSQLBackend {
1166+
transformationChain = append(transformationChain, struct {
1167+
TransformationName string
1168+
Transformation func(schema.Schema, *model.Query) (*model.Query, error)
1169+
}{TransformationName: "QuesmaDateFunctions", Transformation: s.convertQueryDateTimeFunctionToDoris})
1170+
}
11631171
}
1164-
11651172
transformationChain = append(transformationChain,
11661173
[]struct {
11671174
TransformationName string

0 commit comments

Comments
 (0)