Update time functions

Author: pdelewski

platform/frontend_connectors/schema_transformer.go

@@ -912,10 +912,14 @@ func (s *SchemaCheckPass) convertQueryDateTimeFunctionToClickhouse(indexSchema s
 			}
 			return model.NewFunction("toHour", e.Args[0].Accept(b).(model.Expr))
 
-		case model.FromUnixTimeFunction:
+		case model.FromUnixTimeFunction64mili:
 			args := b.VisitChildren(e.Args)
 			return model.NewFunction("fromUnixTimestamp64Milli", args...)
 
+		case model.FromUnixTimeFunction:
+			args := b.VisitChildren(e.Args)
+			return model.NewFunction("fromUnixTimestamp", args...)
+
 		default:
 			return visitFunction(b, e)
 		}
@@ -946,6 +950,9 @@ func (s *SchemaCheckPass) convertQueryDateTimeFunctionToDoris(indexSchema schema
 			args := b.VisitChildren(e.Args)
 			return model.NewFunction("FROM_UNIXTIME", args...)
 
+		case model.FromUnixTimeFunction64mili:
+			args := b.VisitChildren(e.Args)
+			return model.NewFunction("FROM_MILLISECOND", args...)
 		default:
 			return visitFunction(b, e)
 		}

platform/model/constants.go

@@ -7,7 +7,8 @@ const (
 	FullTextFieldNamePlaceHolder = "__quesma_fulltext_field_name"
 	TimestampFieldName           = "@timestamp"
 
-	DateHourFunction     = "__quesma_date_hour"
-	MatchOperator        = "__quesma_match"
-	FromUnixTimeFunction = "__quesma_from_unixtime"
+	DateHourFunction           = "__quesma_date_hour"
+	MatchOperator              = "__quesma_match"
+	FromUnixTimeFunction       = "__quesma_from_unixtime"
+	FromUnixTimeFunction64mili = "__quesma_from_unixtime64mili"
 )

platform/parsers/elastic_query_dsl/dates.go

@@ -85,7 +85,7 @@ func (dm DateManager) ParseDateUsualFormat(exprFromRequest any, datetimeType dat
 		case database_common.DateTime64:
 			threeDigitsOfPrecisionSuffice := utcTs.UnixNano()%1_000_000 == 0
 			if threeDigitsOfPrecisionSuffice {
-				return model.NewFunction(model.FromUnixTimeFunction, addFormat(utcTs.UnixMilli())), true
+				return model.NewFunction(model.FromUnixTimeFunction64mili, addFormat(utcTs.UnixMilli())), true
 			} else {
 				return model.NewFunction(
 					"toDateTime64",
@@ -98,7 +98,7 @@ func (dm DateManager) ParseDateUsualFormat(exprFromRequest any, datetimeType dat
 				), true
 			}
 		case database_common.DateTime:
-			return model.NewFunction("fromUnixTimestamp", addFormat(utcTs.Unix())), true
+			return model.NewFunction(model.FromUnixTimeFunction, addFormat(utcTs.Unix())), true
 		default:
 			logger.WarnWithCtx(dm.ctx).Msgf("Unknown datetimeType: %v", datetimeType)
 		}