chore: polish log for copy. (#15463)

* chore: add query_id in log.

* chore: polish log for copy.

Author: youngsofun

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

@@ -36,7 +36,6 @@ use databend_common_expression::Expr;
 use databend_common_functions::BUILTIN_FUNCTIONS;
 use databend_common_meta_app::principal::StageFileFormatType;
 use indexmap::IndexMap;
-use log::info;
 use log::warn;
 
 use super::Finder;
@@ -136,7 +135,10 @@ impl<'a> Binder {
         let mut init_bind_context = BindContext::new();
         let plan = self.bind_statement(&mut init_bind_context, stmt).await?;
         self.bind_query_index(&mut init_bind_context, &plan).await?;
-        info!("bind stmt to plan, time used: {:?}", start.elapsed());
+        self.ctx.set_status_info(&format!(
+            "bind stmt to plan done, time used: {:?}",
+            start.elapsed()
+        ));
         Ok(plan)
     }
 

src/query/sql/src/planner/plans/copy_into_table.rs

@@ -189,8 +189,10 @@ impl CopyIntoTablePlan {
                 return Err(ErrorCode::Internal(COPY_MAX_FILES_COMMIT_MSG));
             }
             info!(
-                "force mode, ignore file filtering. ({}.{})",
-                &self.database_name, &self.table_name
+                "{}: force mode, ignore file filtering. ({}.{})",
+                ctx.get_id(),
+                &self.database_name,
+                &self.table_name
             );
             (all_source_file_infos, vec![])
         } else {
@@ -225,11 +227,16 @@ impl CopyIntoTablePlan {
             (files_to_copy, duplicated_files)
         };
 
+        let len = need_copy_file_infos.len();
+        let sum: u64 = need_copy_file_infos.iter().map(|i| i.size).sum();
+
         info!(
-            "copy: read files with max_files={:?} finished, all:{}, need copy:{}, elapsed:{:?}",
+            "{}: collect files with max_files={:?} finished, need to copy {} files, {} bytes; skip {} duplicated files, time used:{:?}",
+            ctx.get_id(),
             max_files,
-            num_all_files,
             need_copy_file_infos.len(),
+            num_all_files - len,
+            sum,
             start.elapsed()
         );