feat(meta): Support create dictionary meta api (#16178)

* feat(query): support parse create dictionary stmt * feat(query): support parse create dictionary stmt * feat(query): support parse create dictionary stmt * feat(query): support parse create dictionary stmt * feat(query): support parse create dictionary stmt * feat(meta): support meta store proto * feat(meta): support meta store proto * feat(meta): support meta store proto * feat(meta): support meta store proto * feat(meta): support meta store proto * feat(meta): support meta store proto * feat(meta): support meta store proto * feat(meta): support meta store proto * feat(meta): support meta store proto * feat(meta): support meta store proto * feat(meta): support meta store proto * feat(meta): support meta store proto * feat(meta): support meta store proto * feat(meta): support meta store proto * feat(meta): support meta store proto * feat(meta): support meta store proto * feat(meta): support meta store proto * feat(meta): support meta store proto * feat(meta): support meta store proto * feat(meta): support meta store proto * feat(meta): support meta store proto * feat(meta): support meta store proto * feat(meta): support meta store proto * feat(meta): support meta store proto * feat(meta): support meta store proto * feat(meta): support meta store proto * feat(meta): support meta store proto * feat(meta): support meta store proto * feat(meta): support meta store proto * feat(meta): support meta store proto * feat(meta): support meta store proto * feat(meta): support meta store proto * feat(meta): support meta store proto * feat(meta): support meta store proto * feat(meta): support meta store proto * feat(meta): support meta store proto * feat(meta): support meta store proto * feat(meta): support meta store proto * feat(meta): support meta store proto * feat(meta): support meta store proto * feat(meta): support meta store proto * feat(meta): support meta store proto * feat(meta): support meta store proto * feat(meta): support meta store proto * feat(meta): support meta store proto * feat(meta): support meta store proto * feat(meta): support meta store proto * feat(meta): support meta store proto * feat(meta): support meta store proto * feat(meta): support meta store proto * feat(meta): support meta store proto * feat(meta): support meta store proto * feat(meta): support meta store proto * feat(meta): support meta store proto * feat(meta): support meta store proto * feat(meta): support meta store proto * feat(meta): support meta store proto * feat(meta): support meta store proto * feat(meta): support meta store proto * feat(meta): support meta store proto * feat(meta): support meta store proto * feat(meta): support meta store proto * feat(meta): support meta store proto * feat(meta): support meta store proto * feat(meta): support meta store proto * feat(meta): support meta store proto * feat(meta): support meta store proto * feat(meta): support meta store proto * feat(meta): support meta store proto * feat(meta): support meta store proto * feat(meta): support meta store proto * feat(meta): support meta store proto * feat(meta): support meta store proto * feat(meta): support meta store proto * feat(meta): support meta store proto * feat(meta): support meta store proto * feat(meta): support meta store proto * feat(meta): support meta store proto * feat(meta): support meta store proto * feat(meta): support meta store proto * feat(meta): support meta store proto * feat(meta): support meta store proto * feat(meta): support meta store proto
databendlabs · Aug 13, 2024 · a3a878b · a3a878b
1 parent c09bc28
commit a3a878b
Show file tree

Hide file tree

Showing 16 changed files with 1,131 additions and 1 deletion.
diff --git a/src/common/exception/src/exception_code.rs b/src/common/exception/src/exception_code.rs
@@ -383,6 +383,10 @@ build_exceptions! {
     // Share error codes(continue).
     ErrorShareEndpointCredential(3111),
     WrongSharePrivileges(3112),
+
+    // dictionary
+    DictionaryAlreadyExists(3113),
+    UnknownDictionary(3114),
 }
 
 // Storage errors [3001, 4000].

diff --git a/src/meta/api/src/schema_api.rs b/src/meta/api/src/schema_api.rs
@@ -14,13 +14,16 @@
 
 use std::sync::Arc;
 
+use databend_common_meta_app::schema::tenant_dictionary_ident::TenantDictionaryIdent;
 use databend_common_meta_app::schema::CatalogInfo;
 use databend_common_meta_app::schema::CommitTableMetaReply;
 use databend_common_meta_app::schema::CommitTableMetaReq;
 use databend_common_meta_app::schema::CreateCatalogReply;
 use databend_common_meta_app::schema::CreateCatalogReq;
 use databend_common_meta_app::schema::CreateDatabaseReply;
 use databend_common_meta_app::schema::CreateDatabaseReq;
+use databend_common_meta_app::schema::CreateDictionaryReply;
+use databend_common_meta_app::schema::CreateDictionaryReq;
 use databend_common_meta_app::schema::CreateIndexReply;
 use databend_common_meta_app::schema::CreateIndexReq;
 use databend_common_meta_app::schema::CreateLockRevReply;
@@ -33,6 +36,7 @@ use databend_common_meta_app::schema::CreateVirtualColumnReply;
 use databend_common_meta_app::schema::CreateVirtualColumnReq;
 use databend_common_meta_app::schema::DatabaseInfo;
 use databend_common_meta_app::schema::DeleteLockRevReq;
+use databend_common_meta_app::schema::DictionaryMeta;
 use databend_common_meta_app::schema::DropCatalogReply;
 use databend_common_meta_app::schema::DropCatalogReq;
 use databend_common_meta_app::schema::DropDatabaseReply;
@@ -50,6 +54,7 @@ use databend_common_meta_app::schema::GcDroppedTableReq;
 use databend_common_meta_app::schema::GcDroppedTableResp;
 use databend_common_meta_app::schema::GetCatalogReq;
 use databend_common_meta_app::schema::GetDatabaseReq;
+use databend_common_meta_app::schema::GetDictionaryReply;
 use databend_common_meta_app::schema::GetIndexReply;
 use databend_common_meta_app::schema::GetIndexReq;
 use databend_common_meta_app::schema::GetLVTReply;
@@ -60,6 +65,7 @@ use databend_common_meta_app::schema::GetTableReq;
 use databend_common_meta_app::schema::IndexMeta;
 use databend_common_meta_app::schema::ListCatalogReq;
 use databend_common_meta_app::schema::ListDatabaseReq;
+use databend_common_meta_app::schema::ListDictionaryReq;
 use databend_common_meta_app::schema::ListDroppedTableReq;
 use databend_common_meta_app::schema::ListDroppedTableResp;
 use databend_common_meta_app::schema::ListIndexesByIdReq;
@@ -87,6 +93,8 @@ use databend_common_meta_app::schema::UndropDatabaseReq;
 use databend_common_meta_app::schema::UndropTableByIdReq;
 use databend_common_meta_app::schema::UndropTableReply;
 use databend_common_meta_app::schema::UndropTableReq;
+use databend_common_meta_app::schema::UpdateDictionaryReply;
+use databend_common_meta_app::schema::UpdateDictionaryReq;
 use databend_common_meta_app::schema::UpdateIndexReply;
 use databend_common_meta_app::schema::UpdateIndexReq;
 use databend_common_meta_app::schema::UpdateMultiTableMetaReq;
@@ -304,4 +312,30 @@ pub trait SchemaApi: Send + Sync {
     async fn get_table_lvt(&self, req: GetLVTReq) -> Result<GetLVTReply, KVAppError>;
 
     fn name(&self) -> String;
+
+    // dictionary
+    async fn create_dictionary(
+        &self,
+        req: CreateDictionaryReq,
+    ) -> Result<CreateDictionaryReply, KVAppError>;
+
+    async fn update_dictionary(
+        &self,
+        req: UpdateDictionaryReq,
+    ) -> Result<UpdateDictionaryReply, KVAppError>;
+
+    async fn drop_dictionary(
+        &self,
+        dict_ident: TenantDictionaryIdent,
+    ) -> Result<Option<SeqV<DictionaryMeta>>, KVAppError>;
+
+    async fn get_dictionary(
+        &self,
+        req: TenantDictionaryIdent,
+    ) -> Result<Option<GetDictionaryReply>, KVAppError>;
+
+    async fn list_dictionaries(
+        &self,
+        req: ListDictionaryReq,
+    ) -> Result<Vec<(String, DictionaryMeta)>, KVAppError>;
 }