Update tests

Author: pdelewski

platform/parsers/elastic_query_dsl/aggregation_parser_test.go

@@ -704,9 +704,9 @@ func Test_parseFieldFromScriptField(t *testing.T) {
 		expectedMatch   model.Expr
 		expectedSuccess bool
 	}{
-		{goodQueryMap("doc['field1'].value.getHour()"), model.NewFunction("toHour", model.NewColumnRef("field1")), true},
+		{goodQueryMap("doc['field1'].value.getHour()"), model.NewFunction(model.DateHourFunction, model.NewColumnRef("field1")), true},
 		{goodQueryMap("doc['field1'].value.getHour() + doc['field2'].value.getHour()"), nil, false},
-		{goodQueryMap("doc['field1'].value.hourOfDay"), model.NewFunction("toHour", model.NewColumnRef("field1")), true},
+		{goodQueryMap("doc['field1'].value.hourOfDay"), model.NewFunction(model.DateHourFunction, model.NewColumnRef("field1")), true},
 		{goodQueryMap("doc['field1'].value"), nil, false},
 		{goodQueryMap("value.getHour() + doc['field2'].value.getHour()"), nil, false},
 		{QueryMap{}, nil, false},

platform/testdata/opensearch-visualize/aggregation_requests.go

@@ -1342,8 +1342,8 @@ var AggregationTests = []testdata.AggregationTestCase{
 			}},
 		},
 		ExpectedPancakeSQL: `
-			SELECT maxOrNull(toHour("timestamp")) AS "metric__maxAgg_col_0",
-			  minOrNull(toHour("timestamp")) AS "metric__minAgg_col_0"
+			SELECT maxOrNull(__quesma_date_hour("timestamp")) AS "metric__maxAgg_col_0",
+			  minOrNull(__quesma_date_hour("timestamp")) AS "metric__minAgg_col_0"
 			FROM ` + TableName + ``,
 	},
 	{ // [9]
@@ -1457,9 +1457,9 @@ var AggregationTests = []testdata.AggregationTestCase{
 			}},
 		},
 		ExpectedPancakeSQL: `
-			SELECT toHour("timestamp") AS "aggr__2__key_0", count(*) AS "aggr__2__count"
+			SELECT __quesma_date_hour("timestamp") AS "aggr__2__key_0", count(*) AS "aggr__2__count"
 			FROM ` + TableName + `
-			GROUP BY toHour("timestamp") AS "aggr__2__key_0"
+			GROUP BY __quesma_date_hour("timestamp") AS "aggr__2__key_0"
 			ORDER BY "aggr__2__key_0" ASC`,
 	},
 }

platform/testdata/opensearch-visualize/pipeline_aggregation_requests.go

@@ -850,7 +850,7 @@ var PipelineAggregationTests = []testdata.AggregationTestCase{
 		ExpectedPancakeSQL: `
 			SELECT toInt64(toUnixTimestamp64Milli("timestamp") / 600000) AS "aggr__2__key_0",
 			  count(*) AS "aggr__2__count",
-			  sumOrNull(toHour("timestamp")) AS "metric__2__1-metric_col_0"
+			  sumOrNull(__quesma_date_hour("timestamp")) AS "metric__2__1-metric_col_0"
 			FROM __quesma_table_name
 			GROUP BY toInt64(toUnixTimestamp64Milli("timestamp") / 600000) AS "aggr__2__key_0"
 			ORDER BY "aggr__2__key_0" ASC`,
@@ -1726,7 +1726,7 @@ var PipelineAggregationTests = []testdata.AggregationTestCase{
 		ExpectedPancakeSQL: `
 			SELECT toInt64(toUnixTimestamp64Milli("timestamp") / 600000) AS "aggr__2__key_0",
 			  count(*) AS "aggr__2__count",
-			  sumOrNull(toHour("timestamp")) AS "metric__2__1-metric_col_0"
+			  sumOrNull(__quesma_date_hour("timestamp")) AS "metric__2__1-metric_col_0"
 			FROM __quesma_table_name
 			GROUP BY toInt64(toUnixTimestamp64Milli("timestamp") / 600000) AS "aggr__2__key_0"
 			ORDER BY "aggr__2__key_0" ASC`,