Merge pull request #10658 from xinlifoobar/dev/xinli/select-list-stage

feat(query): list_stage table function.

Author: mergify[bot]

src/query/service/src/interpreters/access/management_mode_access.rs

@@ -47,6 +47,7 @@ impl AccessChecker for ManagementModeAccess {
                             | RewriteKind::ShowUsers
                             | RewriteKind::ShowStages
                             | RewriteKind::DescribeStage
+                            | RewriteKind::ListStage
                             | RewriteKind::ShowRoles),
                         _ => false
                     }
@@ -80,7 +81,6 @@ impl AccessChecker for ManagementModeAccess {
                 // Stage.
                 | Plan::CreateStage(_)
                 | Plan::DropStage(_)
-                | Plan::ListStage(_)
 
                 // UDF
                 | Plan::CreateUDF(_)

src/query/service/src/interpreters/access/privilege_access.rs

@@ -429,7 +429,6 @@ impl AccessChecker for PrivilegeAccess {
             | Plan::ShowCreateCatalog(_)
             | Plan::CreateCatalog(_)
             | Plan::DropCatalog(_)
-            | Plan::ListStage(_)
             | Plan::CreateStage(_)
             | Plan::DropStage(_)
             | Plan::RemoveStage(_)

src/query/service/src/interpreters/interpreter_factory.rs

@@ -259,7 +259,6 @@ impl InterpreterFactory {
             )?)),
 
             // Stages
-            Plan::ListStage(s) => Ok(Arc::new(ListInterpreter::try_create(ctx, *s.clone())?)),
             Plan::CreateStage(create_stage) => Ok(Arc::new(
                 CreateUserStageInterpreter::try_create(ctx, *create_stage.clone())?,
             )),

src/query/service/src/interpreters/interpreter_list.rs

@@ -35,7 +35,6 @@ mod interpreter_file_format_drop;
 mod interpreter_file_format_show;
 mod interpreter_insert;
 mod interpreter_kill;
-mod interpreter_list;
 mod interpreter_metrics;
 mod interpreter_presign;
 mod interpreter_privilege_grant;
@@ -108,7 +107,6 @@ pub use interpreter_explain::ExplainInterpreter;
 pub use interpreter_factory::InterpreterFactory;
 pub use interpreter_insert::InsertInterpreter;
 pub use interpreter_kill::KillInterpreter;
-pub use interpreter_list::ListInterpreter;
 pub use interpreter_metrics::InterpreterMetrics;
 pub use interpreter_privilege_grant::GrantPrivilegeInterpreter;
 pub use interpreter_privilege_revoke::RevokePrivilegeInterpreter;

src/query/service/src/interpreters/mod.rs

@@ -77,7 +77,6 @@ fn has_result_set_by_plan(plan: &Plan) -> bool {
             | Plan::ShowGrantTenantsOfShare(_)
             | Plan::DescribeTable(_)
             | Plan::ShowGrants(_)
-            | Plan::ListStage(_)
             | Plan::Presign(_)
     )
 }

src/query/service/src/servers/mysql/mysql_interactive_worker.rs

@@ -19,6 +19,8 @@ use common_catalog::plan::DataSourcePlan;
 use common_catalog::plan::PartStatistics;
 use common_catalog::plan::Partitions;
 use common_catalog::plan::PushDownInfo;
+use common_catalog::table::Table;
+use common_catalog::table_args::TableArgs;
 use common_exception::ErrorCode;
 use common_exception::Result;
 use common_expression::types::BooleanType;
@@ -47,9 +49,7 @@ use crate::pipelines::processors::port::OutputPort;
 use crate::pipelines::Pipeline;
 use crate::sessions::TableContext;
 use crate::table_functions::infer_schema::table_args::InferSchemaArgsParsed;
-use crate::table_functions::TableArgs;
 use crate::table_functions::TableFunction;
-use crate::Table;
 
 const INFER_SCHEMA: &str = "infer_schema";
 

…tions/infer_schema/infer_schema_table.rs …tions/infer_schema/infer_schema_table.rssrc/query/storages/fuse/src/table_functions/infer_schema/infer_schema_table.rs renamed to src/query/service/src/table_functions/infer_schema/infer_schema_table.rs src/query/storages/fuse/src/table_functions/infer_schema/infer_schema_table.rs renamed to src/query/service/src/table_functions/infer_schema/infer_schema_table.rs

@@ -12,12 +12,11 @@
 //  See the License for the specific language governing permissions and
 //  limitations under the License.
 
+use common_catalog::table_args::TableArgs;
 use common_exception::ErrorCode;
 use common_exception::Result;
 use common_storage::StageFilesInfo;
-
-use crate::table_functions::string_value;
-use crate::table_functions::TableArgs;
+use common_storages_fuse::table_functions::string_value;
 
 #[derive(Clone)]
 pub(crate) struct InferSchemaArgsParsed {