refactor(query): merge memory、null、random、result_cache、view into storage_basic (#18547)

Author: zhang2014

Cargo.lock

@@ -65,16 +65,12 @@ members = [
     "src/query/storages/hive/hive",
     "src/query/storages/iceberg",
     "src/query/storages/information_schema",
-    "src/query/storages/memory",
-    "src/query/storages/null",
+    "src/query/storages/basic",
     "src/query/storages/orc",
-    "src/query/storages/random",
     "src/query/storages/stage",
     "src/query/storages/stream",
     "src/query/storages/system",
-    "src/query/storages/view",
     "src/query/storages/parquet",
-    "src/query/storages/result_cache",
     "src/query/users",
     "src/query/ee_features/attach_table",
     "src/query/ee_features/vacuum_handler",
@@ -171,22 +167,18 @@ databend-common-settings = { path = "src/query/settings" }
 databend-common-sql = { path = "src/query/sql" }
 databend-common-sqlsmith = { path = "src/tests/sqlsmith" }
 databend-common-storage = { path = "src/common/storage" }
+databend-common-storages-basic = { path = "src/query/storages/basic" }
 databend-common-storages-delta = { path = "src/query/storages/delta" }
 databend-common-storages-factory = { path = "src/query/storages/factory" }
 databend-common-storages-fuse = { path = "src/query/storages/fuse" }
 databend-common-storages-hive = { path = "src/query/storages/hive/hive" }
 databend-common-storages-iceberg = { path = "src/query/storages/iceberg" }
 databend-common-storages-information-schema = { path = "src/query/storages/information_schema" }
-databend-common-storages-memory = { path = "src/query/storages/memory" }
-databend-common-storages-null = { path = "src/query/storages/null" }
 databend-common-storages-orc = { path = "src/query/storages/orc" }
 databend-common-storages-parquet = { path = "src/query/storages/parquet" }
-databend-common-storages-random = { path = "src/query/storages/random" }
-databend-common-storages-result-cache = { path = "src/query/storages/result_cache" }
 databend-common-storages-stage = { path = "src/query/storages/stage" }
 databend-common-storages-stream = { path = "src/query/storages/stream" }
 databend-common-storages-system = { path = "src/query/storages/system" }
-databend-common-storages-view = { path = "src/query/storages/view" }
 databend-common-telemetry = { path = "src/common/telemetry" }
 databend-common-tracing = { path = "src/common/tracing" }
 databend-common-users = { path = "src/query/users" }

Cargo.toml

@@ -82,21 +82,18 @@ databend-common-script = { workspace = true }
 databend-common-settings = { workspace = true }
 databend-common-sql = { workspace = true }
 databend-common-storage = { workspace = true }
+databend-common-storages-basic = { workspace = true }
 databend-common-storages-delta = { workspace = true }
 databend-common-storages-factory = { workspace = true }
 databend-common-storages-fuse = { workspace = true }
 databend-common-storages-hive = { workspace = true }
 databend-common-storages-iceberg = { workspace = true }
 databend-common-storages-information-schema = { workspace = true }
-databend-common-storages-memory = { workspace = true }
-databend-common-storages-null = { workspace = true }
 databend-common-storages-orc = { workspace = true }
 databend-common-storages-parquet = { workspace = true }
-databend-common-storages-result-cache = { workspace = true }
 databend-common-storages-stage = { workspace = true }
 databend-common-storages-stream = { workspace = true }
 databend-common-storages-system = { workspace = true }
-databend-common-storages-view = { workspace = true }
 databend-common-telemetry = { workspace = true }
 databend-common-tracing = { workspace = true }
 databend-common-users = { workspace = true }

src/query/service/Cargo.toml

@@ -18,8 +18,8 @@ use databend_common_catalog::table_context::TableContext;
 use databend_common_config::GlobalConfig;
 use databend_common_exception::ErrorCode;
 use databend_common_exception::Result;
+use databend_common_storages_basic::view_table::VIEW_ENGINE;
 use databend_common_storages_stream::stream_table::STREAM_ENGINE;
-use databend_common_storages_view::view_table::VIEW_ENGINE;
 
 use crate::interpreters::access::AccessChecker;
 use crate::sessions::QueryContext;

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

@@ -39,10 +39,10 @@ use databend_common_sql::BindContext;
 use databend_common_sql::ColumnSet;
 use databend_common_sql::FormatOptions;
 use databend_common_sql::MetadataRef;
+use databend_common_storages_basic::gen_result_cache_key;
+use databend_common_storages_basic::ResultCacheReader;
 use databend_common_storages_fuse::FuseLazyPartInfo;
 use databend_common_storages_fuse::FuseTable;
-use databend_common_storages_result_cache::gen_result_cache_key;
-use databend_common_storages_result_cache::ResultCacheReader;
 use databend_common_users::UserApiProvider;
 use serde::Serialize;
 use serde_json;

src/query/service/src/interpreters/interpreter_explain.rs

@@ -37,8 +37,8 @@ use databend_common_expression::TableField;
 use databend_common_expression::TableSchema;
 use databend_common_settings::Settings;
 use databend_common_sql::Planner;
+use databend_common_storages_basic::view_table::VIEW_ENGINE;
 use databend_common_storages_stream::stream_table::STREAM_ENGINE;
-use databend_common_storages_view::view_table::VIEW_ENGINE;
 use derive_visitor::DriveMut;
 use derive_visitor::VisitorMut;
 use futures_util::StreamExt;

src/query/service/src/interpreters/interpreter_report_issue.rs

@@ -36,9 +36,9 @@ use databend_common_sql::executor::physical_plans::FragmentKind;
 use databend_common_sql::parse_result_scan_args;
 use databend_common_sql::ColumnBinding;
 use databend_common_sql::MetadataRef;
-use databend_common_storages_result_cache::gen_result_cache_key;
-use databend_common_storages_result_cache::ResultCacheReader;
-use databend_common_storages_result_cache::WriteResultCacheSink;
+use databend_common_storages_basic::gen_result_cache_key;
+use databend_common_storages_basic::ResultCacheReader;
+use databend_common_storages_basic::WriteResultCacheSink;
 use databend_common_users::UserApiProvider;
 use log::error;
 use log::info;

src/query/service/src/interpreters/interpreter_select.rs

@@ -34,9 +34,9 @@ use databend_common_sql::plans::Mutation;
 use databend_common_sql::plans::Plan;
 use databend_common_sql::DefaultExprBinder;
 use databend_common_sql::Planner;
+use databend_common_storages_basic::view_table::VIEW_ENGINE;
 use databend_common_storages_fuse::FuseTable;
 use databend_common_storages_stream::stream_table::STREAM_ENGINE;
-use databend_common_storages_view::view_table::VIEW_ENGINE;
 use databend_storages_common_table_meta::meta::TableSnapshot;
 use databend_storages_common_table_meta::meta::Versioned;
 use databend_storages_common_table_meta::readers::snapshot_reader::TableSnapshotAccessor;

src/query/service/src/interpreters/interpreter_table_add_column.rs

@@ -21,9 +21,9 @@ use databend_common_expression::types::StringType;
 use databend_common_expression::DataBlock;
 use databend_common_expression::FromData;
 use databend_common_sql::plans::DescribeTablePlan;
+use databend_common_storages_basic::view_table::QUERY;
+use databend_common_storages_basic::view_table::VIEW_ENGINE;
 use databend_common_storages_fuse::TableContext;
-use databend_common_storages_view::view_table::QUERY;
-use databend_common_storages_view::view_table::VIEW_ENGINE;
 
 use crate::interpreters::util::generate_desc_schema;
 use crate::interpreters::Interpreter;

src/query/service/src/interpreters/interpreter_table_describe.rs

@@ -22,9 +22,9 @@ use databend_common_meta_app::principal::OwnershipObject;
 use databend_common_meta_app::schema::DropTableByIdReq;
 use databend_common_sql::plans::DropTablePlan;
 use databend_common_sql::plans::TruncateMode;
+use databend_common_storages_basic::view_table::VIEW_ENGINE;
 use databend_common_storages_fuse::FuseTable;
 use databend_common_storages_stream::stream_table::STREAM_ENGINE;
-use databend_common_storages_view::view_table::VIEW_ENGINE;
 use databend_common_users::RoleCacheManager;
 use databend_common_users::UserApiProvider;
 use databend_storages_common_table_meta::table::OPT_KEY_TEMP_PREFIX;