Move CreateDatabase

Signed-off-by: Xuanwo <github@xuanwo.io>

Author: Xuanwo

Cargo.lock

@@ -15,7 +15,6 @@
 mod plan_aggregator_final;
 mod plan_aggregator_partial;
 mod plan_broadcast;
-mod plan_database_create;
 mod plan_database_drop;
 mod plan_database_rename;
 mod plan_database_show_create;
@@ -109,7 +108,6 @@ mod plan_window_func;
 pub use plan_aggregator_final::AggregatorFinalPlan;
 pub use plan_aggregator_partial::AggregatorPartialPlan;
 pub use plan_broadcast::BroadcastPlan;
-pub use plan_database_create::CreateDatabasePlan;
 pub use plan_database_drop::DropDatabasePlan;
 pub use plan_database_rename::RenameDatabaseEntity;
 pub use plan_database_rename::RenameDatabasePlan;

src/query/legacy-planners/src/lib.rs

@@ -9,6 +9,7 @@ edition = "2021"
 [dependencies]
 common-catalog = { path = "../catalog" }
 common-datavalues = { path = "../datavalues" }
+common-meta-app = {path = "../../meta/app"}
 
 parking_lot = "0.12"
 serde = { version = "1", features = ["derive"]}

src/query/planner/Cargo.toml

@@ -1,4 +1,4 @@
-// Copyright 2021 Datafuse Labs.
+// Copyright 2022 Datafuse Labs.
 //
 // Licensed under the Apache License, Version 2.0 (the "License");
 // you may not use this file except in compliance with the License.

src/query/legacy-planners/src/plan_database_create.rs renamed to src/query/planner/src/plans/create_database.rs

@@ -14,3 +14,6 @@
 
 mod call;
 pub use call::CallPlan;
+
+mod create_database;
+pub use create_database::CreateDatabasePlan;

src/query/planner/src/plans/mod.rs

@@ -16,7 +16,7 @@ use std::sync::Arc;
 
 use common_exception::ErrorCode;
 use common_exception::Result;
-use common_legacy_planners::CreateDatabasePlan;
+use common_planner::plans::CreateDatabasePlan;
 use common_users::UserApiProvider;
 
 use crate::interpreters::Interpreter;

src/query/service/src/interpreters/interpreter_database_create.rs

@@ -30,14 +30,14 @@ use common_datavalues::DataSchemaRefExt;
 use common_datavalues::ToDataType;
 use common_datavalues::Vu8;
 use common_exception::Result;
-use common_legacy_planners::CreateDatabasePlan;
 use common_legacy_planners::DropDatabasePlan;
 use common_legacy_planners::RenameDatabaseEntity;
 use common_legacy_planners::RenameDatabasePlan;
 use common_legacy_planners::ShowCreateDatabasePlan;
 use common_legacy_planners::UndropDatabasePlan;
 use common_meta_app::schema::DatabaseMeta;
 use common_meta_app::share::ShareNameIdent;
+use common_planner::plans::CreateDatabasePlan;
 
 use crate::sql::binder::Binder;
 use crate::sql::planner::semantic::normalize_identifier;

src/query/service/src/sql/planner/binder/ddl/database.rs

@@ -48,7 +48,6 @@ use common_legacy_planners::AlterTableClusterKeyPlan;
 use common_legacy_planners::AlterUserPlan;
 use common_legacy_planners::AlterUserUDFPlan;
 use common_legacy_planners::AlterViewPlan;
-use common_legacy_planners::CreateDatabasePlan;
 use common_legacy_planners::CreateRolePlan;
 use common_legacy_planners::CreateUserPlan;
 use common_legacy_planners::CreateUserStagePlan;
@@ -85,6 +84,7 @@ use common_legacy_planners::UndropDatabasePlan;
 use common_legacy_planners::UndropTablePlan;
 use common_legacy_planners::UseDatabasePlan;
 use common_planner::plans::CallPlan;
+use common_planner::plans::CreateDatabasePlan;
 use common_planner::MetadataRef;
 pub use copy_v2::CopyPlanV2;
 pub use copy_v2::ValidationMode;

src/query/service/src/sql/planner/plans/mod.rs

@@ -20,13 +20,13 @@ use common_datablocks::assert_blocks_sorted_eq_with_name;
 use common_datablocks::DataBlock;
 use common_datavalues::prelude::*;
 use common_exception::Result;
-use common_legacy_planners::CreateDatabasePlan;
 use common_legacy_planners::Expression;
 use common_legacy_planners::Extras;
 use common_meta_app::schema::DatabaseMeta;
 use common_meta_app::schema::TableMeta;
 use common_pipeline_core::processors::port::OutputPort;
 use common_pipeline_core::SourcePipeBuilder;
+use common_planner::plans::CreateDatabasePlan;
 use common_storage::StorageFsConfig;
 use common_storage::StorageParams;
 use common_streams::SendableDataBlockStream;