Fix commit 122fa953

h2/src/docsrc/html/changelog.html

@@ -23,6 +23,8 @@ Change Log
 <ul>
 <li>Issue #1604: TestCrashAPI: PreparedStatement.getGeneratedKeys() is already closed
 </li>
+<li>PR #1667: Detect NULL values and overflow in window frame bounds
+</li>
 <li>PR #1664: Allow any expressions in window frames
 </li>
 <li>Issue #1576: H2 Console should not display precision and scale for data types that don't have them

h2/src/main/org/h2/expression/analysis/WindowFrame.java

@@ -323,7 +323,12 @@ public final class WindowFrame {
         Value[] row = orderedRows.get(currentRow);
         Value currentValue = row[sortIndex];
         int type = currentValue.getType();
+        Value newValue;
+        Value range = getValueOffset(bound, orderedRows.get(currentRow), session);
         switch (type) {
+        case Value.NULL:
+            newValue = ValueNull.INSTANCE;
+            break;
         case Value.BYTE:
         case Value.SHORT:
         case Value.INT:
@@ -348,13 +353,8 @@ public final class WindowFrame {
         case Value.INTERVAL_HOUR_TO_MINUTE:
         case Value.INTERVAL_HOUR_TO_SECOND:
         case Value.INTERVAL_MINUTE_TO_SECOND:
-            break;
-        default:
-            throw DbException.getInvalidValueException("ORDER BY value for RANGE frame", currentValue.getTraceSQL());
-        }
-        Value range = getValueOffset(bound, orderedRows.get(currentRow), session);
-        OpType opType = add ^ (sortOrder.getSortTypes()[0] & SortOrder.DESCENDING) != 0 ? OpType.PLUS : OpType.MINUS;
-        Value newValue;
+            OpType opType = add ^ (sortOrder.getSortTypes()[0] & SortOrder.DESCENDING) != 0 ? OpType.PLUS
+                    : OpType.MINUS;
             try {
                 newValue = new BinaryOperation(opType, ValueExpression.get(currentValue), ValueExpression.get(range))
                         .optimize(session).getValue(session).convertTo(type);
@@ -366,6 +366,10 @@ public final class WindowFrame {
                 }
                 throw ex;
             }
+            break;
+        default:
+            throw DbException.getInvalidValueException("ORDER BY value for RANGE frame", currentValue.getTraceSQL());
+        }
         Value[] newRow = row.clone();
         newRow[sortIndex] = newValue;
         return newRow;

h2/src/test/org/h2/test/scripts/window.sql

@@ -115,8 +115,77 @@ SELECT SUM(ID) OVER (ORDER BY ID ROWS NULL PRECEDING) P FROM TEST;
 SELECT SUM(ID) OVER (ORDER BY ID RANGE NULL PRECEDING) P FROM TEST;
 > exception INVALID_VALUE_2
 
-SELECT SUM(V) OVER (ORDER BY V RANGE BETWEEN 1 PRECEDING AND 1 FOLLOWING) FROM VALUES (1), (NULL), (2) T(V);
-> exception INVALID_VALUE_2
+SELECT ARRAY_AGG(ID) OVER (ORDER BY V NULLS FIRST RANGE BETWEEN 1 PRECEDING AND UNBOUNDED FOLLOWING) A,
+    ID, V FROM VALUES (1, 1), (2, NULL), (3, 2) T(ID, V) ORDER BY V NULLS FIRST;
+> A         ID V
+> --------- -- ----
+> [3, 1, 2] 2  null
+> [3, 1]    1  1
+> [3, 1]    3  2
+> rows (ordered): 3
+
+SELECT ARRAY_AGG(ID) OVER (ORDER BY V NULLS LAST RANGE BETWEEN 1 PRECEDING AND UNBOUNDED FOLLOWING) A,
+    ID, V FROM VALUES (1, 1), (2, NULL), (3, 2) T(ID, V) ORDER BY V NULLS LAST;
+> A         ID V
+> --------- -- ----
+> [2, 3, 1] 1  1
+> [2, 3, 1] 3  2
+> [2]       2  null
+> rows (ordered): 3
+
+SELECT ARRAY_AGG(ID) OVER (ORDER BY V NULLS FIRST RANGE BETWEEN 1 FOLLOWING AND UNBOUNDED FOLLOWING) A,
+    ID, V FROM VALUES (1, 1), (2, NULL), (3, 2) T(ID, V) ORDER BY V NULLS FIRST;
+> A         ID V
+> --------- -- ----
+> [3, 1, 2] 2  null
+> [3]       1  1
+> null      3  2
+> rows (ordered): 3
+
+SELECT ARRAY_AGG(ID) OVER (ORDER BY V NULLS LAST RANGE BETWEEN 1 FOLLOWING AND UNBOUNDED FOLLOWING) A,
+    ID, V FROM VALUES (1, 1), (2, NULL), (3, 2) T(ID, V) ORDER BY V NULLS LAST;
+> A      ID V
+> ------ -- ----
+> [2, 3] 1  1
+> [2]    3  2
+> [2]    2  null
+> rows (ordered): 3
+
+SELECT ARRAY_AGG(ID) OVER (ORDER BY V NULLS FIRST RANGE BETWEEN UNBOUNDED PRECEDING AND 1 FOLLOWING) A,
+    ID, V FROM VALUES (1, 1), (2, NULL), (3, 2) T(ID, V) ORDER BY V NULLS FIRST;
+> A         ID V
+> --------- -- ----
+> [2]       2  null
+> [2, 1, 3] 1  1
+> [2, 1, 3] 3  2
+> rows (ordered): 3
+
+SELECT ARRAY_AGG(ID) OVER (ORDER BY V NULLS LAST RANGE BETWEEN UNBOUNDED PRECEDING AND 1 FOLLOWING) A,
+    ID, V FROM VALUES (1, 1), (2, NULL), (3, 2) T(ID, V) ORDER BY V NULLS LAST;
+> A         ID V
+> --------- -- ----
+> [1, 3]    1  1
+> [1, 3]    3  2
+> [1, 3, 2] 2  null
+> rows (ordered): 3
+
+SELECT ARRAY_AGG(ID) OVER (ORDER BY V NULLS FIRST RANGE BETWEEN UNBOUNDED PRECEDING AND 1 PRECEDING) A,
+    ID, V FROM VALUES (1, 1), (2, NULL), (3, 2) T(ID, V) ORDER BY V NULLS FIRST;
+> A      ID V
+> ------ -- ----
+> [2]    2  null
+> [2]    1  1
+> [2, 1] 3  2
+> rows (ordered): 3
+
+SELECT ARRAY_AGG(ID) OVER (ORDER BY V NULLS LAST RANGE BETWEEN UNBOUNDED PRECEDING AND 1 PRECEDING) A,
+    ID, V FROM VALUES (1, 1), (2, NULL), (3, 2) T(ID, V) ORDER BY V NULLS LAST;
+> A         ID V
+> --------- -- ----
+> null      1  1
+> [1]       3  2
+> [1, 3, 2] 2  null
+> rows (ordered): 3
 
 SELECT SUM(V) OVER (ORDER BY V RANGE BETWEEN 1 PRECEDING AND 1 FOLLOWING) FROM VALUES (TRUE) T(V);
 > exception INVALID_VALUE_2