WIP.

Author: efritz

internal/execution/expressions/subquery.go

@@ -49,21 +49,21 @@ func (e existsSubqueryExpression) ValueFrom(ctx impls.Context, row rows.Row) (an
 	e.subquery.Serialize(w)
 	ctx.Log("%s", buf.String())
 
-	ctx.Log("Preparing subquery")
+	ctx.Log("Preparing subquery over %s", row)
 
-	s, err := e.subquery.Scanner(ctx)
+	s, err := e.subquery.Scanner(ctx.WithOuterRow(row))
 	if err != nil {
 		return nil, err
 	}
 
 	ctx.Log("Scanning subquery")
 
 	if _, err := s.Scan(); err != nil {
-		// if err != scan.ErrNoRows {
-		// 	return nil, err
-		// }
+		if err != scan.ErrNoRows {
+			return nil, err
+		}
 
-		// return false, err
+		return false, err
 	}
 
 	return true, nil

internal/execution/queries/query.go

@@ -44,6 +44,5 @@ func (q *NodeQuery) Execute(ctx impls.Context, w protocol.ResponseWriter) {
 }
 
 func Evaluate(ctx impls.Context, expr impls.Expression, row rows.Row) (any, error) {
-	ctx.Log("Evaluating expression %T over %v\n", expr, row)
 	return expr.ValueFrom(ctx, rows.CombineRows(row, ctx.OuterRow()))
 }