",
- // very close to +292278994-08-17T07:12:55.807Z, the maximum supported millis since epoch
- () -> ESTestCase.randomLongBetween(Long.MAX_VALUE / 100 * 99, Long.MAX_VALUE),
- DataType.DATETIME
- )
- );
+ return dateCases(Long.MIN_VALUE, Long.MAX_VALUE);
+ }
+
+ /**
+ * Generate cases for {@link DataType#DATETIME}.
+ *
+ * For multi-row parameters, see {@link MultiRowTestCaseSupplier#dateCases}.
+ *
+ */
+ public static List dateCases(long min, long max) {
+ List cases = new ArrayList<>();
+ if (min <= 0 && max >= 0) {
+ cases.add(new TypedDataSupplier("<1970-01-01T00:00:00Z>", () -> 0L, DataType.DATETIME));
+ }
+
+ // 1970-01-01T00:00:00Z - 2286-11-20T17:46:40Z
+ long lower1 = Math.max(min, 0);
+ long upper1 = Math.min(max, 10 * (long) 10e11);
+ if (lower1 < upper1) {
+ cases.add(new TypedDataSupplier("", () -> ESTestCase.randomLongBetween(lower1, upper1), DataType.DATETIME));
+ }
+
+ // 2286-11-20T17:46:40Z - +292278994-08-17T07:12:55.807Z
+ long lower2 = Math.max(min, 10 * (long) 10e11);
+ long upper2 = Math.min(max, Long.MAX_VALUE);
+ if (lower2 < upper2) {
+ cases.add(new TypedDataSupplier("", () -> ESTestCase.randomLongBetween(lower2, upper2), DataType.DATETIME));
+ }
+
+ // very close to +292278994-08-17T07:12:55.807Z, the maximum supported millis since epoch
+ long lower3 = Math.max(min, Long.MAX_VALUE / 100 * 99);
+ long upper3 = Math.min(max, Long.MAX_VALUE);
+ if (lower3 < upper3) {
+ cases.add(
+ new TypedDataSupplier("", () -> ESTestCase.randomLongBetween(lower3, upper3), DataType.DATETIME)
+ );
+ }
+
+ return cases;
}
/**
diff --git a/x-pack/plugin/esql/src/test/java/org/elasticsearch/xpack/esql/expression/function/scalar/convert/ToDateNanosTests.java b/x-pack/plugin/esql/src/test/java/org/elasticsearch/xpack/esql/expression/function/scalar/convert/ToDateNanosTests.java
new file mode 100644
index 0000000000000..e91a5cc1ebca4
--- /dev/null
+++ b/x-pack/plugin/esql/src/test/java/org/elasticsearch/xpack/esql/expression/function/scalar/convert/ToDateNanosTests.java
@@ -0,0 +1,135 @@
+/*
+ * Copyright Elasticsearch B.V. and/or licensed to Elasticsearch B.V. under one
+ * or more contributor license agreements. Licensed under the Elastic License
+ * 2.0; you may not use this file except in compliance with the Elastic License
+ * 2.0.
+ */
+
+package org.elasticsearch.xpack.esql.expression.function.scalar.convert;
+
+import com.carrotsearch.randomizedtesting.annotations.Name;
+import com.carrotsearch.randomizedtesting.annotations.ParametersFactory;
+
+import org.elasticsearch.common.time.DateUtils;
+import org.elasticsearch.xpack.esql.core.expression.Expression;
+import org.elasticsearch.xpack.esql.core.tree.Source;
+import org.elasticsearch.xpack.esql.core.type.DataType;
+import org.elasticsearch.xpack.esql.expression.function.AbstractScalarFunctionTestCase;
+import org.elasticsearch.xpack.esql.expression.function.TestCaseSupplier;
+
+import java.math.BigInteger;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.function.Supplier;
+
+public class ToDateNanosTests extends AbstractScalarFunctionTestCase {
+ public ToDateNanosTests(@Name("TestCase") Supplier testCaseSupplier) {
+ this.testCase = testCaseSupplier.get();
+ }
+
+ @ParametersFactory
+ public static Iterable parameters() {
+ final String read = "Attribute[channel=0]";
+ final List suppliers = new ArrayList<>();
+
+ TestCaseSupplier.forUnaryDateNanos(suppliers, read, DataType.DATE_NANOS, DateUtils::toLong, List.of());
+ TestCaseSupplier.forUnaryDatetime(
+ suppliers,
+ "ToDateNanosFromDatetimeEvaluator[field=" + read + "]",
+ DataType.DATE_NANOS,
+ 0,
+ DateUtils.MAX_NANOSECOND_INSTANT.toEpochMilli(),
+ i -> DateUtils.toNanoSeconds(i.toEpochMilli()),
+ List.of()
+ );
+ TestCaseSupplier.forUnaryLong(
+ suppliers,
+ "ToDateNanosFromLongEvaluator[field=" + read + "]",
+ DataType.DATE_NANOS,
+ l -> l,
+ 0,
+ Long.MAX_VALUE,
+ List.of()
+ );
+ TestCaseSupplier.forUnaryLong(
+ suppliers,
+ "ToDateNanosFromLongEvaluator[field=" + read + "]",
+ DataType.DATE_NANOS,
+ l -> null,
+ Long.MIN_VALUE,
+ -1L,
+ List.of(
+ "Line -1:-1: evaluation of [] failed, treating result as null. Only first 20 failures recorded.",
+ "Line -1:-1: java.lang.IllegalArgumentException: Nanosecond dates before 1970-01-01T00:00:00.000Z are not supported."
+ )
+ );
+ TestCaseSupplier.forUnaryUnsignedLong(
+ suppliers,
+ "ToLongFromUnsignedLongEvaluator[field=" + read + "]",
+ DataType.DATE_NANOS,
+ BigInteger::longValueExact,
+ BigInteger.ZERO,
+ BigInteger.valueOf(Long.MAX_VALUE),
+ List.of()
+ );
+ TestCaseSupplier.forUnaryUnsignedLong(
+ suppliers,
+ "ToLongFromUnsignedLongEvaluator[field=" + read + "]",
+ DataType.DATE_NANOS,
+ bi -> null,
+ BigInteger.valueOf(Long.MAX_VALUE).add(BigInteger.TWO),
+ UNSIGNED_LONG_MAX,
+ bi -> List.of(
+ "Line -1:-1: evaluation of [] failed, treating result as null. Only first 20 failures recorded.",
+ "Line -1:-1: org.elasticsearch.xpack.esql.core.InvalidArgumentException: [" + bi + "] out of [long] range"
+ )
+ );
+ TestCaseSupplier.forUnaryDouble(
+ suppliers,
+ "ToDateNanosFromDoubleEvaluator[field=" + read + "]",
+ DataType.DATE_NANOS,
+ d -> null,
+ Double.NEGATIVE_INFINITY,
+ -Double.MIN_VALUE,
+ d -> List.of(
+ "Line -1:-1: evaluation of [] failed, treating result as null. Only first 20 failures recorded.",
+ "Line -1:-1: java.lang.IllegalArgumentException: Nanosecond dates before 1970-01-01T00:00:00.000Z are not supported."
+ )
+ );
+ TestCaseSupplier.forUnaryDouble(
+ suppliers,
+ "ToDateNanosFromDoubleEvaluator[field=" + read + "]",
+ DataType.DATE_NANOS,
+ d -> null,
+ 9.223372036854777E18, // a "convenient" value larger than `(double) Long.MAX_VALUE` (== ...776E18)
+ Double.POSITIVE_INFINITY,
+ d -> List.of(
+ "Line -1:-1: evaluation of [] failed, treating result as null. Only first 20 failures recorded.",
+ "Line -1:-1: org.elasticsearch.xpack.esql.core.InvalidArgumentException: [" + d + "] out of [long] range"
+ )
+ );
+ TestCaseSupplier.forUnaryStrings(
+ suppliers,
+ "ToDateNanosFromStringEvaluator[field=" + read + "]",
+ DataType.DATE_NANOS,
+ bytesRef -> null,
+ bytesRef -> List.of(
+ "Line -1:-1: evaluation of [] failed, treating result as null. Only first 20 failures recorded.",
+ "Line -1:-1: java.lang.IllegalArgumentException: "
+ + (bytesRef.utf8ToString().isEmpty()
+ ? "cannot parse empty datetime"
+ : ("failed to parse date field [" + bytesRef.utf8ToString() + "] with format [strict_date_optional_time_nanos]"))
+ )
+ );
+ return parameterSuppliersFromTypedDataWithDefaultChecks(
+ true,
+ suppliers,
+ (v, p) -> "date_nanos or datetime or double or long or string or unsigned_long"
+ );
+ }
+
+ @Override
+ protected Expression build(Source source, List args) {
+ return new ToDateNanos(source, args.get(0));
+ }
+}