chore: fix unit test

Signed-off-by: Kould <kould2333@gmail.com>

Author: KKould

src/query/service/tests/it/pipelines/filter/random_filter_expr.rs

@@ -147,6 +147,7 @@ fn convert_predicate_tree_to_scalar_expr(node: PredicateNode, data_type: &DataTy
                 table_name: None,
                 column_position: None,
                 table_index: None,
+                source_table_index: None,
                 column_name: "".to_string(),
                 index: 0,
                 data_type: Box::new(data_type.clone()),

src/query/sql/src/planner/optimizer/rule/rewrite/rule_subquery_not_in_to_in.rs

@@ -85,13 +85,14 @@ impl Rule for RuleSubqueryNotInToIn {
     ) -> databend_common_exception::Result<()> {
         let filter: Filter = s_expr.plan().clone().try_into()?;
         let mut join: Join = s_expr.children[0].plan().clone().try_into()?;
-
         let (ScalarExpr::FunctionCall(call), Some(mark_index)) =
             (&filter.predicates[0], join.marker_index)
         else {
             return Ok(());
         };
-        if call.func_name != "not"
+        // subquery only one eq condition(subquery child_expr = subquery output column)
+        if join.equi_conditions.len() != 1
+            || call.func_name != "not"
             || call.arguments.len() != 1
             || call.arguments[0]
                 .used_columns()
@@ -100,8 +101,6 @@ impl Rule for RuleSubqueryNotInToIn {
         {
             return Ok(());
         }
-        // subquery only one eq condition(subquery child_expr = subquery output column)
-        debug_assert!(join.equi_conditions.len() == 1);
 
         let condition = &join.equi_conditions[0];
         let ScalarExpr::BoundColumnRef(BoundColumnRef { column, .. }) = &condition.left else {

src/query/sql/tests/optimizer/filter/deduplicate_join_condition_test.rs

@@ -50,6 +50,7 @@ fn create_column_ref1(
         table_index,
         visibility: Visibility::Visible,
         virtual_expr: None,
+        source_table_index: None,
     };
     ScalarExpr::BoundColumnRef(BoundColumnRef { column, span: None })
 }

src/query/sql/tests/optimizer/filter/infer_filter_test.rs

@@ -42,6 +42,7 @@ fn create_column_ref(index: IndexType, name: &str, data_type: DataType) -> Scala
         table_index: None,
         visibility: Visibility::Visible,
         virtual_expr: None,
+        source_table_index: None,
     };
     ScalarExpr::BoundColumnRef(BoundColumnRef { column, span: None })
 }

src/query/sql/tests/optimizer/filter/normalize_disjunctive_filter_test.rs

@@ -76,6 +76,7 @@ fn create_bound_column_ref(
         table_index,
         visibility: Visibility::Visible,
         virtual_expr: None,
+        source_table_index: None,
     };
     ScalarExpr::BoundColumnRef(BoundColumnRef { column, span: None })
 }