fix:schema mismatch not detected while executing copy into (#13010)

* fix:schema mismatch not detected while executing copy into

* recover fix

* add fix t.* case

* Update 03_0028_copy_into_stage

* Update tests/sqllogictests/suites/base/03_common/03_0028_copy_into_stage

* Update tests/sqllogictests/suites/base/03_common/03_0028_copy_into_stage

---------

Co-authored-by: Yang Xiufeng <[email protected]>

Author: zenus

src/query/sql/src/planner/binder/copy.rs

@@ -213,7 +213,6 @@ impl<'a> Binder {
                     }
                     .into(),
                 );
-
                 let plan = CopyIntoTablePlan {
                     catalog_info,
                     database_name,
@@ -482,6 +481,15 @@ impl<'a> Binder {
             .await?;
         let (scalar_items, projections) =
             self.analyze_projection(&from_context.aggregate_info, &select_list)?;
+
+        if projections.len() != plan.required_source_schema.num_fields() {
+            return Err(ErrorCode::BadArguments(format!(
+                "Number of columns in select list ({}) does not match that of the corresponding table ({})",
+                projections.len(),
+                plan.required_source_schema.num_fields(),
+            )));
+        }
+
         let s_expr =
             self.bind_projection(&mut from_context, &projections, &scalar_items, s_expr)?;
         let mut output_context = BindContext::new();

tests/sqllogictests/suites/base/03_common/03_0028_copy_into_stage

@@ -37,4 +37,26 @@ statement ok
 drop stage test
 
 statement ok
-DROP DATABASE db1
+DROP STAGE IF EXISTS hello
+
+statement ok
+CREATE STAGE IF NOT EXISTS hello
+
+statement ok
+COPY INTO @hello from (select number from numbers(1)) FILE_FORMAT = (type = parquet)
+
+statement ok
+CREATE TABLE world(c1 int , c2 int);
+
+statement error (?s)1006.*Number of columns in select list \(1\) does not match that of the corresponding table \(2\)
+COPY INTO world FROM (select number  from @hello )   file_format = (type = PARQUET);
+
+statement ok
+DROP STAGE IF EXISTS hello
+
+statement ok
+drop table world 
+
+statement ok
+DROP DATABASE db1
+