feat: add table lock manager to fix table lock cannot be released

Cargo.toml

@@ -53,6 +53,7 @@ members = [
     "src/query/storages/common/cache",
     "src/query/storages/common/cache_manager",
     "src/query/storages/common/index",
+    "src/query/storages/common/locks",
     "src/query/storages/common/pruner",
     "src/query/storages/common/table_meta",
     "src/query/storages/factory",
@@ -74,7 +75,6 @@ members = [
     "src/query/ee_features/background_service",
     "src/query/ee_features/aggregating_index",
     "src/query/ee_features/data_mask",
-    "src/query/ee_features/table_lock",
     "src/query/ee_features/storage_encryption",
     # databend-query
     "src/query/service",

src/meta/api/src/schema_api.rs

@@ -23,14 +23,14 @@ use common_meta_app::schema::CreateDatabaseReply;
 use common_meta_app::schema::CreateDatabaseReq;
 use common_meta_app::schema::CreateIndexReply;
 use common_meta_app::schema::CreateIndexReq;
-use common_meta_app::schema::CreateTableLockRevReply;
-use common_meta_app::schema::CreateTableLockRevReq;
+use common_meta_app::schema::CreateLockRevReply;
+use common_meta_app::schema::CreateLockRevReq;
 use common_meta_app::schema::CreateTableReply;
 use common_meta_app::schema::CreateTableReq;
 use common_meta_app::schema::CreateVirtualColumnReply;
 use common_meta_app::schema::CreateVirtualColumnReq;
 use common_meta_app::schema::DatabaseInfo;
-use common_meta_app::schema::DeleteTableLockRevReq;
+use common_meta_app::schema::DeleteLockRevReq;
 use common_meta_app::schema::DropCatalogReply;
 use common_meta_app::schema::DropCatalogReq;
 use common_meta_app::schema::DropDatabaseReply;
@@ -41,7 +41,7 @@ use common_meta_app::schema::DropTableByIdReq;
 use common_meta_app::schema::DropTableReply;
 use common_meta_app::schema::DropVirtualColumnReply;
 use common_meta_app::schema::DropVirtualColumnReq;
-use common_meta_app::schema::ExtendTableLockRevReq;
+use common_meta_app::schema::ExtendLockRevReq;
 use common_meta_app::schema::GcDroppedTableReq;
 use common_meta_app::schema::GcDroppedTableResp;
 use common_meta_app::schema::GetCatalogReq;
@@ -60,9 +60,10 @@ use common_meta_app::schema::ListDroppedTableReq;
 use common_meta_app::schema::ListDroppedTableResp;
 use common_meta_app::schema::ListIndexesByIdReq;
 use common_meta_app::schema::ListIndexesReq;
-use common_meta_app::schema::ListTableLockRevReq;
+use common_meta_app::schema::ListLockRevReq;
 use common_meta_app::schema::ListTableReq;
 use common_meta_app::schema::ListVirtualColumnsReq;
+use common_meta_app::schema::LockMeta;
 use common_meta_app::schema::RenameDatabaseReply;
 use common_meta_app::schema::RenameDatabaseReq;
 use common_meta_app::schema::RenameTableReply;
@@ -240,16 +241,19 @@ pub trait SchemaApi: Send + Sync {
 
     async fn count_tables(&self, req: CountTablesReq) -> Result<CountTablesReply, KVAppError>;
 
-    async fn list_table_lock_revs(&self, req: ListTableLockRevReq) -> Result<Vec<u64>, KVAppError>;
+    async fn list_lock_revisions(
+        &self,
+        req: ListLockRevReq,
+    ) -> Result<Vec<(u64, LockMeta)>, KVAppError>;
 
-    async fn create_table_lock_rev(
+    async fn create_lock_revision(
         &self,
-        req: CreateTableLockRevReq,
-    ) -> Result<CreateTableLockRevReply, KVAppError>;
+        req: CreateLockRevReq,
+    ) -> Result<CreateLockRevReply, KVAppError>;
 
-    async fn extend_table_lock_rev(&self, req: ExtendTableLockRevReq) -> Result<(), KVAppError>;
+    async fn extend_lock_revision(&self, req: ExtendLockRevReq) -> Result<(), KVAppError>;
 
-    async fn delete_table_lock_rev(&self, req: DeleteTableLockRevReq) -> Result<(), KVAppError>;
+    async fn delete_lock_revision(&self, req: DeleteLockRevReq) -> Result<(), KVAppError>;
 
     async fn create_catalog(&self, req: CreateCatalogReq)
     -> Result<CreateCatalogReply, KVAppError>;