Remove old create table

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

Author: Xuanwo

src/query/planners/src/lib.rs

@@ -82,7 +82,6 @@ mod plan_sink;
 mod plan_sort;
 mod plan_subqueries_set;
 mod plan_table_alter_cluster_key;
-mod plan_table_create;
 mod plan_table_describe;
 mod plan_table_drop;
 mod plan_table_drop_cluster_key;
@@ -222,8 +221,6 @@ pub use plan_sink::SINK_SCHEMA;
 pub use plan_sort::SortPlan;
 pub use plan_subqueries_set::SubQueriesSetPlan;
 pub use plan_table_alter_cluster_key::AlterTableClusterKeyPlan;
-pub use plan_table_create::CreateTablePlan;
-pub use plan_table_create::TableOptions;
 pub use plan_table_describe::DescribeTablePlan;
 pub use plan_table_drop::DropTablePlan;
 pub use plan_table_drop_cluster_key::DropTableClusterKeyPlan;

src/query/planners/src/plan_table_create.rs

@@ -60,7 +60,6 @@ mod interpreter_share_show;
 mod interpreter_share_show_grant_tenants;
 mod interpreter_show_grants;
 mod interpreter_show_object_grant_privileges;
-mod interpreter_table_create;
 mod interpreter_table_create_v2;
 mod interpreter_table_describe;
 mod interpreter_table_drop;
@@ -138,7 +137,7 @@ pub use interpreter_share_show::ShowSharesInterpreter;
 pub use interpreter_share_show_grant_tenants::ShowGrantTenantsOfShareInterpreter;
 pub use interpreter_show_grants::ShowGrantsInterpreter;
 pub use interpreter_show_object_grant_privileges::ShowObjectGrantPrivilegesInterpreter;
-pub use interpreter_table_create::CreateTableInterpreter;
+pub use interpreter_table_create_v2::CreateTableInterpreterV2;
 pub use interpreter_table_describe::DescribeTableInterpreter;
 pub use interpreter_table_drop::DropTableInterpreter;
 pub use interpreter_table_exists::ExistsTableInterpreter;

src/query/service/src/interpreters/interpreter_table_create.rs

@@ -26,7 +26,7 @@ use common_fuse_meta::meta::ColumnStatistics;
 use common_planners::Extras;
 use common_planners::Projection;
 use common_storages_fuse::ColumnLeaves;
-use databend_query::interpreters::CreateTableInterpreter;
+use databend_query::interpreters::CreateTableInterpreterV2;
 use databend_query::interpreters::Interpreter;
 use databend_query::storages::fuse::ColumnLeaf;
 use databend_query::storages::fuse::FuseTable;
@@ -147,7 +147,7 @@ async fn test_fuse_table_exact_statistic() -> Result<()> {
     let ctx = fixture.ctx();
 
     let create_table_plan = fixture.default_crate_table_plan();
-    let interpreter = CreateTableInterpreter::try_create(ctx.clone(), create_table_plan)?;
+    let interpreter = CreateTableInterpreterV2::try_create(ctx.clone(), create_table_plan)?;
     interpreter.execute().await?;
 
     let mut table = fixture.latest_default_table().await?;

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

@@ -25,13 +25,13 @@ use common_planners::add;
 use common_planners::col;
 use common_planners::lit;
 use common_planners::sub;
-use common_planners::CreateTablePlan;
 use common_planners::Expression;
 use common_planners::Extras;
-use databend_query::interpreters::CreateTableInterpreter;
+use databend_query::interpreters::CreateTableInterpreterV2;
 use databend_query::interpreters::Interpreter;
 use databend_query::sessions::QueryContext;
 use databend_query::sessions::TableContext;
+use databend_query::sql::plans::CreateTablePlanV2;
 use databend_query::sql::OPT_KEY_DATABASE_ID;
 use databend_query::sql::OPT_KEY_SNAPSHOT_LOCATION;
 use databend_query::storages::fuse::io::MetaReaders;
@@ -70,7 +70,7 @@ async fn test_block_pruner() -> Result<()> {
     let num_blocks_opt = row_per_block.to_string();
 
     // create test table
-    let create_table_plan = CreateTablePlan {
+    let create_table_plan = CreateTablePlanV2 {
         catalog: "default".to_owned(),
         if_not_exists: false,
         tenant: fixture.default_tenant(),
@@ -91,7 +91,7 @@ async fn test_block_pruner() -> Result<()> {
         cluster_keys: vec![],
     };
 
-    let interpreter = CreateTableInterpreter::try_create(ctx.clone(), create_table_plan)?;
+    let interpreter = CreateTableInterpreterV2::try_create(ctx.clone(), create_table_plan)?;
     let _ = interpreter.execute().await?;
 
     // get table
@@ -216,7 +216,7 @@ async fn test_block_pruner_monotonic() -> Result<()> {
     let num_blocks_opt = row_per_block.to_string();
 
     // create test table
-    let create_table_plan = CreateTablePlan {
+    let create_table_plan = CreateTablePlanV2 {
         catalog: "default".to_owned(),
         if_not_exists: false,
         tenant: fixture.default_tenant(),
@@ -240,7 +240,7 @@ async fn test_block_pruner_monotonic() -> Result<()> {
     };
 
     let catalog = ctx.get_catalog("default")?;
-    let interpreter = CreateTableInterpreter::try_create(ctx.clone(), create_table_plan)?;
+    let interpreter = CreateTableInterpreterV2::try_create(ctx.clone(), create_table_plan)?;
     interpreter.execute().await?;
 
     // get table