Merge pull request #7762 from Xuanwo/remove-old-create-interpreter

refactor: Remove the old planner's interpreter creation

Author: Xuanwo

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

@@ -16,7 +16,6 @@ use std::collections::HashMap;
 use std::sync::Arc;
 
 use common_exception::Result;
-use common_legacy_planners::PlanNode;
 
 use crate::interpreters::access::PrivilegeAccess;
 use crate::interpreters::ManagementModeAccess;
@@ -25,12 +24,8 @@ use crate::sql::plans::Plan;
 
 #[async_trait::async_trait]
 pub trait AccessChecker: Sync + Send {
-    // Check the access permission for the old plan.
-    // TODO(bohu): Remove after new plan done.
-    async fn check(&self, plan: &PlanNode) -> Result<()>;
-
-    // Check the access permission for the old plan.
-    async fn check_new(&self, _plan: &Plan) -> Result<()>;
+    // Check the access permission for the plan.
+    async fn check(&self, _plan: &Plan) -> Result<()>;
 }
 
 pub struct Accessor {
@@ -48,17 +43,10 @@ impl Accessor {
         Accessor { accessors }
     }
 
-    pub async fn check(&self, plan: &PlanNode) -> Result<()> {
+    pub async fn check(&self, plan: &Plan) -> Result<()> {
         for accessor in self.accessors.values() {
             accessor.check(plan).await?;
         }
         Ok(())
     }
-
-    pub async fn check_new(&self, plan: &Plan) -> Result<()> {
-        for accessor in self.accessors.values() {
-            accessor.check_new(plan).await?;
-        }
-        Ok(())
-    }
 }

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

@@ -16,7 +16,6 @@ use std::sync::Arc;
 
 use common_exception::ErrorCode;
 use common_exception::Result;
-use common_legacy_planners::PlanNode;
 
 use crate::interpreters::access::AccessChecker;
 use crate::sessions::QueryContext;
@@ -36,22 +35,7 @@ impl ManagementModeAccess {
 #[async_trait::async_trait]
 impl AccessChecker for ManagementModeAccess {
     // Check what we can do if in management mode.
-    async fn check(&self, plan: &PlanNode) -> Result<()> {
-        // Allows for management-mode.
-        if self.ctx.get_config().query.management_mode {
-            return match plan {
-                PlanNode::Empty(_) => Ok(()),
-                _ => Err(ErrorCode::ManagementModePermissionDenied(format!(
-                    "Access denied for operation:{:?} in management-mode",
-                    plan.name()
-                ))),
-            };
-        };
-        Ok(())
-    }
-
-    // Check what we can do if in management mode.
-    async fn check_new(&self, plan: &Plan) -> Result<()> {
+    async fn check(&self, plan: &Plan) -> Result<()> {
         // Allows for management-mode.
         if self.ctx.get_config().query.management_mode {
             let ok = match plan {

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

@@ -15,7 +15,6 @@
 use std::sync::Arc;
 
 use common_exception::Result;
-use common_legacy_planners::PlanNode;
 use common_meta_types::GrantObject;
 use common_meta_types::UserPrivilegeType;
 
@@ -35,12 +34,7 @@ impl PrivilegeAccess {
 
 #[async_trait::async_trait]
 impl AccessChecker for PrivilegeAccess {
-    async fn check(&self, _plan: &PlanNode) -> Result<()> {
-        // The old planner *NO* need to check anymore.
-        Ok(())
-    }
-
-    async fn check_new(&self, plan: &Plan) -> Result<()> {
+    async fn check(&self, plan: &Plan) -> Result<()> {
         let session = self.ctx.get_current_session();
 
         match plan {