OrderedDistinct passes join tree row during exec (#1700)

* OrderedDistinct passes join tree row during exec * float result
dolthub · Apr 7, 2023 · 76d35db · 76d35db
1 parent 4d14ac4
commit 76d35db
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 1 deletion.
diff --git a/enginetest/join_op_tests.go b/enginetest/join_op_tests.go
@@ -177,6 +177,16 @@ var joinOpTests = []struct {
 			setup.XyData[0],
 		},
 		tests: []JoinOpTests{
+			{
+				Query: `
+SELECT SUM(x) FROM xy WHERE x IN (
+  SELECT u FROM uv WHERE u IN (
+    SELECT a FROM ab WHERE a = 2
+    )
+  ) AND
+  x = 2;`,
+				Expected: []sql.Row{{float64(2)}},
+			},
 			{
 				Query:    "select * from ab left join uv on a = u where exists (select * from uv where false)",
 				Expected: []sql.Row{},

diff --git a/sql/plan/distinct.go b/sql/plan/distinct.go
@@ -169,7 +169,7 @@ func (d *OrderedDistinct) Resolved() bool {
 func (d *OrderedDistinct) RowIter(ctx *sql.Context, row sql.Row) (sql.RowIter, error) {
 	span, ctx := ctx.Span("plan.OrderedDistinct")
 
-	it, err := d.Child.RowIter(ctx, nil)
+	it, err := d.Child.RowIter(ctx, row)
 	if err != nil {
 		span.End()
 		return nil, err