fix(query): fix join subquery scalar rewrite

sundy-li · sundy-li · commit 16330a37b79c · 2025-02-12T10:53:50.000+08:00
diff --git a/src/query/sql/src/planner/semantic/type_check.rs b/src/query/sql/src/planner/semantic/type_check.rs
@@ -3183,7 +3183,8 @@ impl<'a> TypeChecker<'a> {
                                     .contains(func.name.to_string());
                         }
                         fn enter_expr(&mut self, expr: &Expr) {
-                            self.contain_agg = matches!(expr, Expr::CountAll { window: None, .. });
+                            self.contain_agg = self.contain_agg
+                                || matches!(expr, Expr::CountAll { window: None, .. });
                         }
                     }
                     let mut visitor = AggFuncVisitor { contain_agg: false };

Original file line number	Diff line number	Diff line change
`@@ -3183,7 +3183,8 @@ impl<'a> TypeChecker<'a> {`
`3183`	`3183`	`.contains(func.name.to_string());`
`3184`	`3184`	`}`
`3185`	`3185`	`fn enter_expr(&mut self, expr: &Expr) {`
`3186`		`- self.contain_agg = matches!(expr, Expr::CountAll { window: None, .. });`
	`3186`	`+ self.contain_agg = self.contain_agg`
	`3187`	`+ \|\| matches!(expr, Expr::CountAll { window: None, .. });`
`3187`	`3188`	`}`
`3188`	`3189`	`}`
`3189`	`3190`	`let mut visitor = AggFuncVisitor { contain_agg: false };`